Documentation ¶
Overview ¶
Code generated by github.com/actgardner/gogen-avro/v8. DO NOT EDIT.
- SOURCE:
- schema.avsc
Code generated by github.com/actgardner/gogen-avro/v8. DO NOT EDIT.
- SOURCE:
- schema.avsc
Code generated by github.com/actgardner/gogen-avro/v8. DO NOT EDIT.
- SOURCE:
- schema.avsc
Code generated by github.com/actgardner/gogen-avro/v8. DO NOT EDIT.
- SOURCE:
- schema.avsc
Code generated by github.com/actgardner/gogen-avro/v8. DO NOT EDIT.
- SOURCE:
- schema.avsc
Code generated by github.com/actgardner/gogen-avro/v8. DO NOT EDIT.
- SOURCE:
- schema.avsc
Code generated by github.com/actgardner/gogen-avro/v8. DO NOT EDIT.
- SOURCE:
- schema.avsc
Code generated by github.com/actgardner/gogen-avro/v8. DO NOT EDIT.
- SOURCE:
- schema.avsc
Index ¶
- Constants
- func NewRecordBarWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
- func NewRecordFooWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
- func NewRecordSchemaWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
- type ArrayUnionRecordFooRecordBarWrapper
- func (r *ArrayUnionRecordFooRecordBarWrapper) AppendArray() types.Field
- func (_ *ArrayUnionRecordFooRecordBarWrapper) AppendMap(key string) types.Field
- func (_ *ArrayUnionRecordFooRecordBarWrapper) Finalize()
- func (_ *ArrayUnionRecordFooRecordBarWrapper) Get(i int) types.Field
- func (r *ArrayUnionRecordFooRecordBarWrapper) NullField(i int)
- func (_ *ArrayUnionRecordFooRecordBarWrapper) SetBoolean(v bool)
- func (_ *ArrayUnionRecordFooRecordBarWrapper) SetBytes(v []byte)
- func (_ *ArrayUnionRecordFooRecordBarWrapper) SetDefault(i int)
- func (_ *ArrayUnionRecordFooRecordBarWrapper) SetDouble(v float64)
- func (_ *ArrayUnionRecordFooRecordBarWrapper) SetFloat(v float32)
- func (_ *ArrayUnionRecordFooRecordBarWrapper) SetInt(v int32)
- func (_ *ArrayUnionRecordFooRecordBarWrapper) SetLong(v int64)
- func (_ *ArrayUnionRecordFooRecordBarWrapper) SetString(v string)
- func (_ *ArrayUnionRecordFooRecordBarWrapper) SetUnionElem(v int64)
- type RecordBar
- func (_ RecordBar) AppendArray() types.Field
- func (_ RecordBar) AppendMap(key string) types.Field
- func (_ RecordBar) AvroCRC64Fingerprint() []byte
- func (_ RecordBar) Finalize()
- func (r *RecordBar) Get(i int) types.Field
- func (r RecordBar) MarshalJSON() ([]byte, error)
- func (r *RecordBar) NullField(i int)
- func (r RecordBar) Schema() string
- func (r RecordBar) SchemaName() string
- func (r RecordBar) Serialize(w io.Writer) error
- func (_ RecordBar) SetBoolean(v bool)
- func (_ RecordBar) SetBytes(v []byte)
- func (r *RecordBar) SetDefault(i int)
- func (_ RecordBar) SetDouble(v float64)
- func (_ RecordBar) SetFloat(v float32)
- func (_ RecordBar) SetInt(v int32)
- func (_ RecordBar) SetLong(v int64)
- func (_ RecordBar) SetString(v string)
- func (_ RecordBar) SetUnionElem(v int64)
- func (r *RecordBar) UnmarshalJSON(data []byte) error
- type RecordBarReader
- type RecordFoo
- func (_ RecordFoo) AppendArray() types.Field
- func (_ RecordFoo) AppendMap(key string) types.Field
- func (_ RecordFoo) AvroCRC64Fingerprint() []byte
- func (_ RecordFoo) Finalize()
- func (r *RecordFoo) Get(i int) types.Field
- func (r RecordFoo) MarshalJSON() ([]byte, error)
- func (r *RecordFoo) NullField(i int)
- func (r RecordFoo) Schema() string
- func (r RecordFoo) SchemaName() string
- func (r RecordFoo) Serialize(w io.Writer) error
- func (_ RecordFoo) SetBoolean(v bool)
- func (_ RecordFoo) SetBytes(v []byte)
- func (r *RecordFoo) SetDefault(i int)
- func (_ RecordFoo) SetDouble(v float64)
- func (_ RecordFoo) SetFloat(v float32)
- func (_ RecordFoo) SetInt(v int32)
- func (_ RecordFoo) SetLong(v int64)
- func (_ RecordFoo) SetString(v string)
- func (_ RecordFoo) SetUnionElem(v int64)
- func (r *RecordFoo) UnmarshalJSON(data []byte) error
- type RecordFooReader
- type RecordSchema
- func (_ RecordSchema) AppendArray() types.Field
- func (_ RecordSchema) AppendMap(key string) types.Field
- func (_ RecordSchema) AvroCRC64Fingerprint() []byte
- func (_ RecordSchema) Finalize()
- func (r *RecordSchema) Get(i int) types.Field
- func (r RecordSchema) MarshalJSON() ([]byte, error)
- func (r *RecordSchema) NullField(i int)
- func (r RecordSchema) Schema() string
- func (r RecordSchema) SchemaName() string
- func (r RecordSchema) Serialize(w io.Writer) error
- func (_ RecordSchema) SetBoolean(v bool)
- func (_ RecordSchema) SetBytes(v []byte)
- func (r *RecordSchema) SetDefault(i int)
- func (_ RecordSchema) SetDouble(v float64)
- func (_ RecordSchema) SetFloat(v float32)
- func (_ RecordSchema) SetInt(v int32)
- func (_ RecordSchema) SetLong(v int64)
- func (_ RecordSchema) SetString(v string)
- func (_ RecordSchema) SetUnionElem(v int64)
- func (r *RecordSchema) UnmarshalJSON(data []byte) error
- type RecordSchemaReader
- type UnionRecordFooRecordBar
- func (_ UnionRecordFooRecordBar) AppendArray() types.Field
- func (_ UnionRecordFooRecordBar) AppendMap(key string) types.Field
- func (_ UnionRecordFooRecordBar) Finalize()
- func (r *UnionRecordFooRecordBar) Get(i int) types.Field
- func (r UnionRecordFooRecordBar) MarshalJSON() ([]byte, error)
- func (_ UnionRecordFooRecordBar) NullField(i int)
- func (r UnionRecordFooRecordBar) Schema() string
- func (r UnionRecordFooRecordBar) Serialize(w io.Writer) error
- func (_ UnionRecordFooRecordBar) SetBoolean(v bool)
- func (_ UnionRecordFooRecordBar) SetBytes(v []byte)
- func (_ UnionRecordFooRecordBar) SetDefault(i int)
- func (_ UnionRecordFooRecordBar) SetDouble(v float64)
- func (_ UnionRecordFooRecordBar) SetFloat(v float32)
- func (_ UnionRecordFooRecordBar) SetInt(v int32)
- func (r *UnionRecordFooRecordBar) SetLong(v int64)
- func (_ UnionRecordFooRecordBar) SetString(v string)
- func (r *UnionRecordFooRecordBar) UnmarshalJSON(data []byte) error
- type UnionRecordFooRecordBarTypeEnum
Constants ¶
View Source
const RecordBarAvroCRC64Fingerprint = "0\x99\x1e\"\x92\xe1\x82{"
View Source
const RecordFooAvroCRC64Fingerprint = "\x94\f\x14v\xb3\x98ߴ"
View Source
const RecordSchemaAvroCRC64Fingerprint = "\xb8\xce$\xde\v\xd5\x00<"
Variables ¶
This section is empty.
Functions ¶
func NewRecordBarWriter ¶
func NewRecordFooWriter ¶
Types ¶
type ArrayUnionRecordFooRecordBarWrapper ¶
type ArrayUnionRecordFooRecordBarWrapper struct {
Target *[]UnionRecordFooRecordBar
}
func (*ArrayUnionRecordFooRecordBarWrapper) AppendArray ¶
func (r *ArrayUnionRecordFooRecordBarWrapper) AppendArray() types.Field
func (*ArrayUnionRecordFooRecordBarWrapper) AppendMap ¶
func (_ *ArrayUnionRecordFooRecordBarWrapper) AppendMap(key string) types.Field
func (*ArrayUnionRecordFooRecordBarWrapper) Finalize ¶
func (_ *ArrayUnionRecordFooRecordBarWrapper) Finalize()
func (*ArrayUnionRecordFooRecordBarWrapper) Get ¶
func (_ *ArrayUnionRecordFooRecordBarWrapper) Get(i int) types.Field
func (*ArrayUnionRecordFooRecordBarWrapper) NullField ¶
func (r *ArrayUnionRecordFooRecordBarWrapper) NullField(i int)
func (*ArrayUnionRecordFooRecordBarWrapper) SetBoolean ¶
func (_ *ArrayUnionRecordFooRecordBarWrapper) SetBoolean(v bool)
func (*ArrayUnionRecordFooRecordBarWrapper) SetBytes ¶
func (_ *ArrayUnionRecordFooRecordBarWrapper) SetBytes(v []byte)
func (*ArrayUnionRecordFooRecordBarWrapper) SetDefault ¶
func (_ *ArrayUnionRecordFooRecordBarWrapper) SetDefault(i int)
func (*ArrayUnionRecordFooRecordBarWrapper) SetDouble ¶
func (_ *ArrayUnionRecordFooRecordBarWrapper) SetDouble(v float64)
func (*ArrayUnionRecordFooRecordBarWrapper) SetFloat ¶
func (_ *ArrayUnionRecordFooRecordBarWrapper) SetFloat(v float32)
func (*ArrayUnionRecordFooRecordBarWrapper) SetInt ¶
func (_ *ArrayUnionRecordFooRecordBarWrapper) SetInt(v int32)
func (*ArrayUnionRecordFooRecordBarWrapper) SetLong ¶
func (_ *ArrayUnionRecordFooRecordBarWrapper) SetLong(v int64)
func (*ArrayUnionRecordFooRecordBarWrapper) SetString ¶
func (_ *ArrayUnionRecordFooRecordBarWrapper) SetString(v string)
func (*ArrayUnionRecordFooRecordBarWrapper) SetUnionElem ¶
func (_ *ArrayUnionRecordFooRecordBarWrapper) SetUnionElem(v int64)
type RecordBar ¶
type RecordBar struct {
Id string `json:"id"`
}
func NewRecordBar ¶
func NewRecordBar() RecordBar
func (RecordBar) AppendArray ¶
func (RecordBar) AvroCRC64Fingerprint ¶
func (RecordBar) MarshalJSON ¶
func (RecordBar) SchemaName ¶
func (RecordBar) SetBoolean ¶
func (*RecordBar) SetDefault ¶
func (RecordBar) SetUnionElem ¶
func (*RecordBar) UnmarshalJSON ¶
type RecordBarReader ¶
type RecordBarReader struct {
// contains filtered or unexported fields
}
container reader
func NewRecordBarReader ¶
func NewRecordBarReader(r io.Reader) (*RecordBarReader, error)
func (RecordBarReader) Read ¶
func (r RecordBarReader) Read() (RecordBar, error)
type RecordFoo ¶
type RecordFoo struct {
Id string `json:"id"`
}
func NewRecordFoo ¶
func NewRecordFoo() RecordFoo
func (RecordFoo) AppendArray ¶
func (RecordFoo) AvroCRC64Fingerprint ¶
func (RecordFoo) MarshalJSON ¶
func (RecordFoo) SchemaName ¶
func (RecordFoo) SetBoolean ¶
func (*RecordFoo) SetDefault ¶
func (RecordFoo) SetUnionElem ¶
func (*RecordFoo) UnmarshalJSON ¶
type RecordFooReader ¶
type RecordFooReader struct {
// contains filtered or unexported fields
}
container reader
func NewRecordFooReader ¶
func NewRecordFooReader(r io.Reader) (*RecordFooReader, error)
func (RecordFooReader) Read ¶
func (r RecordFooReader) Read() (RecordFoo, error)
type RecordSchema ¶
type RecordSchema struct {
Data []UnionRecordFooRecordBar `json:"data"`
}
func DeserializeRecordSchema ¶
func DeserializeRecordSchema(r io.Reader) (RecordSchema, error)
func DeserializeRecordSchemaFromSchema ¶
func DeserializeRecordSchemaFromSchema(r io.Reader, schema string) (RecordSchema, error)
func NewRecordSchema ¶
func NewRecordSchema() RecordSchema
func (RecordSchema) AppendArray ¶
func (_ RecordSchema) AppendArray() types.Field
func (RecordSchema) AvroCRC64Fingerprint ¶
func (_ RecordSchema) AvroCRC64Fingerprint() []byte
func (RecordSchema) Finalize ¶
func (_ RecordSchema) Finalize()
func (RecordSchema) MarshalJSON ¶
func (r RecordSchema) MarshalJSON() ([]byte, error)
func (*RecordSchema) NullField ¶
func (r *RecordSchema) NullField(i int)
func (RecordSchema) Schema ¶
func (r RecordSchema) Schema() string
func (RecordSchema) SchemaName ¶
func (r RecordSchema) SchemaName() string
func (RecordSchema) SetBoolean ¶
func (_ RecordSchema) SetBoolean(v bool)
func (RecordSchema) SetBytes ¶
func (_ RecordSchema) SetBytes(v []byte)
func (*RecordSchema) SetDefault ¶
func (r *RecordSchema) SetDefault(i int)
func (RecordSchema) SetDouble ¶
func (_ RecordSchema) SetDouble(v float64)
func (RecordSchema) SetFloat ¶
func (_ RecordSchema) SetFloat(v float32)
func (RecordSchema) SetInt ¶
func (_ RecordSchema) SetInt(v int32)
func (RecordSchema) SetLong ¶
func (_ RecordSchema) SetLong(v int64)
func (RecordSchema) SetString ¶
func (_ RecordSchema) SetString(v string)
func (RecordSchema) SetUnionElem ¶
func (_ RecordSchema) SetUnionElem(v int64)
func (*RecordSchema) UnmarshalJSON ¶
func (r *RecordSchema) UnmarshalJSON(data []byte) error
type RecordSchemaReader ¶
type RecordSchemaReader struct {
// contains filtered or unexported fields
}
container reader
func NewRecordSchemaReader ¶
func NewRecordSchemaReader(r io.Reader) (*RecordSchemaReader, error)
func (RecordSchemaReader) Read ¶
func (r RecordSchemaReader) Read() (RecordSchema, error)
type UnionRecordFooRecordBar ¶
type UnionRecordFooRecordBar struct { RecordFoo RecordFoo RecordBar RecordBar UnionType UnionRecordFooRecordBarTypeEnum }
func DeserializeUnionRecordFooRecordBar ¶
func DeserializeUnionRecordFooRecordBar(r io.Reader) (UnionRecordFooRecordBar, error)
func DeserializeUnionRecordFooRecordBarFromSchema ¶
func DeserializeUnionRecordFooRecordBarFromSchema(r io.Reader, schema string) (UnionRecordFooRecordBar, error)
func NewUnionRecordFooRecordBar ¶
func NewUnionRecordFooRecordBar() UnionRecordFooRecordBar
func (UnionRecordFooRecordBar) AppendArray ¶
func (_ UnionRecordFooRecordBar) AppendArray() types.Field
func (UnionRecordFooRecordBar) AppendMap ¶
func (_ UnionRecordFooRecordBar) AppendMap(key string) types.Field
func (UnionRecordFooRecordBar) Finalize ¶
func (_ UnionRecordFooRecordBar) Finalize()
func (UnionRecordFooRecordBar) MarshalJSON ¶
func (r UnionRecordFooRecordBar) MarshalJSON() ([]byte, error)
func (UnionRecordFooRecordBar) NullField ¶
func (_ UnionRecordFooRecordBar) NullField(i int)
func (UnionRecordFooRecordBar) Schema ¶
func (r UnionRecordFooRecordBar) Schema() string
func (UnionRecordFooRecordBar) Serialize ¶
func (r UnionRecordFooRecordBar) Serialize(w io.Writer) error
func (UnionRecordFooRecordBar) SetBoolean ¶
func (_ UnionRecordFooRecordBar) SetBoolean(v bool)
func (UnionRecordFooRecordBar) SetBytes ¶
func (_ UnionRecordFooRecordBar) SetBytes(v []byte)
func (UnionRecordFooRecordBar) SetDefault ¶
func (_ UnionRecordFooRecordBar) SetDefault(i int)
func (UnionRecordFooRecordBar) SetDouble ¶
func (_ UnionRecordFooRecordBar) SetDouble(v float64)
func (UnionRecordFooRecordBar) SetFloat ¶
func (_ UnionRecordFooRecordBar) SetFloat(v float32)
func (UnionRecordFooRecordBar) SetInt ¶
func (_ UnionRecordFooRecordBar) SetInt(v int32)
func (*UnionRecordFooRecordBar) SetLong ¶
func (r *UnionRecordFooRecordBar) SetLong(v int64)
func (UnionRecordFooRecordBar) SetString ¶
func (_ UnionRecordFooRecordBar) SetString(v string)
func (*UnionRecordFooRecordBar) UnmarshalJSON ¶
func (r *UnionRecordFooRecordBar) UnmarshalJSON(data []byte) error
type UnionRecordFooRecordBarTypeEnum ¶
type UnionRecordFooRecordBarTypeEnum int
const ( UnionRecordFooRecordBarTypeEnumRecordFoo UnionRecordFooRecordBarTypeEnum = 0 UnionRecordFooRecordBarTypeEnumRecordBar UnionRecordFooRecordBarTypeEnum = 1 )
Click to show internal directories.
Click to hide internal directories.