Documentation ¶
Overview ¶
Code generated by Skaidus. DO NOT EDIT.
- SOURCE:
- schema.avsc
Code generated by Skaidus. DO NOT EDIT.
- SOURCE:
- schema.avsc
Code generated by Skaidus. DO NOT EDIT.
- SOURCE:
- schema.avsc
Code generated by Skaidus. DO NOT EDIT.
- SOURCE:
- schema.avsc
Code generated by Skaidus. DO NOT EDIT.
- SOURCE:
- schema.avsc
Code generated by Skaidus. DO NOT EDIT.
- SOURCE:
- schema.avsc
Code generated by Skaidus. DO NOT EDIT.
- SOURCE:
- schema.avsc
Code generated by Skaidus. DO NOT EDIT.
- SOURCE:
- schema.avsc
Index ¶
- Constants
- func NewPrimitiveUnionTestRecordWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
- func NewRecord1Writer(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
- func NewRecord2Writer(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
- type Bytes
- type BytesWrapper
- func (b BytesWrapper) AppendArray() types.Field
- func (b BytesWrapper) AppendMap(key string) types.Field
- func (b BytesWrapper) Finalize()
- func (b BytesWrapper) Get(i int) types.Field
- func (b BytesWrapper) HintSize(int)
- func (b BytesWrapper) NullField(int)
- func (b BytesWrapper) SetBoolean(v bool)
- func (b BytesWrapper) SetBytes(v []byte)
- func (b BytesWrapper) SetDefault(i int)
- func (b BytesWrapper) SetDouble(v float64)
- func (b BytesWrapper) SetFloat(v float32)
- func (b BytesWrapper) SetInt(v int32)
- func (b BytesWrapper) SetLong(v int64)
- func (b BytesWrapper) SetString(v string)
- func (b BytesWrapper) SetUnionElem(v int64)
- type PrimitiveUnionTestRecord
- func (_ PrimitiveUnionTestRecord) AppendArray() types.Field
- func (_ PrimitiveUnionTestRecord) AppendMap(key string) types.Field
- func (_ PrimitiveUnionTestRecord) AvroCRC64Fingerprint() []byte
- func (_ PrimitiveUnionTestRecord) Finalize()
- func (r *PrimitiveUnionTestRecord) Get(i int) types.Field
- func (_ PrimitiveUnionTestRecord) HintSize(int)
- func (r PrimitiveUnionTestRecord) MarshalJSON() ([]byte, error)
- func (r *PrimitiveUnionTestRecord) NullField(i int)
- func (r PrimitiveUnionTestRecord) Schema() string
- func (r PrimitiveUnionTestRecord) SchemaName() string
- func (r PrimitiveUnionTestRecord) Serialize(w io.Writer) error
- func (_ PrimitiveUnionTestRecord) SetBoolean(v bool)
- func (_ PrimitiveUnionTestRecord) SetBytes(v []byte)
- func (r *PrimitiveUnionTestRecord) SetDefault(i int)
- func (_ PrimitiveUnionTestRecord) SetDouble(v float64)
- func (_ PrimitiveUnionTestRecord) SetFloat(v float32)
- func (_ PrimitiveUnionTestRecord) SetInt(v int32)
- func (_ PrimitiveUnionTestRecord) SetLong(v int64)
- func (_ PrimitiveUnionTestRecord) SetString(v string)
- func (_ PrimitiveUnionTestRecord) SetUnionElem(v int64)
- func (r *PrimitiveUnionTestRecord) UnmarshalJSON(data []byte) error
- type PrimitiveUnionTestRecordReader
- type Record1
- func (_ Record1) AppendArray() types.Field
- func (_ Record1) AppendMap(key string) types.Field
- func (_ Record1) AvroCRC64Fingerprint() []byte
- func (_ Record1) Finalize()
- func (r *Record1) Get(i int) types.Field
- func (_ Record1) HintSize(int)
- func (r Record1) MarshalJSON() ([]byte, error)
- func (r *Record1) NullField(i int)
- func (r Record1) Schema() string
- func (r Record1) SchemaName() string
- func (r Record1) Serialize(w io.Writer) error
- func (_ Record1) SetBoolean(v bool)
- func (_ Record1) SetBytes(v []byte)
- func (r *Record1) SetDefault(i int)
- func (_ Record1) SetDouble(v float64)
- func (_ Record1) SetFloat(v float32)
- func (_ Record1) SetInt(v int32)
- func (_ Record1) SetLong(v int64)
- func (_ Record1) SetString(v string)
- func (_ Record1) SetUnionElem(v int64)
- func (r *Record1) UnmarshalJSON(data []byte) error
- type Record1Reader
- type Record2
- func (_ Record2) AppendArray() types.Field
- func (_ Record2) AppendMap(key string) types.Field
- func (_ Record2) AvroCRC64Fingerprint() []byte
- func (_ Record2) Finalize()
- func (r *Record2) Get(i int) types.Field
- func (_ Record2) HintSize(int)
- func (r Record2) MarshalJSON() ([]byte, error)
- func (r *Record2) NullField(i int)
- func (r Record2) Schema() string
- func (r Record2) SchemaName() string
- func (r Record2) Serialize(w io.Writer) error
- func (_ Record2) SetBoolean(v bool)
- func (_ Record2) SetBytes(v []byte)
- func (r *Record2) SetDefault(i int)
- func (_ Record2) SetDouble(v float64)
- func (_ Record2) SetFloat(v float32)
- func (_ Record2) SetInt(v int32)
- func (_ Record2) SetLong(v int64)
- func (_ Record2) SetString(v string)
- func (_ Record2) SetUnionElem(v int64)
- func (r *Record2) UnmarshalJSON(data []byte) error
- type Record2Reader
- type UnionBytesStringRecord1Record2
- func (_ UnionBytesStringRecord1Record2) AppendArray() types.Field
- func (_ UnionBytesStringRecord1Record2) AppendMap(key string) types.Field
- func (_ UnionBytesStringRecord1Record2) Finalize()
- func (r *UnionBytesStringRecord1Record2) Get(i int) types.Field
- func (_ UnionBytesStringRecord1Record2) HintSize(i int)
- func (r UnionBytesStringRecord1Record2) MarshalJSON() ([]byte, error)
- func (_ UnionBytesStringRecord1Record2) NullField(i int)
- func (r UnionBytesStringRecord1Record2) Schema() string
- func (r UnionBytesStringRecord1Record2) Serialize(w io.Writer) error
- func (_ UnionBytesStringRecord1Record2) SetBoolean(v bool)
- func (_ UnionBytesStringRecord1Record2) SetBytes(v []byte)
- func (_ UnionBytesStringRecord1Record2) SetDefault(i int)
- func (_ UnionBytesStringRecord1Record2) SetDouble(v float64)
- func (_ UnionBytesStringRecord1Record2) SetFloat(v float32)
- func (_ UnionBytesStringRecord1Record2) SetInt(v int32)
- func (r *UnionBytesStringRecord1Record2) SetLong(v int64)
- func (_ UnionBytesStringRecord1Record2) SetString(v string)
- func (r *UnionBytesStringRecord1Record2) UnmarshalJSON(data []byte) error
- type UnionBytesStringRecord1Record2TypeEnum
Constants ¶
View Source
const PrimitiveUnionTestRecordAvroCRC64Fingerprint = "N\xf1pp\x85\x9d\xed="
View Source
const Record1AvroCRC64Fingerprint = "5\x1f\v\x05O7Z\x02"
View Source
const Record2AvroCRC64Fingerprint = "S\n_\xab\xc7-\xf9\x9c"
Variables ¶
This section is empty.
Functions ¶
func NewRecord1Writer ¶
Types ¶
type BytesWrapper ¶
type BytesWrapper struct {
Target *Bytes
}
func (BytesWrapper) AppendArray ¶
func (b BytesWrapper) AppendArray() types.Field
func (BytesWrapper) Finalize ¶
func (b BytesWrapper) Finalize()
func (BytesWrapper) HintSize ¶
func (b BytesWrapper) HintSize(int)
func (BytesWrapper) NullField ¶
func (b BytesWrapper) NullField(int)
func (BytesWrapper) SetBoolean ¶
func (b BytesWrapper) SetBoolean(v bool)
func (BytesWrapper) SetBytes ¶
func (b BytesWrapper) SetBytes(v []byte)
func (BytesWrapper) SetDefault ¶
func (b BytesWrapper) SetDefault(i int)
func (BytesWrapper) SetDouble ¶
func (b BytesWrapper) SetDouble(v float64)
func (BytesWrapper) SetFloat ¶
func (b BytesWrapper) SetFloat(v float32)
func (BytesWrapper) SetInt ¶
func (b BytesWrapper) SetInt(v int32)
func (BytesWrapper) SetLong ¶
func (b BytesWrapper) SetLong(v int64)
func (BytesWrapper) SetString ¶
func (b BytesWrapper) SetString(v string)
func (BytesWrapper) SetUnionElem ¶
func (b BytesWrapper) SetUnionElem(v int64)
type PrimitiveUnionTestRecord ¶
type PrimitiveUnionTestRecord struct {
UnionField UnionBytesStringRecord1Record2 `json:"UnionField"`
}
func DeserializePrimitiveUnionTestRecord ¶
func DeserializePrimitiveUnionTestRecord(r io.Reader) (PrimitiveUnionTestRecord, error)
func DeserializePrimitiveUnionTestRecordFromSchema ¶
func DeserializePrimitiveUnionTestRecordFromSchema(r io.Reader, schema string) (PrimitiveUnionTestRecord, error)
func NewPrimitiveUnionTestRecord ¶
func NewPrimitiveUnionTestRecord() PrimitiveUnionTestRecord
func (PrimitiveUnionTestRecord) AppendArray ¶
func (_ PrimitiveUnionTestRecord) AppendArray() types.Field
func (PrimitiveUnionTestRecord) AppendMap ¶
func (_ PrimitiveUnionTestRecord) AppendMap(key string) types.Field
func (PrimitiveUnionTestRecord) AvroCRC64Fingerprint ¶
func (_ PrimitiveUnionTestRecord) AvroCRC64Fingerprint() []byte
func (PrimitiveUnionTestRecord) Finalize ¶
func (_ PrimitiveUnionTestRecord) Finalize()
func (PrimitiveUnionTestRecord) HintSize ¶
func (_ PrimitiveUnionTestRecord) HintSize(int)
func (PrimitiveUnionTestRecord) MarshalJSON ¶
func (r PrimitiveUnionTestRecord) MarshalJSON() ([]byte, error)
func (*PrimitiveUnionTestRecord) NullField ¶
func (r *PrimitiveUnionTestRecord) NullField(i int)
func (PrimitiveUnionTestRecord) Schema ¶
func (r PrimitiveUnionTestRecord) Schema() string
func (PrimitiveUnionTestRecord) SchemaName ¶
func (r PrimitiveUnionTestRecord) SchemaName() string
func (PrimitiveUnionTestRecord) Serialize ¶
func (r PrimitiveUnionTestRecord) Serialize(w io.Writer) error
func (PrimitiveUnionTestRecord) SetBoolean ¶
func (_ PrimitiveUnionTestRecord) SetBoolean(v bool)
func (PrimitiveUnionTestRecord) SetBytes ¶
func (_ PrimitiveUnionTestRecord) SetBytes(v []byte)
func (*PrimitiveUnionTestRecord) SetDefault ¶
func (r *PrimitiveUnionTestRecord) SetDefault(i int)
func (PrimitiveUnionTestRecord) SetDouble ¶
func (_ PrimitiveUnionTestRecord) SetDouble(v float64)
func (PrimitiveUnionTestRecord) SetFloat ¶
func (_ PrimitiveUnionTestRecord) SetFloat(v float32)
func (PrimitiveUnionTestRecord) SetInt ¶
func (_ PrimitiveUnionTestRecord) SetInt(v int32)
func (PrimitiveUnionTestRecord) SetLong ¶
func (_ PrimitiveUnionTestRecord) SetLong(v int64)
func (PrimitiveUnionTestRecord) SetString ¶
func (_ PrimitiveUnionTestRecord) SetString(v string)
func (PrimitiveUnionTestRecord) SetUnionElem ¶
func (_ PrimitiveUnionTestRecord) SetUnionElem(v int64)
func (*PrimitiveUnionTestRecord) UnmarshalJSON ¶
func (r *PrimitiveUnionTestRecord) UnmarshalJSON(data []byte) error
type PrimitiveUnionTestRecordReader ¶
type PrimitiveUnionTestRecordReader struct {
// contains filtered or unexported fields
}
container reader
func NewPrimitiveUnionTestRecordReader ¶
func NewPrimitiveUnionTestRecordReader(r io.Reader) (*PrimitiveUnionTestRecordReader, error)
func (PrimitiveUnionTestRecordReader) Read ¶
func (r PrimitiveUnionTestRecordReader) Read() (PrimitiveUnionTestRecord, error)
type Record1 ¶
type Record1 struct {
Intfield int32 `json:"intfield"`
}
func NewRecord1 ¶
func NewRecord1() Record1
func (Record1) AppendArray ¶
func (Record1) AvroCRC64Fingerprint ¶
func (Record1) MarshalJSON ¶
func (Record1) SchemaName ¶
func (Record1) SetBoolean ¶
func (*Record1) SetDefault ¶
func (Record1) SetUnionElem ¶
func (*Record1) UnmarshalJSON ¶
type Record1Reader ¶
type Record1Reader struct {
// contains filtered or unexported fields
}
container reader
func NewRecord1Reader ¶
func NewRecord1Reader(r io.Reader) (*Record1Reader, error)
func (Record1Reader) Read ¶
func (r Record1Reader) Read() (Record1, error)
type Record2 ¶
type Record2 struct {
Intfield int32 `json:"intfield"`
}
func NewRecord2 ¶
func NewRecord2() Record2
func (Record2) AppendArray ¶
func (Record2) AvroCRC64Fingerprint ¶
func (Record2) MarshalJSON ¶
func (Record2) SchemaName ¶
func (Record2) SetBoolean ¶
func (*Record2) SetDefault ¶
func (Record2) SetUnionElem ¶
func (*Record2) UnmarshalJSON ¶
type Record2Reader ¶
type Record2Reader struct {
// contains filtered or unexported fields
}
container reader
func NewRecord2Reader ¶
func NewRecord2Reader(r io.Reader) (*Record2Reader, error)
func (Record2Reader) Read ¶
func (r Record2Reader) Read() (Record2, error)
type UnionBytesStringRecord1Record2 ¶
type UnionBytesStringRecord1Record2 struct { Bytes Bytes String string Record1 Record1 Record2 Record2 UnionType UnionBytesStringRecord1Record2TypeEnum }
func DeserializeUnionBytesStringRecord1Record2 ¶
func DeserializeUnionBytesStringRecord1Record2(r io.Reader) (UnionBytesStringRecord1Record2, error)
func DeserializeUnionBytesStringRecord1Record2FromSchema ¶
func DeserializeUnionBytesStringRecord1Record2FromSchema(r io.Reader, schema string) (UnionBytesStringRecord1Record2, error)
func NewUnionBytesStringRecord1Record2 ¶
func NewUnionBytesStringRecord1Record2() UnionBytesStringRecord1Record2
func (UnionBytesStringRecord1Record2) AppendArray ¶
func (_ UnionBytesStringRecord1Record2) AppendArray() types.Field
func (UnionBytesStringRecord1Record2) AppendMap ¶
func (_ UnionBytesStringRecord1Record2) AppendMap(key string) types.Field
func (UnionBytesStringRecord1Record2) Finalize ¶
func (_ UnionBytesStringRecord1Record2) Finalize()
func (*UnionBytesStringRecord1Record2) Get ¶
func (r *UnionBytesStringRecord1Record2) Get(i int) types.Field
func (UnionBytesStringRecord1Record2) HintSize ¶
func (_ UnionBytesStringRecord1Record2) HintSize(i int)
func (UnionBytesStringRecord1Record2) MarshalJSON ¶
func (r UnionBytesStringRecord1Record2) MarshalJSON() ([]byte, error)
func (UnionBytesStringRecord1Record2) NullField ¶
func (_ UnionBytesStringRecord1Record2) NullField(i int)
func (UnionBytesStringRecord1Record2) Schema ¶
func (r UnionBytesStringRecord1Record2) Schema() string
func (UnionBytesStringRecord1Record2) Serialize ¶
func (r UnionBytesStringRecord1Record2) Serialize(w io.Writer) error
func (UnionBytesStringRecord1Record2) SetBoolean ¶
func (_ UnionBytesStringRecord1Record2) SetBoolean(v bool)
func (UnionBytesStringRecord1Record2) SetBytes ¶
func (_ UnionBytesStringRecord1Record2) SetBytes(v []byte)
func (UnionBytesStringRecord1Record2) SetDefault ¶
func (_ UnionBytesStringRecord1Record2) SetDefault(i int)
func (UnionBytesStringRecord1Record2) SetDouble ¶
func (_ UnionBytesStringRecord1Record2) SetDouble(v float64)
func (UnionBytesStringRecord1Record2) SetFloat ¶
func (_ UnionBytesStringRecord1Record2) SetFloat(v float32)
func (UnionBytesStringRecord1Record2) SetInt ¶
func (_ UnionBytesStringRecord1Record2) SetInt(v int32)
func (*UnionBytesStringRecord1Record2) SetLong ¶
func (r *UnionBytesStringRecord1Record2) SetLong(v int64)
func (UnionBytesStringRecord1Record2) SetString ¶
func (_ UnionBytesStringRecord1Record2) SetString(v string)
func (*UnionBytesStringRecord1Record2) UnmarshalJSON ¶
func (r *UnionBytesStringRecord1Record2) UnmarshalJSON(data []byte) error
type UnionBytesStringRecord1Record2TypeEnum ¶
type UnionBytesStringRecord1Record2TypeEnum int
const ( UnionBytesStringRecord1Record2TypeEnumBytes UnionBytesStringRecord1Record2TypeEnum = 0 UnionBytesStringRecord1Record2TypeEnumString UnionBytesStringRecord1Record2TypeEnum = 1 UnionBytesStringRecord1Record2TypeEnumRecord1 UnionBytesStringRecord1Record2TypeEnum = 2 UnionBytesStringRecord1Record2TypeEnumRecord2 UnionBytesStringRecord1Record2TypeEnum = 3 )
Click to show internal directories.
Click to hide internal directories.