soe

Documentation

Overview

Package soe provides convenience methods to read and write Avro Single-Object Encoding headers

Index

• Variables
• func ReadHeader(r io.Reader) ([]byte, error)
• func WriteRecord(w io.Writer, record AvroRecord) error
• type AvroRecord

Variables

var HeaderV1 = []byte{0xC3, 0x01}

Functions

func ReadHeader

func ReadHeader(r io.Reader) ([]byte, error)

ReadHeader reads the magic bytes and CRC64 schema fingerprint from the given reader and returns the fingerprint.

func WriteRecord

func WriteRecord(w io.Writer, record AvroRecord) error

WriteRecord writes the single-object encoding framing (the magic bytes and the Avro CRC64 fingerprint of the canonical form of the record schema), and the record itself into `w`.

Types

type AvroRecord

type AvroRecord interface {
	Serialize(io.Writer) error
	AvroCRC64Fingerprint() []byte
}

AvroRecord is an interface fulfilled by the structs generated by gogen-avro for Avro records.