avro

Documentation

Index

• type Converter
  • func NewConverter(registry *SchemaRegistry, options ConverterOptions) *Converter
  • func (c *Converter) Parse(data []byte) (map[string]interface{}, *EventSource, error)
• type ConverterOptions
• type EventSource
• type SchemaRegistry
  • func (r *SchemaRegistry) Get(key string) (*goavro.Codec, error)

Types

type Converter

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

func NewConverter

func NewConverter(registry *SchemaRegistry, options ConverterOptions) *Converter

func (*Converter) Parse

func (c *Converter) Parse(data []byte) (map[string]interface{}, *EventSource, error)

type ConverterOptions

type ConverterOptions struct {
	AvroNamespace string // prefix for namespace prefix which will be used to identify self defined records
	ToLowerCase   bool   // map all field names to lower case
}

type EventSource

type EventSource struct {
	Record interface{}
	Schema string
}

type SchemaRegistry

type SchemaRegistry struct {
	Consul          schema.Registry
	ConfluentClient *schemaregistry.Client
	// contains filtered or unexported fields
}

func (*SchemaRegistry) Get

func (r *SchemaRegistry) Get(key string) (*goavro.Codec, error)