protobuf

Jul 7, 2022

Changes in this version

+ type Deserializer struct

+ ProtoRegistry *protoregistry.Types

+ func NewDeserializer(client schemaregistry.Client, serdeType serde.Type, conf *DeserializerConfig) (*Deserializer, error)

+ func (s *Deserializer) ConfigureDeserializer(client schemaregistry.Client, serdeType serde.Type, ...) error

+ func (s *Deserializer) Deserialize(topic string, payload []byte) (interface{}, error)

+ func (s *Deserializer) DeserializeInto(topic string, payload []byte, msg interface{}) error

+ type DeserializerConfig struct

+ func NewDeserializerConfig() *DeserializerConfig

+ type Serializer struct

+ func NewSerializer(client schemaregistry.Client, serdeType serde.Type, conf *SerializerConfig) (*Serializer, error)

+ func (s *Serializer) Serialize(topic string, msg interface{}) ([]byte, error)

+ type SerializerConfig struct

+ func NewSerializerConfig() *SerializerConfig