Versions in this module Expand all Collapse all v0 v0.0.1 Aug 19, 2019 Changes in this version + var BinaryType = reflect.TypeOf(&Binary{}) + var GenericRecordType = reflect.TypeOf(&avro.GenericRecord{}) + var KVBinaryType = reflect.TypeOf(&KVBinary{}) + type Binary struct + Data []byte + Schema avro.Schema + type GenericDecoder struct + func (d *GenericDecoder) InType() reflect.Type + func (d *GenericDecoder) Materialize() func(input interface{}) interface{} + func (d *GenericDecoder) OutType() reflect.Type + type GenericEncoder struct + func (e *GenericEncoder) InType() reflect.Type + func (e *GenericEncoder) Materialize() func(input interface{}) interface{} + func (e *GenericEncoder) OutType() reflect.Type + type GenericProjector struct + TargetSchema avrolib.Schema + func (p *GenericProjector) InType() reflect.Type + func (p *GenericProjector) Materialize() func(input interface{}) interface{} + func (p *GenericProjector) OutType() reflect.Type + type JsonEncoder struct + func (e *JsonEncoder) InType() reflect.Type + func (e *JsonEncoder) Materialize() func(input interface{}) interface{} + func (e *JsonEncoder) OutType() reflect.Type + type KVBinary struct + type SchemaRegistryDecoder struct + Url string + func (cf *SchemaRegistryDecoder) InType() reflect.Type + func (cf *SchemaRegistryDecoder) Materialize() func(input interface{}) interface{} + func (cf *SchemaRegistryDecoder) OutType() reflect.Type + type SchemaRegistryEncoder struct + Subject string + Url string + func (cf *SchemaRegistryEncoder) InType() reflect.Type + func (cf *SchemaRegistryEncoder) Materialize() func(input interface{}) interface{} + func (cf *SchemaRegistryEncoder) OutType() reflect.Type