protobuf

Jul 10, 2024

Changes in this version

+ type Serde struct

+ func (s *Serde) FieldTransform(client schemaregistry.Client, ctx serde.RuleContext, ...) (interface{}, error)

May 7, 2024

Changes in this version

type Serializer

+ Conf *SerializerConfig

type SerializerConfig

+ CacheSchemas bool

Jan 23, 2023

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