Versions in this module Expand all Collapse all v2 v2.0.0 Jan 19, 2023 Changes in this version + const DisableValidation + const EnableValidation + const KeySerde + const ValueSerde + func Expect(actual, expected interface{}) error + func ResolveReferences(c schemaregistry.Client, schema schemaregistry.SchemaInfo, ...) error + func TopicNameStrategy(topic string, serdeType Type, schema schemaregistry.SchemaInfo) (string, error) + type BaseDeserializer struct + Conf *DeserializerConfig + MessageFactory MessageFactory + func (s *BaseDeserializer) ConfigureDeserializer(client schemaregistry.Client, serdeType Type, conf *DeserializerConfig) error + func (s *BaseDeserializer) GetSchema(topic string, payload []byte) (schemaregistry.SchemaInfo, error) + type BaseSerializer struct + Conf *SerializerConfig + func (s *BaseSerializer) ConfigureSerializer(client schemaregistry.Client, serdeType Type, conf *SerializerConfig) error + func (s *BaseSerializer) GetID(topic string, msg interface{}, info schemaregistry.SchemaInfo) (int, error) + func (s *BaseSerializer) WriteBytes(id int, msgBytes []byte) ([]byte, error) + type Deserializer interface + Close func() + ConfigureDeserializer func(client schemaregistry.Client, serdeType Type, conf *DeserializerConfig) error + Deserialize func(topic string, payload []byte) (interface{}, error) + DeserializeInto func(topic string, payload []byte, msg interface{}) error + type DeserializerConfig struct + func NewDeserializerConfig() *DeserializerConfig + type FailFunc func(string, ...error) + var MaybeFail FailFunc + func InitFailFunc(t *testing.T) FailFunc + type MessageFactory func(subject string, name string) (interface{}, error) + type Serde struct + Client schemaregistry.Client + SerdeType Type + SubjectNameStrategy SubjectNameStrategyFunc + func (s *Serde) Close() + type Serializer interface + Close func() + ConfigureSerializer func(client schemaregistry.Client, serdeType Type, conf *SerializerConfig) error + Serialize func(topic string, msg interface{}) ([]byte, error) + type SerializerConfig struct + AutoRegisterSchemas bool + NormalizeSchemas bool + UseLatestVersion bool + UseSchemaID int + func NewSerializerConfig() *SerializerConfig + type SubjectNameStrategyFunc func(topic string, serdeType Type, schema schemaregistry.SchemaInfo) (string, error) + type Type = int