avro

Documentation

Index

• func CreateSchema(schema string) *goavro.Codec
• func Writer(msg map[string]interface{}, codec *goavro.Codec) ([]byte, error)
• type Reader
  • func NewReader(data []byte) (*Reader, error)
  • func (a *Reader) ByteString() ([]byte, error)
  • func (a *Reader) JSON() (string, error)
  • func (a *Reader) Map() (map[string]interface{}, error)

Functions

func CreateSchema

func CreateSchema(schema string) *goavro.Codec

CreateSchema creates an avro codec from an avro schema text file

func Writer

func Writer(msg map[string]interface{}, codec *goavro.Codec) ([]byte, error)

Writer writes a user defined message with a avro codec to a slice of bytes.

Types

type Reader

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

Reader is the struct to handle the avro reader

func NewReader

func NewReader(data []byte) (*Reader, error)

NewReader Creates a new avro reader that takes []byte and returns a Reader object.

func (*Reader) ByteString

func (a *Reader) ByteString() ([]byte, error)

ByteString returns a slice of bytes containing the JSON string

func (*Reader) JSON

func (a *Reader) JSON() (string, error)

JSON returns a string that contains a JSON of the read data

func (*Reader) Map

func (a *Reader) Map() (map[string]interface{}, error)

Map returns a map containing all key value pairs