avro

Documentation

Index

• type SchemaCache
  • func NewSchemaCache(url string) (*SchemaCache, error)
  • func (c *SchemaCache) DecodeMessage(b []byte) (message []byte, err error)

Types

type SchemaCache

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

SchemaCache connects to the Confluent schema registry and maintains a cached versions of Avro schemas and codecs.

func NewSchemaCache

func NewSchemaCache(url string) (*SchemaCache, error)

NewSchemaCache returns a new Cache instance

func (*SchemaCache) DecodeMessage

func (c *SchemaCache) DecodeMessage(b []byte) (message []byte, err error)

DecodeMessage returns a text representation of an Avro-encoded message.