Versions in this module Expand all Collapse all v1 v1.0.0 Sep 27, 2022 Changes in this version + const Backward + const BackwardTransitive + const Forward + const ForwardTransitive + const Full + const FullTransitive + const None + type Client interface + DeleteSubject func(subject string, permanent bool) ([]int, error) + DeleteSubjectVersion func(subject string, version int, permanent bool) (deletes int, err error) + GetAllSubjects func() ([]string, error) + GetAllVersions func(subject string) ([]int, error) + GetBySubjectAndID func(subject string, id int) (schema SchemaInfo, err error) + GetCompatibility func(subject string) (compatibility Compatibility, err error) + GetDefaultCompatibility func() (compatibility Compatibility, err error) + GetID func(subject string, schema SchemaInfo, normalize bool) (id int, err error) + GetLatestSchemaMetadata func(subject string) (SchemaMetadata, error) + GetSchemaMetadata func(subject string, version int) (SchemaMetadata, error) + GetVersion func(subject string, schema SchemaInfo, normalize bool) (version int, err error) + Register func(subject string, schema SchemaInfo, normalize bool) (id int, err error) + TestCompatibility func(subject string, version int, schema SchemaInfo) (compatible bool, err error) + UpdateCompatibility func(subject string, update Compatibility) (compatibility Compatibility, err error) + UpdateDefaultCompatibility func(update Compatibility) (compatibility Compatibility, err error) + func NewClient(conf *Config) (Client, error) + type Compatibility int + func (c *Compatibility) ParseString(val string) error + func (c *Compatibility) UnmarshalJSON(b []byte) error + func (c Compatibility) MarshalJSON() ([]byte, error) + func (c Compatibility) String() string + type Config struct + AwsRegion string + BasicAuthCredentialsSource string + BasicAuthUserInfo string + CacheCapacity int + ConnectionTimeoutMs int + RegistryName string + RequestTimeoutMs int + SaslMechanism string + SaslPassword string + SaslUsername string + SchemaRegistryURL string + SslCaLocation string + SslCertificateLocation string + SslDisableEndpointVerification bool + SslKeyLocation string + func NewConfig(url string) *Config + func NewConfigForAwsGlue(registryName string, awsRegion string) *Config + func NewConfigWithAuthentication(url string, username string, password string) *Config + type Reference struct + Name string + Subject string + Version int + type RestError struct + Code int + Message string + func (err *RestError) Error() string + type SchemaInfo struct + References []Reference + Schema string + SchemaType string + func (sd *SchemaInfo) MarshalJSON() ([]byte, error) + func (sd *SchemaInfo) UnmarshalJSON(b []byte) error + type SchemaMetadata struct + ID int + Subject string + Version int + func (sd *SchemaMetadata) MarshalJSON() ([]byte, error) + func (sd *SchemaMetadata) UnmarshalJSON(b []byte) error