Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var BinaryType = reflect.TypeOf(&Binary{})
View Source
var GenericRecordType = reflect.TypeOf(&avro.GenericRecord{})
View Source
var KVBinaryType = reflect.TypeOf(&KVBinary{})
Functions ¶
This section is empty.
Types ¶
type GenericDecoder ¶
type GenericDecoder struct{}
func (*GenericDecoder) InType ¶
func (d *GenericDecoder) InType() reflect.Type
func (*GenericDecoder) Materialize ¶
func (d *GenericDecoder) Materialize() func(input interface{}) interface{}
func (*GenericDecoder) OutType ¶
func (d *GenericDecoder) OutType() reflect.Type
type GenericEncoder ¶
type GenericEncoder struct{}
func (*GenericEncoder) InType ¶
func (e *GenericEncoder) InType() reflect.Type
func (*GenericEncoder) Materialize ¶
func (e *GenericEncoder) Materialize() func(input interface{}) interface{}
func (*GenericEncoder) OutType ¶
func (e *GenericEncoder) OutType() reflect.Type
type GenericProjector ¶
func (*GenericProjector) InType ¶
func (p *GenericProjector) InType() reflect.Type
func (*GenericProjector) Materialize ¶
func (p *GenericProjector) Materialize() func(input interface{}) interface{}
func (*GenericProjector) OutType ¶
func (p *GenericProjector) OutType() reflect.Type
type JsonEncoder ¶
type JsonEncoder struct{}
func (*JsonEncoder) InType ¶
func (e *JsonEncoder) InType() reflect.Type
func (*JsonEncoder) Materialize ¶
func (e *JsonEncoder) Materialize() func(input interface{}) interface{}
func (*JsonEncoder) OutType ¶
func (e *JsonEncoder) OutType() reflect.Type
type SchemaRegistryDecoder ¶
type SchemaRegistryDecoder struct {
Url string
}
func (*SchemaRegistryDecoder) InType ¶
func (cf *SchemaRegistryDecoder) InType() reflect.Type
func (*SchemaRegistryDecoder) Materialize ¶
func (cf *SchemaRegistryDecoder) Materialize() func(input interface{}) interface{}
func (*SchemaRegistryDecoder) OutType ¶
func (cf *SchemaRegistryDecoder) OutType() reflect.Type
type SchemaRegistryEncoder ¶
func (*SchemaRegistryEncoder) InType ¶
func (cf *SchemaRegistryEncoder) InType() reflect.Type
func (*SchemaRegistryEncoder) Materialize ¶
func (cf *SchemaRegistryEncoder) Materialize() func(input interface{}) interface{}
func (*SchemaRegistryEncoder) OutType ¶
func (cf *SchemaRegistryEncoder) OutType() reflect.Type
Click to show internal directories.
Click to hide internal directories.