Versions in this module Expand all Collapse all v0 v0.1.35 Aug 9, 2026 v0.1.34 Aug 3, 2026 Changes in this version + const Auto + const NameConsumerOffsetsKey + const NameConsumerOffsetsValue + const NameDouble + const NameFloat + const NameHex + const NameInt + const NameJSON + const NameLong + const NameMsgpack + const NameNull + const NameRawProtobuf + const NameSchemaRegistry + const NameString + func Decode(reg *Registry, chosen string, data []byte) (text, name string, fallback bool) + func IsFallback(name string) bool + func SchemaID(data []byte) (uint32, bool) + func SelectSerde(configs []SerdeConfig, topic string, isKey bool) string + func Validate(reg *Registry, chosen string, sample []byte) error + type ConsumerOffsetsKeySerde struct + func (ConsumerOffsetsKeySerde) Name() string + func (s ConsumerOffsetsKeySerde) CanDeserialize(d []byte) bool + func (s ConsumerOffsetsKeySerde) Deserialize(d []byte) (string, error) + type ConsumerOffsetsValueSerde struct + func (ConsumerOffsetsValueSerde) Name() string + func (s ConsumerOffsetsValueSerde) CanDeserialize(d []byte) bool + func (s ConsumerOffsetsValueSerde) Deserialize(d []byte) (string, error) + type DecodeFunc func(data []byte) ([]byte, error) + type DescriptorProtobufSerde struct + func NewDescriptorProtobufSerde(name, descPath, messageName string) (*DescriptorProtobufSerde, error) + func (s *DescriptorProtobufSerde) CanDeserialize(d []byte) bool + func (s *DescriptorProtobufSerde) Deserialize(d []byte) (string, error) + func (s *DescriptorProtobufSerde) Name() string + type DuplicateSerdeError struct + Name string + func (e DuplicateSerdeError) Error() string + type HexSerde struct + func (HexSerde) CanDeserialize(_ []byte) bool + func (HexSerde) Deserialize(d []byte) (string, error) + func (HexSerde) Name() string + func (HexSerde) Serialize(text string) ([]byte, error) + type JSONSerde struct + func (JSONSerde) CanDeserialize(d []byte) bool + func (JSONSerde) Deserialize(d []byte) (string, error) + func (JSONSerde) Name() string + func (JSONSerde) Serialize(text string) ([]byte, error) + type MsgpackSerde struct + func (MsgpackSerde) CanDeserialize(d []byte) bool + func (MsgpackSerde) Deserialize(d []byte) (string, error) + func (MsgpackSerde) Name() string + func (MsgpackSerde) Serialize(text string) ([]byte, error) + type NullSerde struct + func (NullSerde) CanDeserialize(d []byte) bool + func (NullSerde) Deserialize(d []byte) (string, error) + func (NullSerde) Name() string + type RawProtobufSerde struct + func (RawProtobufSerde) CanDeserialize(d []byte) bool + func (RawProtobufSerde) Deserialize(d []byte) (string, error) + func (RawProtobufSerde) Name() string + type Registry struct + func BuildRegistry(decode DecodeFunc, configs []SerdeConfig) (*Registry, error) + func NewRegistry() *Registry + func (r *Registry) AutoDetect(data []byte) Serde + func (r *Registry) Get(name string) (Serde, bool) + func (r *Registry) Names() []string + func (r *Registry) Register(s Serde) error + func (r *Registry) RegisterAuto(s Serde) error + type SchemaRegistrySerde struct + func NewSchemaRegistrySerde(decode DecodeFunc) *SchemaRegistrySerde + func (s *SchemaRegistrySerde) CanDeserialize(data []byte) bool + func (s *SchemaRegistrySerde) Deserialize(data []byte) (string, error) + func (s *SchemaRegistrySerde) Name() string + type Serde interface + CanDeserialize func(data []byte) bool + Deserialize func(data []byte) (string, error) + Name func() string + func DoubleSerde() Serde + func FloatSerde() Serde + func IntSerde() Serde + func LongSerde() Serde + type SerdeConfig struct + DescriptorPath string + MessageType string + Name string + Target string + TopicPattern string + type Serializer interface + Serialize func(text string) ([]byte, error) + type StringSerde struct + func (StringSerde) CanDeserialize(_ []byte) bool + func (StringSerde) Deserialize(d []byte) (string, error) + func (StringSerde) Name() string + func (StringSerde) Serialize(text string) ([]byte, error) + type UnknownSerdeError struct + Name string + func (e UnknownSerdeError) Error() string
Go to main page