generic

Documentation

Index

• type Codec
  • func NewCodec(writer, reader schema.AvroType) (*Codec, error)
  • func NewCodecFromSchema(writer, reader []byte) (*Codec, error)
  • func (c *Codec) Deserialize(r io.Reader) (interface{}, error)
• type Datum
  • func DatumForType(t schema.AvroType) Datum

Types

type Codec

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

func NewCodec

func NewCodec(writer, reader schema.AvroType) (*Codec, error)

func NewCodecFromSchema

func NewCodecFromSchema(writer, reader []byte) (*Codec, error)

func (*Codec) Deserialize

func (c *Codec) Deserialize(r io.Reader) (interface{}, error)

type Datum

type Datum interface {
	types.Field
	Datum() interface{}
}

func DatumForType

func DatumForType(t schema.AvroType) Datum