Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
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 ¶
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
Source Files