Versions in this module Expand all Collapse all v1 v1.1.0 Mar 15, 2026 Changes in this version + type DataValidator struct + func NewDataValidator() *DataValidator + func (v *DataValidator) ValidateData(format SchemaFormat, definition string, data []byte) error type SchemaRegistry + func (sr *SchemaRegistry) HasSchema(subject Subject) bool + func (sr *SchemaRegistry) ValidateMessage(subject Subject, data []byte) error v1.0.1 Nov 22, 2025 Changes in this version + type CompatibilityMode string + const CompatibilityBackward + const CompatibilityBackwardTransitive + const CompatibilityForward + const CompatibilityForwardTransitive + const CompatibilityFull + const CompatibilityFullTransitive + const CompatibilityNone + type DefaultValidator struct + func NewDefaultValidator() *DefaultValidator + func (v *DefaultValidator) CheckCompatibility(format SchemaFormat, oldSchema, newSchema string, mode CompatibilityMode) (bool, error) + func (v *DefaultValidator) Validate(format SchemaFormat, definition string) error + type DeleteSchemaRequest struct + Subject Subject + Version Version + type DeleteSchemaResponse struct + ErrorCode ErrorCode + type DeleteSubjectRequest struct + Subject Subject + type DeleteSubjectResponse struct + ErrorCode ErrorCode + Versions []Version + type ErrorCode int + const ErrorIncompatibleSchema + const ErrorInvalidCompatibilityMode + const ErrorInvalidSchema + const ErrorInvalidSubject + const ErrorInvalidVersion + const ErrorNone + const ErrorSchemaNotFound + const ErrorSchemaRegistryError + const ErrorSubjectAlreadyExists + const ErrorSubjectNotFound + const ErrorVersionAlreadyExists + const ErrorVersionNotFound + func (e ErrorCode) Error() string + func (e ErrorCode) String() string + type GetCompatibilityRequest struct + Subject Subject + type GetCompatibilityResponse struct + Compatibility CompatibilityMode + ErrorCode ErrorCode + type GetLatestSchemaRequest struct + Subject Subject + type GetLatestSchemaResponse struct + ErrorCode ErrorCode + Schema *Schema + type GetSchemaBySubjectVersionRequest struct + Subject Subject + Version Version + type GetSchemaBySubjectVersionResponse struct + ErrorCode ErrorCode + Schema *Schema + type GetSchemaRequest struct + ID SchemaID + type GetSchemaResponse struct + ErrorCode ErrorCode + Schema *Schema + type ListSubjectsRequest struct + Prefix string + type ListSubjectsResponse struct + ErrorCode ErrorCode + Subjects []Subject + type ListVersionsRequest struct + Subject Subject + type ListVersionsResponse struct + ErrorCode ErrorCode + Versions []Version + type RegisterSchemaRequest struct + Definition string + Format SchemaFormat + Subject Subject + type RegisterSchemaResponse struct + ErrorCode ErrorCode + ID SchemaID + type RegistryStats struct + TotalSchemas int + TotalSubjects int + type Schema struct + CreatedAt time.Time + Definition string + Format SchemaFormat + ID SchemaID + Subject Subject + UpdatedAt time.Time + Version Version + type SchemaFormat string + const FormatAvro + const FormatJSON + const FormatProtobuf + type SchemaID int32 + type SchemaMetadata struct + CreatedAt time.Time + Fingerprint string + Format SchemaFormat + ID SchemaID + Subject Subject + Version Version + type SchemaReference struct + Name string + Subject Subject + Version Version + type SchemaRegistry struct + func NewSchemaRegistry(validator SchemaValidator, logger *logging.Logger) *SchemaRegistry + func (sr *SchemaRegistry) DeleteSchema(req *DeleteSchemaRequest) (*DeleteSchemaResponse, error) + func (sr *SchemaRegistry) DeleteSubject(req *DeleteSubjectRequest) (*DeleteSubjectResponse, error) + func (sr *SchemaRegistry) GetCompatibility(req *GetCompatibilityRequest) (*GetCompatibilityResponse, error) + func (sr *SchemaRegistry) GetLatestSchema(req *GetLatestSchemaRequest) (*GetLatestSchemaResponse, error) + func (sr *SchemaRegistry) GetSchema(req *GetSchemaRequest) (*GetSchemaResponse, error) + func (sr *SchemaRegistry) GetSchemaBySubjectVersion(req *GetSchemaBySubjectVersionRequest) (*GetSchemaBySubjectVersionResponse, error) + func (sr *SchemaRegistry) ListSubjects(req *ListSubjectsRequest) (*ListSubjectsResponse, error) + func (sr *SchemaRegistry) ListVersions(req *ListVersionsRequest) (*ListVersionsResponse, error) + func (sr *SchemaRegistry) RegisterSchema(req *RegisterSchemaRequest) (*RegisterSchemaResponse, error) + func (sr *SchemaRegistry) SetGlobalCompatibility(mode CompatibilityMode) error + func (sr *SchemaRegistry) Stats() RegistryStats + func (sr *SchemaRegistry) TestCompatibility(req *TestCompatibilityRequest) (*TestCompatibilityResponse, error) + func (sr *SchemaRegistry) UpdateCompatibility(req *UpdateCompatibilityRequest) (*UpdateCompatibilityResponse, error) + type SchemaValidator interface + CheckCompatibility func(format SchemaFormat, oldSchema, newSchema string, mode CompatibilityMode) (bool, error) + Validate func(format SchemaFormat, definition string) error + type SchemaWithReferences struct + References []SchemaReference + Schema *Schema + type Subject string + type SubjectVersion struct + Subject Subject + Version Version + type TestCompatibilityRequest struct + Definition string + Format SchemaFormat + Subject Subject + Version Version + type TestCompatibilityResponse struct + Compatible bool + ErrorCode ErrorCode + Message string + type UpdateCompatibilityRequest struct + Compatibility CompatibilityMode + Subject Subject + type UpdateCompatibilityResponse struct + ErrorCode ErrorCode + type Version int32
Go to main page