serializers

Jan 19, 2023

Changes in this version

+ var ErrIsNotAvro = errors.New("Is not avro")

+ var SupportedSerializers = []string

+ type AvroSerializer struct

+ func NewAvroSerializer(avroSchemaCacheURL string, schemaID int) (*AvroSerializer, error)

+ func (as *AvroSerializer) Decode(raw []byte) ([]byte, error)

+ func (as *AvroSerializer) Encode(input []byte) ([]byte, error)

+ type Base64Serializer struct

+ func NewBase64Serializer() *Base64Serializer

+ func (bs *Base64Serializer) Decode(input []byte) ([]byte, error)

+ func (bs *Base64Serializer) Encode(input []byte) ([]byte, error)

+ type DescriptorRegistry struct

+ func NewDescriptorRegistry(importPaths []string, exclusions []string) (*DescriptorRegistry, error)

+ func (d *DescriptorRegistry) MessageForType(_type string) *dynamic.Message

+ type MessagePackSerializer struct

+ func NewMessagePackSerializer() *MessagePackSerializer

+ func (mp *MessagePackSerializer) Decode(input []byte) ([]byte, error)

+ func (mp *MessagePackSerializer) Encode(input []byte) ([]byte, error)

+ type ProtobufSerializer struct

+ func NewProtobufSerializer(importPaths []string, protoType string) (*ProtobufSerializer, error)

+ func (ps *ProtobufSerializer) Decode(data []byte) ([]byte, error)

+ func (ps *ProtobufSerializer) Encode(raw []byte) ([]byte, error)

+ func (ps *ProtobufSerializer) GetExample(protoType string) string

+ type RawSerializer struct

+ func NewRawSerializer() *RawSerializer

+ func (re *RawSerializer) Decode(input []byte) ([]byte, error)

+ func (re *RawSerializer) Encode(input []byte) ([]byte, error)

+ type SchemaCache struct

+ func NewSchemaCache(url string) (*SchemaCache, error)

+ func (c *SchemaCache) DecodeMessage(b []byte) (message []byte, err error)

+ func (c *SchemaCache) EncodeMessage(schemaID int, json []byte) (message []byte, err error)