avro

Documentation

Index

• type DeserializerConfig
  • func NewDeserializerConfig() *DeserializerConfig
• type GenericDeserializer
  • func NewGenericDeserializer(client schemaregistry.Client, serdeType serde.Type, conf *DeserializerConfig) (*GenericDeserializer, error)
  • func (s *GenericDeserializer) Deserialize(topic string, payload []byte) (interface{}, error)
  • func (s *GenericDeserializer) DeserializeInto(topic string, payload []byte, msg interface{}) error
• type GenericSerializer
  • func NewGenericSerializer(client schemaregistry.Client, serdeType serde.Type, conf *SerializerConfig) (*GenericSerializer, error)
  • func (s *GenericSerializer) Serialize(topic string, msg interface{}) ([]byte, error)
• type SerializerConfig
  • func NewSerializerConfig() *SerializerConfig
• type SpecificAvroMessage
• type SpecificDeserializer
  • func NewSpecificDeserializer(client schemaregistry.Client, serdeType serde.Type, conf *DeserializerConfig) (*SpecificDeserializer, error)
  • func (s *SpecificDeserializer) Deserialize(topic string, payload []byte) (interface{}, error)
  • func (s *SpecificDeserializer) DeserializeInto(topic string, payload []byte, msg interface{}) error
• type SpecificSerializer
  • func NewSpecificSerializer(client schemaregistry.Client, serdeType serde.Type, conf *SerializerConfig) (*SpecificSerializer, error)
  • func (s *SpecificSerializer) Serialize(topic string, msg interface{}) ([]byte, error)

Types

type DeserializerConfig

type DeserializerConfig struct {
	serde.DeserializerConfig
}

DeserializerConfig is used to pass multiple configuration options to the deserializers.

func NewDeserializerConfig

func NewDeserializerConfig() *DeserializerConfig

NewDeserializerConfig returns a new configuration instance with sane defaults.

type GenericDeserializer

type GenericDeserializer struct {
	serde.BaseDeserializer
}

GenericDeserializer represents a generic Avro deserializer

func NewGenericDeserializer

func NewGenericDeserializer(client schemaregistry.Client, serdeType serde.Type, conf *DeserializerConfig) (*GenericDeserializer, error)

NewGenericDeserializer creates an Avro deserializer for generic objects

func (*GenericDeserializer) Deserialize

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

Deserialize implements deserialization of generic Avro data

func (*GenericDeserializer) DeserializeInto

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

DeserializeInto implements deserialization of generic Avro data to the given object

type GenericSerializer

type GenericSerializer struct {
	serde.BaseSerializer
}

GenericSerializer represents a generic Avro serializer

func NewGenericSerializer

func NewGenericSerializer(client schemaregistry.Client, serdeType serde.Type, conf *SerializerConfig) (*GenericSerializer, error)

NewGenericSerializer creates an Avro serializer for generic objects

func (*GenericSerializer) Serialize

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

Serialize implements serialization of generic Avro data

type SerializerConfig

type SerializerConfig struct {
	serde.SerializerConfig
}

SerializerConfig is used to pass multiple configuration options to the serializers.

func NewSerializerConfig

func NewSerializerConfig() *SerializerConfig

NewSerializerConfig returns a new configuration instance with sane defaults.

type SpecificAvroMessage

type SpecificAvroMessage interface {
	types.Field
	Serialize(w io.Writer) error
	Schema() string
}

SpecificAvroMessage represents a generated Avro class from gogen-avro

type SpecificDeserializer

type SpecificDeserializer struct {
	serde.BaseDeserializer
}

SpecificDeserializer represents a specific Avro deserializer

func NewSpecificDeserializer

func NewSpecificDeserializer(client schemaregistry.Client, serdeType serde.Type, conf *DeserializerConfig) (*SpecificDeserializer, error)

NewSpecificDeserializer creates an Avro deserializer for Avro-generated objects

func (*SpecificDeserializer) Deserialize

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

Deserialize implements deserialization of specific Avro data

func (*SpecificDeserializer) DeserializeInto

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

DeserializeInto implements deserialization of specific Avro data to the given object

type SpecificSerializer

type SpecificSerializer struct {
	serde.BaseSerializer
}

SpecificSerializer represents a specific Avro serializer

func NewSpecificSerializer

func NewSpecificSerializer(client schemaregistry.Client, serdeType serde.Type, conf *SerializerConfig) (*SpecificSerializer, error)

NewSpecificSerializer creates an Avro serializer for Avro-generated objects

func (*SpecificSerializer) Serialize

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

Serialize implements serialization of specific Avro data