pb

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 19, 2026 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
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

View Source
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.

View Source
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.

View Source
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)

View Source
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) Enum

func (BreakingChangeType) EnumDescriptor deprecated

func (BreakingChangeType) EnumDescriptor() ([]byte, []int)

Deprecated: Use BreakingChangeType.Descriptor instead.

func (BreakingChangeType) Number

func (BreakingChangeType) String

func (x BreakingChangeType) String() string

func (BreakingChangeType) Type

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.

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 (*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 (*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

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) CompareSchemas

func (UnimplementedContractValidatorServer) DeregisterConsumer

func (UnimplementedContractValidatorServer) GenerateFixture

func (UnimplementedContractValidatorServer) GetSchema

func (UnimplementedContractValidatorServer) ListConsumers

func (UnimplementedContractValidatorServer) ListEndpoints

func (UnimplementedContractValidatorServer) ListSchemas

func (UnimplementedContractValidatorServer) RegisterConsumer

func (UnimplementedContractValidatorServer) RegisterSchema

func (UnimplementedContractValidatorServer) ValidateInteraction

func (UnimplementedContractValidatorServer) ValidateProducerResponse

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL