schema_registry

type SchemaRegistryClient interface {
	GetDefaultCompatibility() (schemaregistry.Compatibility, error)
	GetAllSubjects() ([]string, error)
	GetLatestSchemaMetadata(subject string) (schemaregistry.SchemaMetadata, error)
	GetCompatibility(subject string) (schemaregistry.Compatibility, error)
	GetAllVersions(subject string) ([]int, error)
	GetSchemaMetadata(subject string, version int) (schemaregistry.SchemaMetadata, error)
	GetAllContexts() ([]string, error)
}

type SchemaRegistryService struct {
	// contains filtered or unexported fields
}