Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterContractValidatorServer(s grpc.ServiceRegistrar, srv ContractValidatorServer)
- type BreakingChange
- func (*BreakingChange) Descriptor() ([]byte, []int)deprecated
- func (x *BreakingChange) GetDescription() string
- func (x *BreakingChange) GetMethod() string
- func (x *BreakingChange) GetNewValue() string
- func (x *BreakingChange) GetOldValue() string
- func (x *BreakingChange) GetPath() string
- func (x *BreakingChange) GetType() BreakingChangeType
- func (*BreakingChange) ProtoMessage()
- func (x *BreakingChange) ProtoReflect() protoreflect.Message
- func (x *BreakingChange) Reset()
- func (x *BreakingChange) String() string
- type BreakingChangeType
- func (BreakingChangeType) Descriptor() protoreflect.EnumDescriptor
- func (x BreakingChangeType) Enum() *BreakingChangeType
- func (BreakingChangeType) EnumDescriptor() ([]byte, []int)deprecated
- func (x BreakingChangeType) Number() protoreflect.EnumNumber
- func (x BreakingChangeType) String() string
- func (BreakingChangeType) Type() protoreflect.EnumType
- type CanIDeployRequest
- func (*CanIDeployRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CanIDeployRequest) GetEnvironment() string
- func (x *CanIDeployRequest) GetNewVersion() string
- func (x *CanIDeployRequest) GetSchemaId() string
- func (*CanIDeployRequest) ProtoMessage()
- func (x *CanIDeployRequest) ProtoReflect() protoreflect.Message
- func (x *CanIDeployRequest) Reset()
- func (x *CanIDeployRequest) String() string
- type CanIDeployResponse
- func (*CanIDeployResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CanIDeployResponse) GetAffectedConsumers() []*ConsumerImpact
- func (x *CanIDeployResponse) GetBreakingChanges() []*BreakingChange
- func (x *CanIDeployResponse) GetSafeToDeploy() bool
- func (x *CanIDeployResponse) GetSummary() string
- func (*CanIDeployResponse) ProtoMessage()
- func (x *CanIDeployResponse) ProtoReflect() protoreflect.Message
- func (x *CanIDeployResponse) Reset()
- func (x *CanIDeployResponse) String() string
- type CompareSchemasRequest
- func (*CompareSchemasRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CompareSchemasRequest) GetNewVersion() string
- func (x *CompareSchemasRequest) GetOldVersion() string
- func (x *CompareSchemasRequest) GetSchemaId() string
- func (*CompareSchemasRequest) ProtoMessage()
- func (x *CompareSchemasRequest) ProtoReflect() protoreflect.Message
- func (x *CompareSchemasRequest) Reset()
- func (x *CompareSchemasRequest) String() string
- type CompareSchemasResponse
- func (*CompareSchemasResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CompareSchemasResponse) GetBreakingChanges() []*BreakingChange
- func (x *CompareSchemasResponse) GetCompatible() bool
- func (x *CompareSchemasResponse) GetNewSchema() *SchemaMetadata
- func (x *CompareSchemasResponse) GetOldSchema() *SchemaMetadata
- func (*CompareSchemasResponse) ProtoMessage()
- func (x *CompareSchemasResponse) ProtoReflect() protoreflect.Message
- func (x *CompareSchemasResponse) Reset()
- func (x *CompareSchemasResponse) String() string
- type ConsumerImpact
- func (*ConsumerImpact) Descriptor() ([]byte, []int)deprecated
- func (x *ConsumerImpact) GetConsumerId() string
- func (x *ConsumerImpact) GetConsumerVersion() string
- func (x *ConsumerImpact) GetCurrentSchemaVersion() string
- func (x *ConsumerImpact) GetEnvironment() string
- func (x *ConsumerImpact) GetRelevantChanges() []*BreakingChange
- func (x *ConsumerImpact) GetWillBreak() bool
- func (*ConsumerImpact) ProtoMessage()
- func (x *ConsumerImpact) ProtoReflect() protoreflect.Message
- func (x *ConsumerImpact) Reset()
- func (x *ConsumerImpact) String() string
- type ConsumerInfo
- func (*ConsumerInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ConsumerInfo) GetConsumerId() string
- func (x *ConsumerInfo) GetConsumerVersion() string
- func (x *ConsumerInfo) GetEnvironment() string
- func (x *ConsumerInfo) GetLastValidatedAt() int64
- func (x *ConsumerInfo) GetRegisteredAt() int64
- func (x *ConsumerInfo) GetSchemaId() string
- func (x *ConsumerInfo) GetSchemaVersion() string
- func (x *ConsumerInfo) GetUsedEndpoints() []*EndpointUsage
- func (*ConsumerInfo) ProtoMessage()
- func (x *ConsumerInfo) ProtoReflect() protoreflect.Message
- func (x *ConsumerInfo) Reset()
- func (x *ConsumerInfo) String() string
- type ContractValidatorClient
- type ContractValidatorServer
- type DeregisterConsumerRequest
- func (*DeregisterConsumerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeregisterConsumerRequest) GetConsumerId() string
- func (x *DeregisterConsumerRequest) GetEnvironment() string
- func (x *DeregisterConsumerRequest) GetSchemaId() string
- func (*DeregisterConsumerRequest) ProtoMessage()
- func (x *DeregisterConsumerRequest) ProtoReflect() protoreflect.Message
- func (x *DeregisterConsumerRequest) Reset()
- func (x *DeregisterConsumerRequest) String() string
- type DeregisterConsumerResponse
- func (*DeregisterConsumerResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeregisterConsumerResponse) GetMessage() string
- func (x *DeregisterConsumerResponse) GetSuccess() bool
- func (*DeregisterConsumerResponse) ProtoMessage()
- func (x *DeregisterConsumerResponse) ProtoReflect() protoreflect.Message
- func (x *DeregisterConsumerResponse) Reset()
- func (x *DeregisterConsumerResponse) String() string
- type EndpointInfo
- func (*EndpointInfo) Descriptor() ([]byte, []int)deprecated
- func (x *EndpointInfo) GetMethod() string
- func (x *EndpointInfo) GetOperationId() string
- func (x *EndpointInfo) GetPath() string
- func (x *EndpointInfo) GetSummary() string
- func (*EndpointInfo) ProtoMessage()
- func (x *EndpointInfo) ProtoReflect() protoreflect.Message
- func (x *EndpointInfo) Reset()
- func (x *EndpointInfo) String() string
- type EndpointUsage
- func (*EndpointUsage) Descriptor() ([]byte, []int)deprecated
- func (x *EndpointUsage) GetMethod() string
- func (x *EndpointUsage) GetPath() string
- func (x *EndpointUsage) GetUsedFields() []string
- func (*EndpointUsage) ProtoMessage()
- func (x *EndpointUsage) ProtoReflect() protoreflect.Message
- func (x *EndpointUsage) Reset()
- func (x *EndpointUsage) String() string
- type GenerateFixtureRequest
- func (*GenerateFixtureRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GenerateFixtureRequest) GetContentType() string
- func (x *GenerateFixtureRequest) GetMethod() string
- func (x *GenerateFixtureRequest) GetOutputType() OutputType
- func (x *GenerateFixtureRequest) GetPath() string
- func (x *GenerateFixtureRequest) GetSchemaId() string
- func (x *GenerateFixtureRequest) GetStatusCode() int32
- func (x *GenerateFixtureRequest) GetUseExamples() bool
- func (*GenerateFixtureRequest) ProtoMessage()
- func (x *GenerateFixtureRequest) ProtoReflect() protoreflect.Message
- func (x *GenerateFixtureRequest) Reset()
- func (x *GenerateFixtureRequest) String() string
- type GenerateFixtureResponse
- func (*GenerateFixtureResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GenerateFixtureResponse) GetFixture() *GeneratedFixture
- func (x *GenerateFixtureResponse) GetMessage() string
- func (x *GenerateFixtureResponse) GetRequestBody() string
- func (x *GenerateFixtureResponse) GetResponse() *GeneratedResponse
- func (x *GenerateFixtureResponse) GetSuccess() bool
- func (*GenerateFixtureResponse) ProtoMessage()
- func (x *GenerateFixtureResponse) ProtoReflect() protoreflect.Message
- func (x *GenerateFixtureResponse) Reset()
- func (x *GenerateFixtureResponse) String() string
- type GeneratedFixture
- func (*GeneratedFixture) Descriptor() ([]byte, []int)deprecated
- func (x *GeneratedFixture) GetRequest() *GeneratedRequest
- func (x *GeneratedFixture) GetResponse() *GeneratedResponse
- func (*GeneratedFixture) ProtoMessage()
- func (x *GeneratedFixture) ProtoReflect() protoreflect.Message
- func (x *GeneratedFixture) Reset()
- func (x *GeneratedFixture) String() string
- type GeneratedRequest
- func (*GeneratedRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GeneratedRequest) GetBody() string
- func (x *GeneratedRequest) GetHeaders() map[string]string
- func (x *GeneratedRequest) GetMethod() string
- func (x *GeneratedRequest) GetPath() string
- func (*GeneratedRequest) ProtoMessage()
- func (x *GeneratedRequest) ProtoReflect() protoreflect.Message
- func (x *GeneratedRequest) Reset()
- func (x *GeneratedRequest) String() string
- type GeneratedResponse
- func (*GeneratedResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GeneratedResponse) GetBody() string
- func (x *GeneratedResponse) GetHeaders() map[string]string
- func (x *GeneratedResponse) GetStatusCode() int32
- func (*GeneratedResponse) ProtoMessage()
- func (x *GeneratedResponse) ProtoReflect() protoreflect.Message
- func (x *GeneratedResponse) Reset()
- func (x *GeneratedResponse) String() string
- type GetSchemaRequest
- func (*GetSchemaRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetSchemaRequest) GetSchemaId() string
- func (x *GetSchemaRequest) GetSchemaVersion() string
- func (*GetSchemaRequest) ProtoMessage()
- func (x *GetSchemaRequest) ProtoReflect() protoreflect.Message
- func (x *GetSchemaRequest) Reset()
- func (x *GetSchemaRequest) String() string
- type GetSchemaResponse
- func (*GetSchemaResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetSchemaResponse) GetFound() bool
- func (x *GetSchemaResponse) GetMetadata() *SchemaMetadata
- func (x *GetSchemaResponse) GetSchemaContent() string
- func (*GetSchemaResponse) ProtoMessage()
- func (x *GetSchemaResponse) ProtoReflect() protoreflect.Message
- func (x *GetSchemaResponse) Reset()
- func (x *GetSchemaResponse) String() string
- type InteractionRequest
- func (*InteractionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InteractionRequest) GetRequest() *RequestData
- func (x *InteractionRequest) GetResponse() *ResponseData
- func (x *InteractionRequest) GetSchemaId() string
- func (x *InteractionRequest) GetSchemaVersion() string
- func (*InteractionRequest) ProtoMessage()
- func (x *InteractionRequest) ProtoReflect() protoreflect.Message
- func (x *InteractionRequest) Reset()
- func (x *InteractionRequest) String() string
- type ListConsumersRequest
- func (*ListConsumersRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListConsumersRequest) GetEnvironment() string
- func (x *ListConsumersRequest) GetSchemaId() string
- func (*ListConsumersRequest) ProtoMessage()
- func (x *ListConsumersRequest) ProtoReflect() protoreflect.Message
- func (x *ListConsumersRequest) Reset()
- func (x *ListConsumersRequest) String() string
- type ListConsumersResponse
- func (*ListConsumersResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListConsumersResponse) GetConsumers() []*ConsumerInfo
- func (*ListConsumersResponse) ProtoMessage()
- func (x *ListConsumersResponse) ProtoReflect() protoreflect.Message
- func (x *ListConsumersResponse) Reset()
- func (x *ListConsumersResponse) String() string
- type ListEndpointsRequest
- func (*ListEndpointsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListEndpointsRequest) GetSchemaId() string
- func (*ListEndpointsRequest) ProtoMessage()
- func (x *ListEndpointsRequest) ProtoReflect() protoreflect.Message
- func (x *ListEndpointsRequest) Reset()
- func (x *ListEndpointsRequest) String() string
- type ListEndpointsResponse
- func (*ListEndpointsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListEndpointsResponse) GetEndpoints() []*EndpointInfo
- func (*ListEndpointsResponse) ProtoMessage()
- func (x *ListEndpointsResponse) ProtoReflect() protoreflect.Message
- func (x *ListEndpointsResponse) Reset()
- func (x *ListEndpointsResponse) String() string
- type ListSchemasRequest
- func (*ListSchemasRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListSchemasRequest) GetOwner() string
- func (x *ListSchemasRequest) GetPageSize() int32
- func (x *ListSchemasRequest) GetPageToken() string
- func (x *ListSchemasRequest) GetTeam() string
- func (*ListSchemasRequest) ProtoMessage()
- func (x *ListSchemasRequest) ProtoReflect() protoreflect.Message
- func (x *ListSchemasRequest) Reset()
- func (x *ListSchemasRequest) String() string
- type ListSchemasResponse
- func (*ListSchemasResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListSchemasResponse) GetNextPageToken() string
- func (x *ListSchemasResponse) GetSchemas() []*SchemaMetadata
- func (x *ListSchemasResponse) GetTotalCount() int32
- func (*ListSchemasResponse) ProtoMessage()
- func (x *ListSchemasResponse) ProtoReflect() protoreflect.Message
- func (x *ListSchemasResponse) Reset()
- func (x *ListSchemasResponse) String() string
- type OutputType
- type RegisterConsumerRequest
- func (*RegisterConsumerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterConsumerRequest) GetConsumerId() string
- func (x *RegisterConsumerRequest) GetConsumerVersion() string
- func (x *RegisterConsumerRequest) GetEnvironment() string
- func (x *RegisterConsumerRequest) GetSchemaId() string
- func (x *RegisterConsumerRequest) GetSchemaVersion() string
- func (x *RegisterConsumerRequest) GetUsedEndpoints() []*EndpointUsage
- func (*RegisterConsumerRequest) ProtoMessage()
- func (x *RegisterConsumerRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterConsumerRequest) Reset()
- func (x *RegisterConsumerRequest) String() string
- type RegisterConsumerResponse
- func (*RegisterConsumerResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterConsumerResponse) GetConsumer() *ConsumerInfo
- func (x *RegisterConsumerResponse) GetMessage() string
- func (x *RegisterConsumerResponse) GetSuccess() bool
- func (*RegisterConsumerResponse) ProtoMessage()
- func (x *RegisterConsumerResponse) ProtoReflect() protoreflect.Message
- func (x *RegisterConsumerResponse) Reset()
- func (x *RegisterConsumerResponse) String() string
- type RegisterSchemaRequest
- func (*RegisterSchemaRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterSchemaRequest) GetCheckCompatibility() bool
- func (x *RegisterSchemaRequest) GetOwnership() *SchemaOwnership
- func (x *RegisterSchemaRequest) GetSchemaContent() string
- func (x *RegisterSchemaRequest) GetSchemaId() string
- func (x *RegisterSchemaRequest) GetSchemaVersion() string
- func (*RegisterSchemaRequest) ProtoMessage()
- func (x *RegisterSchemaRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterSchemaRequest) Reset()
- func (x *RegisterSchemaRequest) String() string
- type RegisterSchemaResponse
- func (*RegisterSchemaResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterSchemaResponse) GetBreakingChanges() []*BreakingChange
- func (x *RegisterSchemaResponse) GetMessage() string
- func (x *RegisterSchemaResponse) GetMetadata() *SchemaMetadata
- func (x *RegisterSchemaResponse) GetSuccess() bool
- func (*RegisterSchemaResponse) ProtoMessage()
- func (x *RegisterSchemaResponse) ProtoReflect() protoreflect.Message
- func (x *RegisterSchemaResponse) Reset()
- func (x *RegisterSchemaResponse) String() string
- type RequestData
- func (*RequestData) Descriptor() ([]byte, []int)deprecated
- func (x *RequestData) GetBody() string
- func (x *RequestData) GetHeaders() map[string]string
- func (x *RequestData) GetMethod() string
- func (x *RequestData) GetPath() string
- func (*RequestData) ProtoMessage()
- func (x *RequestData) ProtoReflect() protoreflect.Message
- func (x *RequestData) Reset()
- func (x *RequestData) String() string
- type ResponseData
- func (*ResponseData) Descriptor() ([]byte, []int)deprecated
- func (x *ResponseData) GetBody() string
- func (x *ResponseData) GetHeaders() map[string]string
- func (x *ResponseData) GetStatusCode() int32
- func (*ResponseData) ProtoMessage()
- func (x *ResponseData) ProtoReflect() protoreflect.Message
- func (x *ResponseData) Reset()
- func (x *ResponseData) String() string
- type SchemaMetadata
- func (*SchemaMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *SchemaMetadata) GetEndpointCount() int32
- func (x *SchemaMetadata) GetOpenapiVersion() string
- func (x *SchemaMetadata) GetOwnership() *SchemaOwnership
- func (x *SchemaMetadata) GetRegisteredAt() int64
- func (x *SchemaMetadata) GetSchemaHash() string
- func (x *SchemaMetadata) GetSchemaId() string
- func (x *SchemaMetadata) GetSchemaVersion() string
- func (x *SchemaMetadata) GetUpdatedAt() int64
- func (*SchemaMetadata) ProtoMessage()
- func (x *SchemaMetadata) ProtoReflect() protoreflect.Message
- func (x *SchemaMetadata) Reset()
- func (x *SchemaMetadata) String() string
- type SchemaOwnership
- func (*SchemaOwnership) Descriptor() ([]byte, []int)deprecated
- func (x *SchemaOwnership) GetContactEmail() string
- func (x *SchemaOwnership) GetOwner() string
- func (x *SchemaOwnership) GetReadOnly() bool
- func (x *SchemaOwnership) GetTeam() string
- func (*SchemaOwnership) ProtoMessage()
- func (x *SchemaOwnership) ProtoReflect() protoreflect.Message
- func (x *SchemaOwnership) Reset()
- func (x *SchemaOwnership) String() string
- type UnimplementedContractValidatorServer
- func (UnimplementedContractValidatorServer) CanIDeploy(context.Context, *CanIDeployRequest) (*CanIDeployResponse, error)
- func (UnimplementedContractValidatorServer) CompareSchemas(context.Context, *CompareSchemasRequest) (*CompareSchemasResponse, error)
- func (UnimplementedContractValidatorServer) DeregisterConsumer(context.Context, *DeregisterConsumerRequest) (*DeregisterConsumerResponse, error)
- func (UnimplementedContractValidatorServer) GenerateFixture(context.Context, *GenerateFixtureRequest) (*GenerateFixtureResponse, error)
- func (UnimplementedContractValidatorServer) GetSchema(context.Context, *GetSchemaRequest) (*GetSchemaResponse, error)
- func (UnimplementedContractValidatorServer) ListConsumers(context.Context, *ListConsumersRequest) (*ListConsumersResponse, error)
- func (UnimplementedContractValidatorServer) ListEndpoints(context.Context, *ListEndpointsRequest) (*ListEndpointsResponse, error)
- func (UnimplementedContractValidatorServer) ListSchemas(context.Context, *ListSchemasRequest) (*ListSchemasResponse, error)
- func (UnimplementedContractValidatorServer) RegisterConsumer(context.Context, *RegisterConsumerRequest) (*RegisterConsumerResponse, error)
- func (UnimplementedContractValidatorServer) RegisterSchema(context.Context, *RegisterSchemaRequest) (*RegisterSchemaResponse, error)
- func (UnimplementedContractValidatorServer) ValidateInteraction(context.Context, *InteractionRequest) (*ValidationResult, error)
- func (UnimplementedContractValidatorServer) ValidateProducerResponse(context.Context, *ValidateProducerRequest) (*ValidationResult, error)
- type UnsafeContractValidatorServer
- type ValidateProducerRequest
- func (*ValidateProducerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ValidateProducerRequest) GetMethod() string
- func (x *ValidateProducerRequest) GetPath() string
- func (x *ValidateProducerRequest) GetRequest() *RequestData
- func (x *ValidateProducerRequest) GetResponse() *ResponseData
- func (x *ValidateProducerRequest) GetSchemaId() string
- func (x *ValidateProducerRequest) GetSchemaVersion() string
- func (*ValidateProducerRequest) ProtoMessage()
- func (x *ValidateProducerRequest) ProtoReflect() protoreflect.Message
- func (x *ValidateProducerRequest) Reset()
- func (x *ValidateProducerRequest) String() string
- type ValidationResult
- func (*ValidationResult) Descriptor() ([]byte, []int)deprecated
- func (x *ValidationResult) GetErrors() []string
- func (x *ValidationResult) GetValid() bool
- func (x *ValidationResult) GetValidatedAgainstHash() string
- func (x *ValidationResult) GetValidatedAgainstVersion() string
- func (*ValidationResult) ProtoMessage()
- func (x *ValidationResult) ProtoReflect() protoreflect.Message
- func (x *ValidationResult) Reset()
- func (x *ValidationResult) String() string
Constants ¶
const ( ContractValidator_RegisterSchema_FullMethodName = "/cvt.ContractValidator/RegisterSchema" ContractValidator_ValidateInteraction_FullMethodName = "/cvt.ContractValidator/ValidateInteraction" ContractValidator_GetSchema_FullMethodName = "/cvt.ContractValidator/GetSchema" ContractValidator_ListSchemas_FullMethodName = "/cvt.ContractValidator/ListSchemas" ContractValidator_CompareSchemas_FullMethodName = "/cvt.ContractValidator/CompareSchemas" ContractValidator_GenerateFixture_FullMethodName = "/cvt.ContractValidator/GenerateFixture" ContractValidator_ListEndpoints_FullMethodName = "/cvt.ContractValidator/ListEndpoints" ContractValidator_ValidateProducerResponse_FullMethodName = "/cvt.ContractValidator/ValidateProducerResponse" ContractValidator_RegisterConsumer_FullMethodName = "/cvt.ContractValidator/RegisterConsumer" ContractValidator_ListConsumers_FullMethodName = "/cvt.ContractValidator/ListConsumers" ContractValidator_DeregisterConsumer_FullMethodName = "/cvt.ContractValidator/DeregisterConsumer" ContractValidator_CanIDeploy_FullMethodName = "/cvt.ContractValidator/CanIDeploy" )
Variables ¶
var ( BreakingChangeType_name = map[int32]string{ 0: "BREAKING_CHANGE_UNSPECIFIED", 1: "ENDPOINT_REMOVED", 2: "REQUIRED_FIELD_ADDED", 3: "TYPE_CHANGED", 4: "REQUIRED_PARAMETER_ADDED", 5: "RESPONSE_SCHEMA_CHANGED", 6: "ENUM_VALUE_REMOVED", } BreakingChangeType_value = map[string]int32{ "BREAKING_CHANGE_UNSPECIFIED": 0, "ENDPOINT_REMOVED": 1, "REQUIRED_FIELD_ADDED": 2, "TYPE_CHANGED": 3, "REQUIRED_PARAMETER_ADDED": 4, "RESPONSE_SCHEMA_CHANGED": 5, "ENUM_VALUE_REMOVED": 6, } )
Enum value maps for BreakingChangeType.
var ( OutputType_name = map[int32]string{ 0: "OUTPUT_FIXTURE", 1: "OUTPUT_REQUEST", 2: "OUTPUT_RESPONSE", } OutputType_value = map[string]int32{ "OUTPUT_FIXTURE": 0, "OUTPUT_REQUEST": 1, "OUTPUT_RESPONSE": 2, } )
Enum value maps for OutputType.
var ContractValidator_ServiceDesc = grpc.ServiceDesc{ ServiceName: "cvt.ContractValidator", HandlerType: (*ContractValidatorServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "RegisterSchema", Handler: _ContractValidator_RegisterSchema_Handler, }, { MethodName: "ValidateInteraction", Handler: _ContractValidator_ValidateInteraction_Handler, }, { MethodName: "GetSchema", Handler: _ContractValidator_GetSchema_Handler, }, { MethodName: "ListSchemas", Handler: _ContractValidator_ListSchemas_Handler, }, { MethodName: "CompareSchemas", Handler: _ContractValidator_CompareSchemas_Handler, }, { MethodName: "GenerateFixture", Handler: _ContractValidator_GenerateFixture_Handler, }, { MethodName: "ListEndpoints", Handler: _ContractValidator_ListEndpoints_Handler, }, { MethodName: "ValidateProducerResponse", Handler: _ContractValidator_ValidateProducerResponse_Handler, }, { MethodName: "RegisterConsumer", Handler: _ContractValidator_RegisterConsumer_Handler, }, { MethodName: "ListConsumers", Handler: _ContractValidator_ListConsumers_Handler, }, { MethodName: "DeregisterConsumer", Handler: _ContractValidator_DeregisterConsumer_Handler, }, { MethodName: "CanIDeploy", Handler: _ContractValidator_CanIDeploy_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "api/protos/cvt.proto", }
ContractValidator_ServiceDesc is the grpc.ServiceDesc for ContractValidator service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_api_protos_cvt_proto protoreflect.FileDescriptor
Functions ¶
func RegisterContractValidatorServer ¶
func RegisterContractValidatorServer(s grpc.ServiceRegistrar, srv ContractValidatorServer)
Types ¶
type BreakingChange ¶
type BreakingChange struct {
Type BreakingChangeType `protobuf:"varint,1,opt,name=type,proto3,enum=cvt.BreakingChangeType" json:"type,omitempty"`
Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` // API path affected (e.g., "/users/{id}")
Method string `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"` // HTTP method affected (e.g., "POST")
Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"` // Human-readable description
OldValue string `protobuf:"bytes,5,opt,name=old_value,json=oldValue,proto3" json:"old_value,omitempty"` // Previous value (for context)
NewValue string `protobuf:"bytes,6,opt,name=new_value,json=newValue,proto3" json:"new_value,omitempty"` // New value (for context)
// contains filtered or unexported fields
}
Breaking change detected between schema versions
func (*BreakingChange) Descriptor
deprecated
func (*BreakingChange) Descriptor() ([]byte, []int)
Deprecated: Use BreakingChange.ProtoReflect.Descriptor instead.
func (*BreakingChange) GetDescription ¶
func (x *BreakingChange) GetDescription() string
func (*BreakingChange) GetMethod ¶
func (x *BreakingChange) GetMethod() string
func (*BreakingChange) GetNewValue ¶
func (x *BreakingChange) GetNewValue() string
func (*BreakingChange) GetOldValue ¶
func (x *BreakingChange) GetOldValue() string
func (*BreakingChange) GetPath ¶
func (x *BreakingChange) GetPath() string
func (*BreakingChange) GetType ¶
func (x *BreakingChange) GetType() BreakingChangeType
func (*BreakingChange) ProtoMessage ¶
func (*BreakingChange) ProtoMessage()
func (*BreakingChange) ProtoReflect ¶
func (x *BreakingChange) ProtoReflect() protoreflect.Message
func (*BreakingChange) Reset ¶
func (x *BreakingChange) Reset()
func (*BreakingChange) String ¶
func (x *BreakingChange) String() string
type BreakingChangeType ¶
type BreakingChangeType int32
const ( BreakingChangeType_BREAKING_CHANGE_UNSPECIFIED BreakingChangeType = 0 BreakingChangeType_ENDPOINT_REMOVED BreakingChangeType = 1 // Endpoint path+method was removed BreakingChangeType_REQUIRED_FIELD_ADDED BreakingChangeType = 2 // Required field added to request body BreakingChangeType_TYPE_CHANGED BreakingChangeType = 3 // Field type changed incompatibly BreakingChangeType_REQUIRED_PARAMETER_ADDED BreakingChangeType = 4 // Required query/path/header param added BreakingChangeType_RESPONSE_SCHEMA_CHANGED BreakingChangeType = 5 // Response schema changed incompatibly BreakingChangeType_ENUM_VALUE_REMOVED BreakingChangeType = 6 // Enum value was removed )
func (BreakingChangeType) Descriptor ¶
func (BreakingChangeType) Descriptor() protoreflect.EnumDescriptor
func (BreakingChangeType) Enum ¶
func (x BreakingChangeType) Enum() *BreakingChangeType
func (BreakingChangeType) EnumDescriptor
deprecated
func (BreakingChangeType) EnumDescriptor() ([]byte, []int)
Deprecated: Use BreakingChangeType.Descriptor instead.
func (BreakingChangeType) Number ¶
func (x BreakingChangeType) Number() protoreflect.EnumNumber
func (BreakingChangeType) String ¶
func (x BreakingChangeType) String() string
func (BreakingChangeType) Type ¶
func (BreakingChangeType) Type() protoreflect.EnumType
type CanIDeployRequest ¶
type CanIDeployRequest struct {
SchemaId string `protobuf:"bytes,1,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty"` // Schema to deploy
NewVersion string `protobuf:"bytes,2,opt,name=new_version,json=newVersion,proto3" json:"new_version,omitempty"` // New version to deploy
Environment string `protobuf:"bytes,3,opt,name=environment,proto3" json:"environment,omitempty"` // Target environment (dev, staging, prod)
// contains filtered or unexported fields
}
Request to check deployment safety
func (*CanIDeployRequest) Descriptor
deprecated
func (*CanIDeployRequest) Descriptor() ([]byte, []int)
Deprecated: Use CanIDeployRequest.ProtoReflect.Descriptor instead.
func (*CanIDeployRequest) GetEnvironment ¶
func (x *CanIDeployRequest) GetEnvironment() string
func (*CanIDeployRequest) GetNewVersion ¶
func (x *CanIDeployRequest) GetNewVersion() string
func (*CanIDeployRequest) GetSchemaId ¶
func (x *CanIDeployRequest) GetSchemaId() string
func (*CanIDeployRequest) ProtoMessage ¶
func (*CanIDeployRequest) ProtoMessage()
func (*CanIDeployRequest) ProtoReflect ¶
func (x *CanIDeployRequest) ProtoReflect() protoreflect.Message
func (*CanIDeployRequest) Reset ¶
func (x *CanIDeployRequest) Reset()
func (*CanIDeployRequest) String ¶
func (x *CanIDeployRequest) String() string
type CanIDeployResponse ¶
type CanIDeployResponse struct {
SafeToDeploy bool `protobuf:"varint,1,opt,name=safe_to_deploy,json=safeToDeploy,proto3" json:"safe_to_deploy,omitempty"` // True if safe to deploy
Summary string `protobuf:"bytes,2,opt,name=summary,proto3" json:"summary,omitempty"` // Human-readable summary
BreakingChanges []*BreakingChange `protobuf:"bytes,3,rep,name=breaking_changes,json=breakingChanges,proto3" json:"breaking_changes,omitempty"` // All breaking changes in new version
AffectedConsumers []*ConsumerImpact `protobuf:"bytes,4,rep,name=affected_consumers,json=affectedConsumers,proto3" json:"affected_consumers,omitempty"` // Impact on each consumer
// contains filtered or unexported fields
}
Response with deployment safety analysis
func (*CanIDeployResponse) Descriptor
deprecated
func (*CanIDeployResponse) Descriptor() ([]byte, []int)
Deprecated: Use CanIDeployResponse.ProtoReflect.Descriptor instead.
func (*CanIDeployResponse) GetAffectedConsumers ¶
func (x *CanIDeployResponse) GetAffectedConsumers() []*ConsumerImpact
func (*CanIDeployResponse) GetBreakingChanges ¶
func (x *CanIDeployResponse) GetBreakingChanges() []*BreakingChange
func (*CanIDeployResponse) GetSafeToDeploy ¶
func (x *CanIDeployResponse) GetSafeToDeploy() bool
func (*CanIDeployResponse) GetSummary ¶
func (x *CanIDeployResponse) GetSummary() string
func (*CanIDeployResponse) ProtoMessage ¶
func (*CanIDeployResponse) ProtoMessage()
func (*CanIDeployResponse) ProtoReflect ¶
func (x *CanIDeployResponse) ProtoReflect() protoreflect.Message
func (*CanIDeployResponse) Reset ¶
func (x *CanIDeployResponse) Reset()
func (*CanIDeployResponse) String ¶
func (x *CanIDeployResponse) String() string
type CompareSchemasRequest ¶
type CompareSchemasRequest struct {
SchemaId string `protobuf:"bytes,1,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty"`
OldVersion string `protobuf:"bytes,2,opt,name=old_version,json=oldVersion,proto3" json:"old_version,omitempty"` // Version to compare from (empty = previous)
NewVersion string `protobuf:"bytes,3,opt,name=new_version,json=newVersion,proto3" json:"new_version,omitempty"` // Version to compare to (empty = latest)
// contains filtered or unexported fields
}
Request to compare two schema versions
func (*CompareSchemasRequest) Descriptor
deprecated
func (*CompareSchemasRequest) Descriptor() ([]byte, []int)
Deprecated: Use CompareSchemasRequest.ProtoReflect.Descriptor instead.
func (*CompareSchemasRequest) GetNewVersion ¶
func (x *CompareSchemasRequest) GetNewVersion() string
func (*CompareSchemasRequest) GetOldVersion ¶
func (x *CompareSchemasRequest) GetOldVersion() string
func (*CompareSchemasRequest) GetSchemaId ¶
func (x *CompareSchemasRequest) GetSchemaId() string
func (*CompareSchemasRequest) ProtoMessage ¶
func (*CompareSchemasRequest) ProtoMessage()
func (*CompareSchemasRequest) ProtoReflect ¶
func (x *CompareSchemasRequest) ProtoReflect() protoreflect.Message
func (*CompareSchemasRequest) Reset ¶
func (x *CompareSchemasRequest) Reset()
func (*CompareSchemasRequest) String ¶
func (x *CompareSchemasRequest) String() string
type CompareSchemasResponse ¶
type CompareSchemasResponse struct {
Compatible bool `protobuf:"varint,1,opt,name=compatible,proto3" json:"compatible,omitempty"` // True if no breaking changes
BreakingChanges []*BreakingChange `protobuf:"bytes,2,rep,name=breaking_changes,json=breakingChanges,proto3" json:"breaking_changes,omitempty"`
OldSchema *SchemaMetadata `protobuf:"bytes,3,opt,name=old_schema,json=oldSchema,proto3" json:"old_schema,omitempty"`
NewSchema *SchemaMetadata `protobuf:"bytes,4,opt,name=new_schema,json=newSchema,proto3" json:"new_schema,omitempty"`
// contains filtered or unexported fields
}
func (*CompareSchemasResponse) Descriptor
deprecated
func (*CompareSchemasResponse) Descriptor() ([]byte, []int)
Deprecated: Use CompareSchemasResponse.ProtoReflect.Descriptor instead.
func (*CompareSchemasResponse) GetBreakingChanges ¶
func (x *CompareSchemasResponse) GetBreakingChanges() []*BreakingChange
func (*CompareSchemasResponse) GetCompatible ¶
func (x *CompareSchemasResponse) GetCompatible() bool
func (*CompareSchemasResponse) GetNewSchema ¶
func (x *CompareSchemasResponse) GetNewSchema() *SchemaMetadata
func (*CompareSchemasResponse) GetOldSchema ¶
func (x *CompareSchemasResponse) GetOldSchema() *SchemaMetadata
func (*CompareSchemasResponse) ProtoMessage ¶
func (*CompareSchemasResponse) ProtoMessage()
func (*CompareSchemasResponse) ProtoReflect ¶
func (x *CompareSchemasResponse) ProtoReflect() protoreflect.Message
func (*CompareSchemasResponse) Reset ¶
func (x *CompareSchemasResponse) Reset()
func (*CompareSchemasResponse) String ¶
func (x *CompareSchemasResponse) String() string
type ConsumerImpact ¶
type ConsumerImpact struct {
ConsumerId string `protobuf:"bytes,1,opt,name=consumer_id,json=consumerId,proto3" json:"consumer_id,omitempty"`
ConsumerVersion string `protobuf:"bytes,2,opt,name=consumer_version,json=consumerVersion,proto3" json:"consumer_version,omitempty"`
CurrentSchemaVersion string `protobuf:"bytes,3,opt,name=current_schema_version,json=currentSchemaVersion,proto3" json:"current_schema_version,omitempty"` // Version consumer was tested against
Environment string `protobuf:"bytes,4,opt,name=environment,proto3" json:"environment,omitempty"`
WillBreak bool `protobuf:"varint,5,opt,name=will_break,json=willBreak,proto3" json:"will_break,omitempty"` // True if consumer will be affected
RelevantChanges []*BreakingChange `protobuf:"bytes,6,rep,name=relevant_changes,json=relevantChanges,proto3" json:"relevant_changes,omitempty"` // Breaking changes affecting this consumer
// contains filtered or unexported fields
}
Impact of schema changes on a specific consumer
func (*ConsumerImpact) Descriptor
deprecated
func (*ConsumerImpact) Descriptor() ([]byte, []int)
Deprecated: Use ConsumerImpact.ProtoReflect.Descriptor instead.
func (*ConsumerImpact) GetConsumerId ¶
func (x *ConsumerImpact) GetConsumerId() string
func (*ConsumerImpact) GetConsumerVersion ¶
func (x *ConsumerImpact) GetConsumerVersion() string
func (*ConsumerImpact) GetCurrentSchemaVersion ¶
func (x *ConsumerImpact) GetCurrentSchemaVersion() string
func (*ConsumerImpact) GetEnvironment ¶
func (x *ConsumerImpact) GetEnvironment() string
func (*ConsumerImpact) GetRelevantChanges ¶
func (x *ConsumerImpact) GetRelevantChanges() []*BreakingChange
func (*ConsumerImpact) GetWillBreak ¶
func (x *ConsumerImpact) GetWillBreak() bool
func (*ConsumerImpact) ProtoMessage ¶
func (*ConsumerImpact) ProtoMessage()
func (*ConsumerImpact) ProtoReflect ¶
func (x *ConsumerImpact) ProtoReflect() protoreflect.Message
func (*ConsumerImpact) Reset ¶
func (x *ConsumerImpact) Reset()
func (*ConsumerImpact) String ¶
func (x *ConsumerImpact) String() string
type ConsumerInfo ¶
type ConsumerInfo struct {
ConsumerId string `protobuf:"bytes,1,opt,name=consumer_id,json=consumerId,proto3" json:"consumer_id,omitempty"` // Unique consumer identifier (e.g., "order-service")
ConsumerVersion string `protobuf:"bytes,2,opt,name=consumer_version,json=consumerVersion,proto3" json:"consumer_version,omitempty"` // Consumer's version (e.g., "2.1.0")
SchemaId string `protobuf:"bytes,3,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty"` // Schema this consumer depends on
SchemaVersion string `protobuf:"bytes,4,opt,name=schema_version,json=schemaVersion,proto3" json:"schema_version,omitempty"` // Schema version consumer was tested against
Environment string `protobuf:"bytes,5,opt,name=environment,proto3" json:"environment,omitempty"` // Environment (dev, staging, prod)
RegisteredAt int64 `protobuf:"varint,6,opt,name=registered_at,json=registeredAt,proto3" json:"registered_at,omitempty"` // Unix timestamp of registration
LastValidatedAt int64 `protobuf:"varint,7,opt,name=last_validated_at,json=lastValidatedAt,proto3" json:"last_validated_at,omitempty"` // Unix timestamp of last successful validation
UsedEndpoints []*EndpointUsage `protobuf:"bytes,8,rep,name=used_endpoints,json=usedEndpoints,proto3" json:"used_endpoints,omitempty"` // Which endpoints the consumer uses
// contains filtered or unexported fields
}
Information about a consumer's dependency on a schema
func (*ConsumerInfo) Descriptor
deprecated
func (*ConsumerInfo) Descriptor() ([]byte, []int)
Deprecated: Use ConsumerInfo.ProtoReflect.Descriptor instead.
func (*ConsumerInfo) GetConsumerId ¶
func (x *ConsumerInfo) GetConsumerId() string
func (*ConsumerInfo) GetConsumerVersion ¶
func (x *ConsumerInfo) GetConsumerVersion() string
func (*ConsumerInfo) GetEnvironment ¶
func (x *ConsumerInfo) GetEnvironment() string
func (*ConsumerInfo) GetLastValidatedAt ¶
func (x *ConsumerInfo) GetLastValidatedAt() int64
func (*ConsumerInfo) GetRegisteredAt ¶
func (x *ConsumerInfo) GetRegisteredAt() int64
func (*ConsumerInfo) GetSchemaId ¶
func (x *ConsumerInfo) GetSchemaId() string
func (*ConsumerInfo) GetSchemaVersion ¶
func (x *ConsumerInfo) GetSchemaVersion() string
func (*ConsumerInfo) GetUsedEndpoints ¶
func (x *ConsumerInfo) GetUsedEndpoints() []*EndpointUsage
func (*ConsumerInfo) ProtoMessage ¶
func (*ConsumerInfo) ProtoMessage()
func (*ConsumerInfo) ProtoReflect ¶
func (x *ConsumerInfo) ProtoReflect() protoreflect.Message
func (*ConsumerInfo) Reset ¶
func (x *ConsumerInfo) Reset()
func (*ConsumerInfo) String ¶
func (x *ConsumerInfo) String() string
type ContractValidatorClient ¶
type ContractValidatorClient interface {
// Registers an OpenAPI schema for future validation
RegisterSchema(ctx context.Context, in *RegisterSchemaRequest, opts ...grpc.CallOption) (*RegisterSchemaResponse, error)
// Validates a single request/response interaction against a registered schema
ValidateInteraction(ctx context.Context, in *InteractionRequest, opts ...grpc.CallOption) (*ValidationResult, error)
// Gets metadata for a registered schema
GetSchema(ctx context.Context, in *GetSchemaRequest, opts ...grpc.CallOption) (*GetSchemaResponse, error)
// Lists all registered schemas
ListSchemas(ctx context.Context, in *ListSchemasRequest, opts ...grpc.CallOption) (*ListSchemasResponse, error)
// Compares two schema versions for breaking changes
CompareSchemas(ctx context.Context, in *CompareSchemasRequest, opts ...grpc.CallOption) (*CompareSchemasResponse, error)
// Generates test fixtures from an OpenAPI schema
GenerateFixture(ctx context.Context, in *GenerateFixtureRequest, opts ...grpc.CallOption) (*GenerateFixtureResponse, error)
// Lists all endpoints available in a schema
ListEndpoints(ctx context.Context, in *ListEndpointsRequest, opts ...grpc.CallOption) (*ListEndpointsResponse, error)
// Validates a producer's response against its OpenAPI schema (for producer contract tests)
ValidateProducerResponse(ctx context.Context, in *ValidateProducerRequest, opts ...grpc.CallOption) (*ValidationResult, error)
// Registers a consumer's dependency on a schema
RegisterConsumer(ctx context.Context, in *RegisterConsumerRequest, opts ...grpc.CallOption) (*RegisterConsumerResponse, error)
// Lists all consumers that depend on a schema
ListConsumers(ctx context.Context, in *ListConsumersRequest, opts ...grpc.CallOption) (*ListConsumersResponse, error)
// Removes a consumer registration
DeregisterConsumer(ctx context.Context, in *DeregisterConsumerRequest, opts ...grpc.CallOption) (*DeregisterConsumerResponse, error)
// Checks if a schema version can be safely deployed
CanIDeploy(ctx context.Context, in *CanIDeployRequest, opts ...grpc.CallOption) (*CanIDeployResponse, error)
}
ContractValidatorClient is the client API for ContractValidator service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewContractValidatorClient ¶
func NewContractValidatorClient(cc grpc.ClientConnInterface) ContractValidatorClient
type ContractValidatorServer ¶
type ContractValidatorServer interface {
// Registers an OpenAPI schema for future validation
RegisterSchema(context.Context, *RegisterSchemaRequest) (*RegisterSchemaResponse, error)
// Validates a single request/response interaction against a registered schema
ValidateInteraction(context.Context, *InteractionRequest) (*ValidationResult, error)
// Gets metadata for a registered schema
GetSchema(context.Context, *GetSchemaRequest) (*GetSchemaResponse, error)
// Lists all registered schemas
ListSchemas(context.Context, *ListSchemasRequest) (*ListSchemasResponse, error)
// Compares two schema versions for breaking changes
CompareSchemas(context.Context, *CompareSchemasRequest) (*CompareSchemasResponse, error)
// Generates test fixtures from an OpenAPI schema
GenerateFixture(context.Context, *GenerateFixtureRequest) (*GenerateFixtureResponse, error)
// Lists all endpoints available in a schema
ListEndpoints(context.Context, *ListEndpointsRequest) (*ListEndpointsResponse, error)
// Validates a producer's response against its OpenAPI schema (for producer contract tests)
ValidateProducerResponse(context.Context, *ValidateProducerRequest) (*ValidationResult, error)
// Registers a consumer's dependency on a schema
RegisterConsumer(context.Context, *RegisterConsumerRequest) (*RegisterConsumerResponse, error)
// Lists all consumers that depend on a schema
ListConsumers(context.Context, *ListConsumersRequest) (*ListConsumersResponse, error)
// Removes a consumer registration
DeregisterConsumer(context.Context, *DeregisterConsumerRequest) (*DeregisterConsumerResponse, error)
// Checks if a schema version can be safely deployed
CanIDeploy(context.Context, *CanIDeployRequest) (*CanIDeployResponse, error)
// contains filtered or unexported methods
}
ContractValidatorServer is the server API for ContractValidator service. All implementations must embed UnimplementedContractValidatorServer for forward compatibility.
type DeregisterConsumerRequest ¶
type DeregisterConsumerRequest struct {
ConsumerId string `protobuf:"bytes,1,opt,name=consumer_id,json=consumerId,proto3" json:"consumer_id,omitempty"`
SchemaId string `protobuf:"bytes,2,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty"` // Required: which schema dependency to remove
Environment string `protobuf:"bytes,3,opt,name=environment,proto3" json:"environment,omitempty"`
// contains filtered or unexported fields
}
Request to remove a consumer registration
func (*DeregisterConsumerRequest) Descriptor
deprecated
func (*DeregisterConsumerRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeregisterConsumerRequest.ProtoReflect.Descriptor instead.
func (*DeregisterConsumerRequest) GetConsumerId ¶
func (x *DeregisterConsumerRequest) GetConsumerId() string
func (*DeregisterConsumerRequest) GetEnvironment ¶
func (x *DeregisterConsumerRequest) GetEnvironment() string
func (*DeregisterConsumerRequest) GetSchemaId ¶
func (x *DeregisterConsumerRequest) GetSchemaId() string
func (*DeregisterConsumerRequest) ProtoMessage ¶
func (*DeregisterConsumerRequest) ProtoMessage()
func (*DeregisterConsumerRequest) ProtoReflect ¶
func (x *DeregisterConsumerRequest) ProtoReflect() protoreflect.Message
func (*DeregisterConsumerRequest) Reset ¶
func (x *DeregisterConsumerRequest) Reset()
func (*DeregisterConsumerRequest) String ¶
func (x *DeregisterConsumerRequest) String() string
type DeregisterConsumerResponse ¶
type DeregisterConsumerResponse struct {
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
Response from consumer deregistration
func (*DeregisterConsumerResponse) Descriptor
deprecated
func (*DeregisterConsumerResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeregisterConsumerResponse.ProtoReflect.Descriptor instead.
func (*DeregisterConsumerResponse) GetMessage ¶
func (x *DeregisterConsumerResponse) GetMessage() string
func (*DeregisterConsumerResponse) GetSuccess ¶
func (x *DeregisterConsumerResponse) GetSuccess() bool
func (*DeregisterConsumerResponse) ProtoMessage ¶
func (*DeregisterConsumerResponse) ProtoMessage()
func (*DeregisterConsumerResponse) ProtoReflect ¶
func (x *DeregisterConsumerResponse) ProtoReflect() protoreflect.Message
func (*DeregisterConsumerResponse) Reset ¶
func (x *DeregisterConsumerResponse) Reset()
func (*DeregisterConsumerResponse) String ¶
func (x *DeregisterConsumerResponse) String() string
type EndpointInfo ¶
type EndpointInfo struct {
Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"` // HTTP method
Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` // API path
OperationId string `protobuf:"bytes,3,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"` // OpenAPI operationId (if defined)
Summary string `protobuf:"bytes,4,opt,name=summary,proto3" json:"summary,omitempty"` // OpenAPI summary (if defined)
// contains filtered or unexported fields
}
func (*EndpointInfo) Descriptor
deprecated
func (*EndpointInfo) Descriptor() ([]byte, []int)
Deprecated: Use EndpointInfo.ProtoReflect.Descriptor instead.
func (*EndpointInfo) GetMethod ¶
func (x *EndpointInfo) GetMethod() string
func (*EndpointInfo) GetOperationId ¶
func (x *EndpointInfo) GetOperationId() string
func (*EndpointInfo) GetPath ¶
func (x *EndpointInfo) GetPath() string
func (*EndpointInfo) GetSummary ¶
func (x *EndpointInfo) GetSummary() string
func (*EndpointInfo) ProtoMessage ¶
func (*EndpointInfo) ProtoMessage()
func (*EndpointInfo) ProtoReflect ¶
func (x *EndpointInfo) ProtoReflect() protoreflect.Message
func (*EndpointInfo) Reset ¶
func (x *EndpointInfo) Reset()
func (*EndpointInfo) String ¶
func (x *EndpointInfo) String() string
type EndpointUsage ¶
type EndpointUsage struct {
Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"` // HTTP method
Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` // API path
UsedFields []string `protobuf:"bytes,3,rep,name=used_fields,json=usedFields,proto3" json:"used_fields,omitempty"` // Fields used in response (e.g., ["email", "name"])
// contains filtered or unexported fields
}
Describes which endpoints and fields a consumer uses
func (*EndpointUsage) Descriptor
deprecated
func (*EndpointUsage) Descriptor() ([]byte, []int)
Deprecated: Use EndpointUsage.ProtoReflect.Descriptor instead.
func (*EndpointUsage) GetMethod ¶
func (x *EndpointUsage) GetMethod() string
func (*EndpointUsage) GetPath ¶
func (x *EndpointUsage) GetPath() string
func (*EndpointUsage) GetUsedFields ¶
func (x *EndpointUsage) GetUsedFields() []string
func (*EndpointUsage) ProtoMessage ¶
func (*EndpointUsage) ProtoMessage()
func (*EndpointUsage) ProtoReflect ¶
func (x *EndpointUsage) ProtoReflect() protoreflect.Message
func (*EndpointUsage) Reset ¶
func (x *EndpointUsage) Reset()
func (*EndpointUsage) String ¶
func (x *EndpointUsage) String() string
type GenerateFixtureRequest ¶
type GenerateFixtureRequest struct {
SchemaId string `protobuf:"bytes,1,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty"` // Schema to generate fixtures from
Method string `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"` // HTTP method (GET, POST, etc.)
Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"` // API path (e.g., /users/{id})
StatusCode int32 `protobuf:"varint,4,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"` // Response status code (0 = auto-select)
UseExamples bool `protobuf:"varint,5,opt,name=use_examples,json=useExamples,proto3" json:"use_examples,omitempty"` // Use schema examples when available
ContentType string `protobuf:"bytes,6,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"` // Content type (default: application/json)
OutputType OutputType `protobuf:"varint,7,opt,name=output_type,json=outputType,proto3,enum=cvt.OutputType" json:"output_type,omitempty"` // What to generate
// contains filtered or unexported fields
}
Request to generate test fixtures
func (*GenerateFixtureRequest) Descriptor
deprecated
func (*GenerateFixtureRequest) Descriptor() ([]byte, []int)
Deprecated: Use GenerateFixtureRequest.ProtoReflect.Descriptor instead.
func (*GenerateFixtureRequest) GetContentType ¶
func (x *GenerateFixtureRequest) GetContentType() string
func (*GenerateFixtureRequest) GetMethod ¶
func (x *GenerateFixtureRequest) GetMethod() string
func (*GenerateFixtureRequest) GetOutputType ¶
func (x *GenerateFixtureRequest) GetOutputType() OutputType
func (*GenerateFixtureRequest) GetPath ¶
func (x *GenerateFixtureRequest) GetPath() string
func (*GenerateFixtureRequest) GetSchemaId ¶
func (x *GenerateFixtureRequest) GetSchemaId() string
func (*GenerateFixtureRequest) GetStatusCode ¶
func (x *GenerateFixtureRequest) GetStatusCode() int32
func (*GenerateFixtureRequest) GetUseExamples ¶
func (x *GenerateFixtureRequest) GetUseExamples() bool
func (*GenerateFixtureRequest) ProtoMessage ¶
func (*GenerateFixtureRequest) ProtoMessage()
func (*GenerateFixtureRequest) ProtoReflect ¶
func (x *GenerateFixtureRequest) ProtoReflect() protoreflect.Message
func (*GenerateFixtureRequest) Reset ¶
func (x *GenerateFixtureRequest) Reset()
func (*GenerateFixtureRequest) String ¶
func (x *GenerateFixtureRequest) String() string
type GenerateFixtureResponse ¶
type GenerateFixtureResponse struct {
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
Fixture *GeneratedFixture `protobuf:"bytes,3,opt,name=fixture,proto3" json:"fixture,omitempty"` // Full fixture (if output_type = FIXTURE)
RequestBody string `protobuf:"bytes,4,opt,name=request_body,json=requestBody,proto3" json:"request_body,omitempty"` // Request body JSON (if output_type = REQUEST)
Response *GeneratedResponse `protobuf:"bytes,5,opt,name=response,proto3" json:"response,omitempty"` // Response (if output_type = RESPONSE)
// contains filtered or unexported fields
}
func (*GenerateFixtureResponse) Descriptor
deprecated
func (*GenerateFixtureResponse) Descriptor() ([]byte, []int)
Deprecated: Use GenerateFixtureResponse.ProtoReflect.Descriptor instead.
func (*GenerateFixtureResponse) GetFixture ¶
func (x *GenerateFixtureResponse) GetFixture() *GeneratedFixture
func (*GenerateFixtureResponse) GetMessage ¶
func (x *GenerateFixtureResponse) GetMessage() string
func (*GenerateFixtureResponse) GetRequestBody ¶
func (x *GenerateFixtureResponse) GetRequestBody() string
func (*GenerateFixtureResponse) GetResponse ¶
func (x *GenerateFixtureResponse) GetResponse() *GeneratedResponse
func (*GenerateFixtureResponse) GetSuccess ¶
func (x *GenerateFixtureResponse) GetSuccess() bool
func (*GenerateFixtureResponse) ProtoMessage ¶
func (*GenerateFixtureResponse) ProtoMessage()
func (*GenerateFixtureResponse) ProtoReflect ¶
func (x *GenerateFixtureResponse) ProtoReflect() protoreflect.Message
func (*GenerateFixtureResponse) Reset ¶
func (x *GenerateFixtureResponse) Reset()
func (*GenerateFixtureResponse) String ¶
func (x *GenerateFixtureResponse) String() string
type GeneratedFixture ¶
type GeneratedFixture struct {
Request *GeneratedRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
Response *GeneratedResponse `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"`
// contains filtered or unexported fields
}
func (*GeneratedFixture) Descriptor
deprecated
func (*GeneratedFixture) Descriptor() ([]byte, []int)
Deprecated: Use GeneratedFixture.ProtoReflect.Descriptor instead.
func (*GeneratedFixture) GetRequest ¶
func (x *GeneratedFixture) GetRequest() *GeneratedRequest
func (*GeneratedFixture) GetResponse ¶
func (x *GeneratedFixture) GetResponse() *GeneratedResponse
func (*GeneratedFixture) ProtoMessage ¶
func (*GeneratedFixture) ProtoMessage()
func (*GeneratedFixture) ProtoReflect ¶
func (x *GeneratedFixture) ProtoReflect() protoreflect.Message
func (*GeneratedFixture) Reset ¶
func (x *GeneratedFixture) Reset()
func (*GeneratedFixture) String ¶
func (x *GeneratedFixture) String() string
type GeneratedRequest ¶
type GeneratedRequest struct {
Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
Headers map[string]string `` /* 141-byte string literal not displayed */
Body string `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"` // JSON body as string
// contains filtered or unexported fields
}
func (*GeneratedRequest) Descriptor
deprecated
func (*GeneratedRequest) Descriptor() ([]byte, []int)
Deprecated: Use GeneratedRequest.ProtoReflect.Descriptor instead.
func (*GeneratedRequest) GetBody ¶
func (x *GeneratedRequest) GetBody() string
func (*GeneratedRequest) GetHeaders ¶
func (x *GeneratedRequest) GetHeaders() map[string]string
func (*GeneratedRequest) GetMethod ¶
func (x *GeneratedRequest) GetMethod() string
func (*GeneratedRequest) GetPath ¶
func (x *GeneratedRequest) GetPath() string
func (*GeneratedRequest) ProtoMessage ¶
func (*GeneratedRequest) ProtoMessage()
func (*GeneratedRequest) ProtoReflect ¶
func (x *GeneratedRequest) ProtoReflect() protoreflect.Message
func (*GeneratedRequest) Reset ¶
func (x *GeneratedRequest) Reset()
func (*GeneratedRequest) String ¶
func (x *GeneratedRequest) String() string
type GeneratedResponse ¶
type GeneratedResponse struct {
StatusCode int32 `protobuf:"varint,1,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
Headers map[string]string `` /* 141-byte string literal not displayed */
Body string `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"` // JSON body as string
// contains filtered or unexported fields
}
func (*GeneratedResponse) Descriptor
deprecated
func (*GeneratedResponse) Descriptor() ([]byte, []int)
Deprecated: Use GeneratedResponse.ProtoReflect.Descriptor instead.
func (*GeneratedResponse) GetBody ¶
func (x *GeneratedResponse) GetBody() string
func (*GeneratedResponse) GetHeaders ¶
func (x *GeneratedResponse) GetHeaders() map[string]string
func (*GeneratedResponse) GetStatusCode ¶
func (x *GeneratedResponse) GetStatusCode() int32
func (*GeneratedResponse) ProtoMessage ¶
func (*GeneratedResponse) ProtoMessage()
func (*GeneratedResponse) ProtoReflect ¶
func (x *GeneratedResponse) ProtoReflect() protoreflect.Message
func (*GeneratedResponse) Reset ¶
func (x *GeneratedResponse) Reset()
func (*GeneratedResponse) String ¶
func (x *GeneratedResponse) String() string
type GetSchemaRequest ¶
type GetSchemaRequest struct {
SchemaId string `protobuf:"bytes,1,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty"`
SchemaVersion string `protobuf:"bytes,2,opt,name=schema_version,json=schemaVersion,proto3" json:"schema_version,omitempty"` // Optional: specific version (empty = latest)
// contains filtered or unexported fields
}
Request to get a specific schema
func (*GetSchemaRequest) Descriptor
deprecated
func (*GetSchemaRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetSchemaRequest.ProtoReflect.Descriptor instead.
func (*GetSchemaRequest) GetSchemaId ¶
func (x *GetSchemaRequest) GetSchemaId() string
func (*GetSchemaRequest) GetSchemaVersion ¶
func (x *GetSchemaRequest) GetSchemaVersion() string
func (*GetSchemaRequest) ProtoMessage ¶
func (*GetSchemaRequest) ProtoMessage()
func (*GetSchemaRequest) ProtoReflect ¶
func (x *GetSchemaRequest) ProtoReflect() protoreflect.Message
func (*GetSchemaRequest) Reset ¶
func (x *GetSchemaRequest) Reset()
func (*GetSchemaRequest) String ¶
func (x *GetSchemaRequest) String() string
type GetSchemaResponse ¶
type GetSchemaResponse struct {
Found bool `protobuf:"varint,1,opt,name=found,proto3" json:"found,omitempty"`
Metadata *SchemaMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
SchemaContent string `protobuf:"bytes,3,opt,name=schema_content,json=schemaContent,proto3" json:"schema_content,omitempty"` // The actual schema content
// contains filtered or unexported fields
}
func (*GetSchemaResponse) Descriptor
deprecated
func (*GetSchemaResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetSchemaResponse.ProtoReflect.Descriptor instead.
func (*GetSchemaResponse) GetFound ¶
func (x *GetSchemaResponse) GetFound() bool
func (*GetSchemaResponse) GetMetadata ¶
func (x *GetSchemaResponse) GetMetadata() *SchemaMetadata
func (*GetSchemaResponse) GetSchemaContent ¶
func (x *GetSchemaResponse) GetSchemaContent() string
func (*GetSchemaResponse) ProtoMessage ¶
func (*GetSchemaResponse) ProtoMessage()
func (*GetSchemaResponse) ProtoReflect ¶
func (x *GetSchemaResponse) ProtoReflect() protoreflect.Message
func (*GetSchemaResponse) Reset ¶
func (x *GetSchemaResponse) Reset()
func (*GetSchemaResponse) String ¶
func (x *GetSchemaResponse) String() string
type InteractionRequest ¶
type InteractionRequest struct {
SchemaId string `protobuf:"bytes,1,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty"`
Request *RequestData `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
Response *ResponseData `protobuf:"bytes,3,opt,name=response,proto3" json:"response,omitempty"`
SchemaVersion string `protobuf:"bytes,4,opt,name=schema_version,json=schemaVersion,proto3" json:"schema_version,omitempty"` // Optional: validate against specific version
// contains filtered or unexported fields
}
func (*InteractionRequest) Descriptor
deprecated
func (*InteractionRequest) Descriptor() ([]byte, []int)
Deprecated: Use InteractionRequest.ProtoReflect.Descriptor instead.
func (*InteractionRequest) GetRequest ¶
func (x *InteractionRequest) GetRequest() *RequestData
func (*InteractionRequest) GetResponse ¶
func (x *InteractionRequest) GetResponse() *ResponseData
func (*InteractionRequest) GetSchemaId ¶
func (x *InteractionRequest) GetSchemaId() string
func (*InteractionRequest) GetSchemaVersion ¶
func (x *InteractionRequest) GetSchemaVersion() string
func (*InteractionRequest) ProtoMessage ¶
func (*InteractionRequest) ProtoMessage()
func (*InteractionRequest) ProtoReflect ¶
func (x *InteractionRequest) ProtoReflect() protoreflect.Message
func (*InteractionRequest) Reset ¶
func (x *InteractionRequest) Reset()
func (*InteractionRequest) String ¶
func (x *InteractionRequest) String() string
type ListConsumersRequest ¶
type ListConsumersRequest struct {
SchemaId string `protobuf:"bytes,1,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty"` // Required: schema to query
Environment string `protobuf:"bytes,2,opt,name=environment,proto3" json:"environment,omitempty"` // Optional: filter by environment
// contains filtered or unexported fields
}
Request to list consumers of a schema
func (*ListConsumersRequest) Descriptor
deprecated
func (*ListConsumersRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListConsumersRequest.ProtoReflect.Descriptor instead.
func (*ListConsumersRequest) GetEnvironment ¶
func (x *ListConsumersRequest) GetEnvironment() string
func (*ListConsumersRequest) GetSchemaId ¶
func (x *ListConsumersRequest) GetSchemaId() string
func (*ListConsumersRequest) ProtoMessage ¶
func (*ListConsumersRequest) ProtoMessage()
func (*ListConsumersRequest) ProtoReflect ¶
func (x *ListConsumersRequest) ProtoReflect() protoreflect.Message
func (*ListConsumersRequest) Reset ¶
func (x *ListConsumersRequest) Reset()
func (*ListConsumersRequest) String ¶
func (x *ListConsumersRequest) String() string
type ListConsumersResponse ¶
type ListConsumersResponse struct {
Consumers []*ConsumerInfo `protobuf:"bytes,1,rep,name=consumers,proto3" json:"consumers,omitempty"`
// contains filtered or unexported fields
}
Response containing list of consumers
func (*ListConsumersResponse) Descriptor
deprecated
func (*ListConsumersResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListConsumersResponse.ProtoReflect.Descriptor instead.
func (*ListConsumersResponse) GetConsumers ¶
func (x *ListConsumersResponse) GetConsumers() []*ConsumerInfo
func (*ListConsumersResponse) ProtoMessage ¶
func (*ListConsumersResponse) ProtoMessage()
func (*ListConsumersResponse) ProtoReflect ¶
func (x *ListConsumersResponse) ProtoReflect() protoreflect.Message
func (*ListConsumersResponse) Reset ¶
func (x *ListConsumersResponse) Reset()
func (*ListConsumersResponse) String ¶
func (x *ListConsumersResponse) String() string
type ListEndpointsRequest ¶
type ListEndpointsRequest struct {
SchemaId string `protobuf:"bytes,1,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty"`
// contains filtered or unexported fields
}
Request to list endpoints in a schema
func (*ListEndpointsRequest) Descriptor
deprecated
func (*ListEndpointsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListEndpointsRequest.ProtoReflect.Descriptor instead.
func (*ListEndpointsRequest) GetSchemaId ¶
func (x *ListEndpointsRequest) GetSchemaId() string
func (*ListEndpointsRequest) ProtoMessage ¶
func (*ListEndpointsRequest) ProtoMessage()
func (*ListEndpointsRequest) ProtoReflect ¶
func (x *ListEndpointsRequest) ProtoReflect() protoreflect.Message
func (*ListEndpointsRequest) Reset ¶
func (x *ListEndpointsRequest) Reset()
func (*ListEndpointsRequest) String ¶
func (x *ListEndpointsRequest) String() string
type ListEndpointsResponse ¶
type ListEndpointsResponse struct {
Endpoints []*EndpointInfo `protobuf:"bytes,1,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
// contains filtered or unexported fields
}
func (*ListEndpointsResponse) Descriptor
deprecated
func (*ListEndpointsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListEndpointsResponse.ProtoReflect.Descriptor instead.
func (*ListEndpointsResponse) GetEndpoints ¶
func (x *ListEndpointsResponse) GetEndpoints() []*EndpointInfo
func (*ListEndpointsResponse) ProtoMessage ¶
func (*ListEndpointsResponse) ProtoMessage()
func (*ListEndpointsResponse) ProtoReflect ¶
func (x *ListEndpointsResponse) ProtoReflect() protoreflect.Message
func (*ListEndpointsResponse) Reset ¶
func (x *ListEndpointsResponse) Reset()
func (*ListEndpointsResponse) String ¶
func (x *ListEndpointsResponse) String() string
type ListSchemasRequest ¶
type ListSchemasRequest struct {
PageSize int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // Max results per page (default 100)
PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // Token for pagination
Owner string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"` // Optional: filter by owner
Team string `protobuf:"bytes,4,opt,name=team,proto3" json:"team,omitempty"` // Optional: filter by team
// contains filtered or unexported fields
}
Request to list all schemas
func (*ListSchemasRequest) Descriptor
deprecated
func (*ListSchemasRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListSchemasRequest.ProtoReflect.Descriptor instead.
func (*ListSchemasRequest) GetOwner ¶
func (x *ListSchemasRequest) GetOwner() string
func (*ListSchemasRequest) GetPageSize ¶
func (x *ListSchemasRequest) GetPageSize() int32
func (*ListSchemasRequest) GetPageToken ¶
func (x *ListSchemasRequest) GetPageToken() string
func (*ListSchemasRequest) GetTeam ¶
func (x *ListSchemasRequest) GetTeam() string
func (*ListSchemasRequest) ProtoMessage ¶
func (*ListSchemasRequest) ProtoMessage()
func (*ListSchemasRequest) ProtoReflect ¶
func (x *ListSchemasRequest) ProtoReflect() protoreflect.Message
func (*ListSchemasRequest) Reset ¶
func (x *ListSchemasRequest) Reset()
func (*ListSchemasRequest) String ¶
func (x *ListSchemasRequest) String() string
type ListSchemasResponse ¶
type ListSchemasResponse struct {
Schemas []*SchemaMetadata `protobuf:"bytes,1,rep,name=schemas,proto3" json:"schemas,omitempty"`
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // Token for next page (empty if no more)
TotalCount int32 `protobuf:"varint,3,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"` // Total number of schemas matching filter
// contains filtered or unexported fields
}
func (*ListSchemasResponse) Descriptor
deprecated
func (*ListSchemasResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListSchemasResponse.ProtoReflect.Descriptor instead.
func (*ListSchemasResponse) GetNextPageToken ¶
func (x *ListSchemasResponse) GetNextPageToken() string
func (*ListSchemasResponse) GetSchemas ¶
func (x *ListSchemasResponse) GetSchemas() []*SchemaMetadata
func (*ListSchemasResponse) GetTotalCount ¶
func (x *ListSchemasResponse) GetTotalCount() int32
func (*ListSchemasResponse) ProtoMessage ¶
func (*ListSchemasResponse) ProtoMessage()
func (*ListSchemasResponse) ProtoReflect ¶
func (x *ListSchemasResponse) ProtoReflect() protoreflect.Message
func (*ListSchemasResponse) Reset ¶
func (x *ListSchemasResponse) Reset()
func (*ListSchemasResponse) String ¶
func (x *ListSchemasResponse) String() string
type OutputType ¶
type OutputType int32
const ( OutputType_OUTPUT_FIXTURE OutputType = 0 // Complete request/response pair (default) OutputType_OUTPUT_REQUEST OutputType = 1 // Request body only OutputType_OUTPUT_RESPONSE OutputType = 2 // Response only )
func (OutputType) Descriptor ¶
func (OutputType) Descriptor() protoreflect.EnumDescriptor
func (OutputType) Enum ¶
func (x OutputType) Enum() *OutputType
func (OutputType) EnumDescriptor
deprecated
func (OutputType) EnumDescriptor() ([]byte, []int)
Deprecated: Use OutputType.Descriptor instead.
func (OutputType) Number ¶
func (x OutputType) Number() protoreflect.EnumNumber
func (OutputType) String ¶
func (x OutputType) String() string
func (OutputType) Type ¶
func (OutputType) Type() protoreflect.EnumType
type RegisterConsumerRequest ¶
type RegisterConsumerRequest struct {
ConsumerId string `protobuf:"bytes,1,opt,name=consumer_id,json=consumerId,proto3" json:"consumer_id,omitempty"`
ConsumerVersion string `protobuf:"bytes,2,opt,name=consumer_version,json=consumerVersion,proto3" json:"consumer_version,omitempty"`
SchemaId string `protobuf:"bytes,3,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty"`
SchemaVersion string `protobuf:"bytes,4,opt,name=schema_version,json=schemaVersion,proto3" json:"schema_version,omitempty"`
Environment string `protobuf:"bytes,5,opt,name=environment,proto3" json:"environment,omitempty"`
UsedEndpoints []*EndpointUsage `protobuf:"bytes,6,rep,name=used_endpoints,json=usedEndpoints,proto3" json:"used_endpoints,omitempty"`
// contains filtered or unexported fields
}
Request to register a consumer's dependency
func (*RegisterConsumerRequest) Descriptor
deprecated
func (*RegisterConsumerRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterConsumerRequest.ProtoReflect.Descriptor instead.
func (*RegisterConsumerRequest) GetConsumerId ¶
func (x *RegisterConsumerRequest) GetConsumerId() string
func (*RegisterConsumerRequest) GetConsumerVersion ¶
func (x *RegisterConsumerRequest) GetConsumerVersion() string
func (*RegisterConsumerRequest) GetEnvironment ¶
func (x *RegisterConsumerRequest) GetEnvironment() string
func (*RegisterConsumerRequest) GetSchemaId ¶
func (x *RegisterConsumerRequest) GetSchemaId() string
func (*RegisterConsumerRequest) GetSchemaVersion ¶
func (x *RegisterConsumerRequest) GetSchemaVersion() string
func (*RegisterConsumerRequest) GetUsedEndpoints ¶
func (x *RegisterConsumerRequest) GetUsedEndpoints() []*EndpointUsage
func (*RegisterConsumerRequest) ProtoMessage ¶
func (*RegisterConsumerRequest) ProtoMessage()
func (*RegisterConsumerRequest) ProtoReflect ¶
func (x *RegisterConsumerRequest) ProtoReflect() protoreflect.Message
func (*RegisterConsumerRequest) Reset ¶
func (x *RegisterConsumerRequest) Reset()
func (*RegisterConsumerRequest) String ¶
func (x *RegisterConsumerRequest) String() string
type RegisterConsumerResponse ¶
type RegisterConsumerResponse struct {
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
Consumer *ConsumerInfo `protobuf:"bytes,3,opt,name=consumer,proto3" json:"consumer,omitempty"`
// contains filtered or unexported fields
}
Response from consumer registration
func (*RegisterConsumerResponse) Descriptor
deprecated
func (*RegisterConsumerResponse) Descriptor() ([]byte, []int)
Deprecated: Use RegisterConsumerResponse.ProtoReflect.Descriptor instead.
func (*RegisterConsumerResponse) GetConsumer ¶
func (x *RegisterConsumerResponse) GetConsumer() *ConsumerInfo
func (*RegisterConsumerResponse) GetMessage ¶
func (x *RegisterConsumerResponse) GetMessage() string
func (*RegisterConsumerResponse) GetSuccess ¶
func (x *RegisterConsumerResponse) GetSuccess() bool
func (*RegisterConsumerResponse) ProtoMessage ¶
func (*RegisterConsumerResponse) ProtoMessage()
func (*RegisterConsumerResponse) ProtoReflect ¶
func (x *RegisterConsumerResponse) ProtoReflect() protoreflect.Message
func (*RegisterConsumerResponse) Reset ¶
func (x *RegisterConsumerResponse) Reset()
func (*RegisterConsumerResponse) String ¶
func (x *RegisterConsumerResponse) String() string
type RegisterSchemaRequest ¶
type RegisterSchemaRequest struct {
SchemaId string `protobuf:"bytes,1,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty"` // Unique identifier for the schema
SchemaContent string `protobuf:"bytes,2,opt,name=schema_content,json=schemaContent,proto3" json:"schema_content,omitempty"` // The OpenAPI spec content (YAML or JSON)
SchemaVersion string `protobuf:"bytes,3,opt,name=schema_version,json=schemaVersion,proto3" json:"schema_version,omitempty"` // Optional semantic version
Ownership *SchemaOwnership `protobuf:"bytes,4,opt,name=ownership,proto3" json:"ownership,omitempty"` // Optional ownership information
CheckCompatibility bool `protobuf:"varint,5,opt,name=check_compatibility,json=checkCompatibility,proto3" json:"check_compatibility,omitempty"` // If true, check for breaking changes
// contains filtered or unexported fields
}
func (*RegisterSchemaRequest) Descriptor
deprecated
func (*RegisterSchemaRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterSchemaRequest.ProtoReflect.Descriptor instead.
func (*RegisterSchemaRequest) GetCheckCompatibility ¶
func (x *RegisterSchemaRequest) GetCheckCompatibility() bool
func (*RegisterSchemaRequest) GetOwnership ¶
func (x *RegisterSchemaRequest) GetOwnership() *SchemaOwnership
func (*RegisterSchemaRequest) GetSchemaContent ¶
func (x *RegisterSchemaRequest) GetSchemaContent() string
func (*RegisterSchemaRequest) GetSchemaId ¶
func (x *RegisterSchemaRequest) GetSchemaId() string
func (*RegisterSchemaRequest) GetSchemaVersion ¶
func (x *RegisterSchemaRequest) GetSchemaVersion() string
func (*RegisterSchemaRequest) ProtoMessage ¶
func (*RegisterSchemaRequest) ProtoMessage()
func (*RegisterSchemaRequest) ProtoReflect ¶
func (x *RegisterSchemaRequest) ProtoReflect() protoreflect.Message
func (*RegisterSchemaRequest) Reset ¶
func (x *RegisterSchemaRequest) Reset()
func (*RegisterSchemaRequest) String ¶
func (x *RegisterSchemaRequest) String() string
type RegisterSchemaResponse ¶
type RegisterSchemaResponse struct {
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
Metadata *SchemaMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"` // Metadata for the registered schema
BreakingChanges []*BreakingChange `protobuf:"bytes,4,rep,name=breaking_changes,json=breakingChanges,proto3" json:"breaking_changes,omitempty"` // Breaking changes if any detected
// contains filtered or unexported fields
}
func (*RegisterSchemaResponse) Descriptor
deprecated
func (*RegisterSchemaResponse) Descriptor() ([]byte, []int)
Deprecated: Use RegisterSchemaResponse.ProtoReflect.Descriptor instead.
func (*RegisterSchemaResponse) GetBreakingChanges ¶
func (x *RegisterSchemaResponse) GetBreakingChanges() []*BreakingChange
func (*RegisterSchemaResponse) GetMessage ¶
func (x *RegisterSchemaResponse) GetMessage() string
func (*RegisterSchemaResponse) GetMetadata ¶
func (x *RegisterSchemaResponse) GetMetadata() *SchemaMetadata
func (*RegisterSchemaResponse) GetSuccess ¶
func (x *RegisterSchemaResponse) GetSuccess() bool
func (*RegisterSchemaResponse) ProtoMessage ¶
func (*RegisterSchemaResponse) ProtoMessage()
func (*RegisterSchemaResponse) ProtoReflect ¶
func (x *RegisterSchemaResponse) ProtoReflect() protoreflect.Message
func (*RegisterSchemaResponse) Reset ¶
func (x *RegisterSchemaResponse) Reset()
func (*RegisterSchemaResponse) String ¶
func (x *RegisterSchemaResponse) String() string
type RequestData ¶
type RequestData struct {
Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"` // GET, POST, etc.
Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` // /users/123
Headers map[string]string `` /* 141-byte string literal not displayed */
Body string `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"` // JSON body as string
// contains filtered or unexported fields
}
func (*RequestData) Descriptor
deprecated
func (*RequestData) Descriptor() ([]byte, []int)
Deprecated: Use RequestData.ProtoReflect.Descriptor instead.
func (*RequestData) GetBody ¶
func (x *RequestData) GetBody() string
func (*RequestData) GetHeaders ¶
func (x *RequestData) GetHeaders() map[string]string
func (*RequestData) GetMethod ¶
func (x *RequestData) GetMethod() string
func (*RequestData) GetPath ¶
func (x *RequestData) GetPath() string
func (*RequestData) ProtoMessage ¶
func (*RequestData) ProtoMessage()
func (*RequestData) ProtoReflect ¶
func (x *RequestData) ProtoReflect() protoreflect.Message
func (*RequestData) Reset ¶
func (x *RequestData) Reset()
func (*RequestData) String ¶
func (x *RequestData) String() string
type ResponseData ¶
type ResponseData struct {
StatusCode int32 `protobuf:"varint,1,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
Headers map[string]string `` /* 141-byte string literal not displayed */
Body string `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"` // JSON body as string
// contains filtered or unexported fields
}
func (*ResponseData) Descriptor
deprecated
func (*ResponseData) Descriptor() ([]byte, []int)
Deprecated: Use ResponseData.ProtoReflect.Descriptor instead.
func (*ResponseData) GetBody ¶
func (x *ResponseData) GetBody() string
func (*ResponseData) GetHeaders ¶
func (x *ResponseData) GetHeaders() map[string]string
func (*ResponseData) GetStatusCode ¶
func (x *ResponseData) GetStatusCode() int32
func (*ResponseData) ProtoMessage ¶
func (*ResponseData) ProtoMessage()
func (*ResponseData) ProtoReflect ¶
func (x *ResponseData) ProtoReflect() protoreflect.Message
func (*ResponseData) Reset ¶
func (x *ResponseData) Reset()
func (*ResponseData) String ¶
func (x *ResponseData) String() string
type SchemaMetadata ¶
type SchemaMetadata struct {
SchemaId string `protobuf:"bytes,1,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty"` // Unique identifier
SchemaVersion string `protobuf:"bytes,2,opt,name=schema_version,json=schemaVersion,proto3" json:"schema_version,omitempty"` // Semantic version (e.g., "1.2.3")
SchemaHash string `protobuf:"bytes,3,opt,name=schema_hash,json=schemaHash,proto3" json:"schema_hash,omitempty"` // SHA256 hash of schema content
RegisteredAt int64 `protobuf:"varint,4,opt,name=registered_at,json=registeredAt,proto3" json:"registered_at,omitempty"` // Unix timestamp of initial registration
UpdatedAt int64 `protobuf:"varint,5,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"` // Unix timestamp of last update
Ownership *SchemaOwnership `protobuf:"bytes,6,opt,name=ownership,proto3" json:"ownership,omitempty"`
OpenapiVersion string `protobuf:"bytes,7,opt,name=openapi_version,json=openapiVersion,proto3" json:"openapi_version,omitempty"` // Detected OpenAPI version (e.g., "3.0.0")
EndpointCount int32 `protobuf:"varint,8,opt,name=endpoint_count,json=endpointCount,proto3" json:"endpoint_count,omitempty"` // Number of endpoints in schema
// contains filtered or unexported fields
}
Metadata about a registered schema
func (*SchemaMetadata) Descriptor
deprecated
func (*SchemaMetadata) Descriptor() ([]byte, []int)
Deprecated: Use SchemaMetadata.ProtoReflect.Descriptor instead.
func (*SchemaMetadata) GetEndpointCount ¶
func (x *SchemaMetadata) GetEndpointCount() int32
func (*SchemaMetadata) GetOpenapiVersion ¶
func (x *SchemaMetadata) GetOpenapiVersion() string
func (*SchemaMetadata) GetOwnership ¶
func (x *SchemaMetadata) GetOwnership() *SchemaOwnership
func (*SchemaMetadata) GetRegisteredAt ¶
func (x *SchemaMetadata) GetRegisteredAt() int64
func (*SchemaMetadata) GetSchemaHash ¶
func (x *SchemaMetadata) GetSchemaHash() string
func (*SchemaMetadata) GetSchemaId ¶
func (x *SchemaMetadata) GetSchemaId() string
func (*SchemaMetadata) GetSchemaVersion ¶
func (x *SchemaMetadata) GetSchemaVersion() string
func (*SchemaMetadata) GetUpdatedAt ¶
func (x *SchemaMetadata) GetUpdatedAt() int64
func (*SchemaMetadata) ProtoMessage ¶
func (*SchemaMetadata) ProtoMessage()
func (*SchemaMetadata) ProtoReflect ¶
func (x *SchemaMetadata) ProtoReflect() protoreflect.Message
func (*SchemaMetadata) Reset ¶
func (x *SchemaMetadata) Reset()
func (*SchemaMetadata) String ¶
func (x *SchemaMetadata) String() string
type SchemaOwnership ¶
type SchemaOwnership struct {
Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"` // Owner name or identifier
Team string `protobuf:"bytes,2,opt,name=team,proto3" json:"team,omitempty"` // Team responsible for the schema
ContactEmail string `protobuf:"bytes,3,opt,name=contact_email,json=contactEmail,proto3" json:"contact_email,omitempty"` // Contact email for schema issues
ReadOnly bool `protobuf:"varint,4,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"` // If true, schema cannot be updated
// contains filtered or unexported fields
}
Schema ownership and governance information
func (*SchemaOwnership) Descriptor
deprecated
func (*SchemaOwnership) Descriptor() ([]byte, []int)
Deprecated: Use SchemaOwnership.ProtoReflect.Descriptor instead.
func (*SchemaOwnership) GetContactEmail ¶
func (x *SchemaOwnership) GetContactEmail() string
func (*SchemaOwnership) GetOwner ¶
func (x *SchemaOwnership) GetOwner() string
func (*SchemaOwnership) GetReadOnly ¶
func (x *SchemaOwnership) GetReadOnly() bool
func (*SchemaOwnership) GetTeam ¶
func (x *SchemaOwnership) GetTeam() string
func (*SchemaOwnership) ProtoMessage ¶
func (*SchemaOwnership) ProtoMessage()
func (*SchemaOwnership) ProtoReflect ¶
func (x *SchemaOwnership) ProtoReflect() protoreflect.Message
func (*SchemaOwnership) Reset ¶
func (x *SchemaOwnership) Reset()
func (*SchemaOwnership) String ¶
func (x *SchemaOwnership) String() string
type UnimplementedContractValidatorServer ¶
type UnimplementedContractValidatorServer struct{}
UnimplementedContractValidatorServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedContractValidatorServer) CanIDeploy ¶
func (UnimplementedContractValidatorServer) CanIDeploy(context.Context, *CanIDeployRequest) (*CanIDeployResponse, error)
func (UnimplementedContractValidatorServer) CompareSchemas ¶
func (UnimplementedContractValidatorServer) CompareSchemas(context.Context, *CompareSchemasRequest) (*CompareSchemasResponse, error)
func (UnimplementedContractValidatorServer) DeregisterConsumer ¶
func (UnimplementedContractValidatorServer) DeregisterConsumer(context.Context, *DeregisterConsumerRequest) (*DeregisterConsumerResponse, error)
func (UnimplementedContractValidatorServer) GenerateFixture ¶
func (UnimplementedContractValidatorServer) GenerateFixture(context.Context, *GenerateFixtureRequest) (*GenerateFixtureResponse, error)
func (UnimplementedContractValidatorServer) GetSchema ¶
func (UnimplementedContractValidatorServer) GetSchema(context.Context, *GetSchemaRequest) (*GetSchemaResponse, error)
func (UnimplementedContractValidatorServer) ListConsumers ¶
func (UnimplementedContractValidatorServer) ListConsumers(context.Context, *ListConsumersRequest) (*ListConsumersResponse, error)
func (UnimplementedContractValidatorServer) ListEndpoints ¶
func (UnimplementedContractValidatorServer) ListEndpoints(context.Context, *ListEndpointsRequest) (*ListEndpointsResponse, error)
func (UnimplementedContractValidatorServer) ListSchemas ¶
func (UnimplementedContractValidatorServer) ListSchemas(context.Context, *ListSchemasRequest) (*ListSchemasResponse, error)
func (UnimplementedContractValidatorServer) RegisterConsumer ¶
func (UnimplementedContractValidatorServer) RegisterConsumer(context.Context, *RegisterConsumerRequest) (*RegisterConsumerResponse, error)
func (UnimplementedContractValidatorServer) RegisterSchema ¶
func (UnimplementedContractValidatorServer) RegisterSchema(context.Context, *RegisterSchemaRequest) (*RegisterSchemaResponse, error)
func (UnimplementedContractValidatorServer) ValidateInteraction ¶
func (UnimplementedContractValidatorServer) ValidateInteraction(context.Context, *InteractionRequest) (*ValidationResult, error)
func (UnimplementedContractValidatorServer) ValidateProducerResponse ¶
func (UnimplementedContractValidatorServer) ValidateProducerResponse(context.Context, *ValidateProducerRequest) (*ValidationResult, error)
type UnsafeContractValidatorServer ¶
type UnsafeContractValidatorServer interface {
// contains filtered or unexported methods
}
UnsafeContractValidatorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ContractValidatorServer will result in compilation errors.
type ValidateProducerRequest ¶
type ValidateProducerRequest struct {
SchemaId string `protobuf:"bytes,1,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty"` // Schema to validate against
SchemaVersion string `protobuf:"bytes,2,opt,name=schema_version,json=schemaVersion,proto3" json:"schema_version,omitempty"` // Optional: specific schema version
Method string `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"` // HTTP method (GET, POST, etc.)
Path string `protobuf:"bytes,4,opt,name=path,proto3" json:"path,omitempty"` // API path with actual values (e.g., /users/123)
Response *ResponseData `protobuf:"bytes,5,opt,name=response,proto3" json:"response,omitempty"` // The response to validate
Request *RequestData `protobuf:"bytes,6,opt,name=request,proto3" json:"request,omitempty"` // Optional: request context (for path param extraction)
// contains filtered or unexported fields
}
Request to validate a producer's response against its OpenAPI schema
func (*ValidateProducerRequest) Descriptor
deprecated
func (*ValidateProducerRequest) Descriptor() ([]byte, []int)
Deprecated: Use ValidateProducerRequest.ProtoReflect.Descriptor instead.
func (*ValidateProducerRequest) GetMethod ¶
func (x *ValidateProducerRequest) GetMethod() string
func (*ValidateProducerRequest) GetPath ¶
func (x *ValidateProducerRequest) GetPath() string
func (*ValidateProducerRequest) GetRequest ¶
func (x *ValidateProducerRequest) GetRequest() *RequestData
func (*ValidateProducerRequest) GetResponse ¶
func (x *ValidateProducerRequest) GetResponse() *ResponseData
func (*ValidateProducerRequest) GetSchemaId ¶
func (x *ValidateProducerRequest) GetSchemaId() string
func (*ValidateProducerRequest) GetSchemaVersion ¶
func (x *ValidateProducerRequest) GetSchemaVersion() string
func (*ValidateProducerRequest) ProtoMessage ¶
func (*ValidateProducerRequest) ProtoMessage()
func (*ValidateProducerRequest) ProtoReflect ¶
func (x *ValidateProducerRequest) ProtoReflect() protoreflect.Message
func (*ValidateProducerRequest) Reset ¶
func (x *ValidateProducerRequest) Reset()
func (*ValidateProducerRequest) String ¶
func (x *ValidateProducerRequest) String() string
type ValidationResult ¶
type ValidationResult struct {
Valid bool `protobuf:"varint,1,opt,name=valid,proto3" json:"valid,omitempty"`
Errors []string `protobuf:"bytes,2,rep,name=errors,proto3" json:"errors,omitempty"`
ValidatedAgainstVersion string `` // Version of schema used for validation
/* 132-byte string literal not displayed */
ValidatedAgainstHash string `protobuf:"bytes,4,opt,name=validated_against_hash,json=validatedAgainstHash,proto3" json:"validated_against_hash,omitempty"` // Hash of schema used for validation
// contains filtered or unexported fields
}
func (*ValidationResult) Descriptor
deprecated
func (*ValidationResult) Descriptor() ([]byte, []int)
Deprecated: Use ValidationResult.ProtoReflect.Descriptor instead.
func (*ValidationResult) GetErrors ¶
func (x *ValidationResult) GetErrors() []string
func (*ValidationResult) GetValid ¶
func (x *ValidationResult) GetValid() bool
func (*ValidationResult) GetValidatedAgainstHash ¶
func (x *ValidationResult) GetValidatedAgainstHash() string
func (*ValidationResult) GetValidatedAgainstVersion ¶
func (x *ValidationResult) GetValidatedAgainstVersion() string
func (*ValidationResult) ProtoMessage ¶
func (*ValidationResult) ProtoMessage()
func (*ValidationResult) ProtoReflect ¶
func (x *ValidationResult) ProtoReflect() protoreflect.Message
func (*ValidationResult) Reset ¶
func (x *ValidationResult) Reset()
func (*ValidationResult) String ¶
func (x *ValidationResult) String() string