avrov2

Documentation

Index

• func StructToSchema(t reflect.Type, tags ...reflect.StructTag) (avro.Schema, error)
• type Deserializer
  • func NewDeserializer(client schemaregistry.Client, serdeType serde.Type, conf *DeserializerConfig) (*Deserializer, error)
  • func (s *Deserializer) Deserialize(topic string, payload []byte) (interface{}, error)
  • func (s *Deserializer) DeserializeInto(topic string, payload []byte, msg interface{}) error
• type DeserializerConfig
  • func NewDeserializerConfig() *DeserializerConfig
• type Serde
  • func (s *Serde) FieldTransform(client schemaregistry.Client, ctx serde.RuleContext, ...) (interface{}, error)
  • func (s *Serde) RegisterType(name string, msgType interface{})
  • func (s *Serde) RegisterTypeFromMessageFactory(name string, messageFactory serde.MessageFactory) error
• type Serializer
  • func NewSerializer(client schemaregistry.Client, serdeType serde.Type, conf *SerializerConfig) (*Serializer, error)
  • func (s *Serializer) Serialize(topic string, msg interface{}) ([]byte, error)
• type SerializerConfig
  • func NewSerializerConfig() *SerializerConfig

Functions

func StructToSchema

func StructToSchema(t reflect.Type, tags ...reflect.StructTag) (avro.Schema, error)

StructToSchema generates an Avro schema from the given struct type

Types

type Deserializer

type Deserializer struct {
	serde.BaseDeserializer
	*Serde
}

Deserializer represents a generic Avro deserializer

func NewDeserializer

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

NewDeserializer creates an Avro deserializer for generic objects

func (*Deserializer) Deserialize

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

Deserialize implements deserialization of generic Avro data

func (*Deserializer) DeserializeInto

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

DeserializeInto implements deserialization of generic Avro data to the given object

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 Serde

type Serde struct {
	// contains filtered or unexported fields
}

Serde represents an Avro serde

func (*Serde) FieldTransform

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

FieldTransform transforms a field value using the given field transform

func (*Serde) RegisterType

func (s *Serde) RegisterType(name string, msgType interface{})

RegisterType registers a type with the Avro Serde

func (*Serde) RegisterTypeFromMessageFactory

func (s *Serde) RegisterTypeFromMessageFactory(name string, messageFactory serde.MessageFactory) error

RegisterTypeFromMessageFactory registers a type with the Avro Serde using a message factory

type Serializer

type Serializer struct {
	serde.BaseSerializer
	*Serde
}

Serializer represents a generic Avro serializer

func NewSerializer

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

NewSerializer creates an Avro serializer for generic objects

func (*Serializer) Serialize

func (s *Serializer) 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.