Documentation ¶
Overview ¶
Code generated by github.com/actgardner/gogen-avro/v7. DO NOT EDIT.
- SOURCE:
- union.avsc
Code generated by github.com/actgardner/gogen-avro/v7. DO NOT EDIT.
- SOURCE:
- union.avsc
Code generated by github.com/actgardner/gogen-avro/v7. DO NOT EDIT.
- SOURCE:
- union.avsc
Code generated by github.com/actgardner/gogen-avro/v7. DO NOT EDIT.
- SOURCE:
- union.avsc
Index ¶
- Constants
- func NewEventWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
- type Event
- func (_ *Event) AppendArray() types.Field
- func (_ *Event) AppendMap(key string) types.Field
- func (_ *Event) AvroCRC64Fingerprint() []byte
- func (_ *Event) Finalize()
- func (r *Event) Get(i int) types.Field
- func (r *Event) NullField(i int)
- func (r *Event) Schema() string
- func (r *Event) SchemaName() string
- func (r *Event) Serialize(w io.Writer) error
- func (_ *Event) SetBoolean(v bool)
- func (_ *Event) SetBytes(v []byte)
- func (r *Event) SetDefault(i int)
- func (_ *Event) SetDouble(v float64)
- func (_ *Event) SetFloat(v float32)
- func (_ *Event) SetInt(v int32)
- func (_ *Event) SetLong(v int64)
- func (_ *Event) SetString(v string)
- func (_ *Event) SetUnionElem(v int64)
- type EventReader
- type Ip_address
- type Ip_addressWrapper
- func (_ *Ip_addressWrapper) AppendArray() types.Field
- func (_ *Ip_addressWrapper) AppendMap(key string) types.Field
- func (_ *Ip_addressWrapper) Finalize()
- func (_ *Ip_addressWrapper) Get(i int) types.Field
- func (_ *Ip_addressWrapper) NullField(int)
- func (_ *Ip_addressWrapper) SetBoolean(v bool)
- func (r *Ip_addressWrapper) SetBytes(v []byte)
- func (_ *Ip_addressWrapper) SetDefault(i int)
- func (_ *Ip_addressWrapper) SetDouble(v float64)
- func (_ *Ip_addressWrapper) SetFloat(v float32)
- func (_ *Ip_addressWrapper) SetInt(v int32)
- func (_ *Ip_addressWrapper) SetLong(v int64)
- func (_ *Ip_addressWrapper) SetString(v string)
- func (_ *Ip_addressWrapper) SetUnionElem(v int64)
- type UnionIp_addressEvent
- func (_ *UnionIp_addressEvent) AppendArray() types.Field
- func (_ *UnionIp_addressEvent) AppendMap(key string) types.Field
- func (_ *UnionIp_addressEvent) Finalize()
- func (r *UnionIp_addressEvent) Get(i int) types.Field
- func (r *UnionIp_addressEvent) MarshalJSON() ([]byte, error)
- func (_ *UnionIp_addressEvent) NullField(i int)
- func (_ *UnionIp_addressEvent) SetBoolean(v bool)
- func (_ *UnionIp_addressEvent) SetBytes(v []byte)
- func (_ *UnionIp_addressEvent) SetDefault(i int)
- func (_ *UnionIp_addressEvent) SetDouble(v float64)
- func (_ *UnionIp_addressEvent) SetFloat(v float32)
- func (_ *UnionIp_addressEvent) SetInt(v int32)
- func (r *UnionIp_addressEvent) SetLong(v int64)
- func (_ *UnionIp_addressEvent) SetString(v string)
- func (r *UnionIp_addressEvent) UnmarshalJSON(data []byte) error
- type UnionIp_addressEventTypeEnum
Constants ¶
View Source
const EventAvroCRC64Fingerprint = "\xebZ\xc0m\xf9OV\x97"
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Event ¶
type Event struct { // Unique ID for this event. Id string `json:"id"` // Start IP of this observation's IP range. Start_ip Ip_address `json:"start_ip"` // End IP of this observation's IP range. End_ip Ip_address `json:"end_ip"` }
func (*Event) AppendArray ¶
func (*Event) AvroCRC64Fingerprint ¶
func (*Event) SchemaName ¶
func (*Event) SetBoolean ¶
func (*Event) SetDefault ¶
func (*Event) SetUnionElem ¶
type EventReader ¶
type EventReader struct {
// contains filtered or unexported fields
}
container reader
func NewEventReader ¶
func NewEventReader(r io.Reader) (*EventReader, error)
func (EventReader) Read ¶
func (r EventReader) Read() (*Event, error)
type Ip_address ¶
type Ip_address [16]byte
type Ip_addressWrapper ¶
type Ip_addressWrapper struct {
Target *Ip_address
}
func (*Ip_addressWrapper) AppendArray ¶
func (_ *Ip_addressWrapper) AppendArray() types.Field
func (*Ip_addressWrapper) Finalize ¶
func (_ *Ip_addressWrapper) Finalize()
func (*Ip_addressWrapper) NullField ¶
func (_ *Ip_addressWrapper) NullField(int)
func (*Ip_addressWrapper) SetBoolean ¶
func (_ *Ip_addressWrapper) SetBoolean(v bool)
func (*Ip_addressWrapper) SetBytes ¶
func (r *Ip_addressWrapper) SetBytes(v []byte)
func (*Ip_addressWrapper) SetDefault ¶
func (_ *Ip_addressWrapper) SetDefault(i int)
func (*Ip_addressWrapper) SetDouble ¶
func (_ *Ip_addressWrapper) SetDouble(v float64)
func (*Ip_addressWrapper) SetFloat ¶
func (_ *Ip_addressWrapper) SetFloat(v float32)
func (*Ip_addressWrapper) SetInt ¶
func (_ *Ip_addressWrapper) SetInt(v int32)
func (*Ip_addressWrapper) SetLong ¶
func (_ *Ip_addressWrapper) SetLong(v int64)
func (*Ip_addressWrapper) SetString ¶
func (_ *Ip_addressWrapper) SetString(v string)
func (*Ip_addressWrapper) SetUnionElem ¶
func (_ *Ip_addressWrapper) SetUnionElem(v int64)
type UnionIp_addressEvent ¶
type UnionIp_addressEvent struct { Ip_address Ip_address Event *Event UnionType UnionIp_addressEventTypeEnum }
func NewUnionIp_addressEvent ¶
func NewUnionIp_addressEvent() *UnionIp_addressEvent
func (*UnionIp_addressEvent) AppendArray ¶
func (_ *UnionIp_addressEvent) AppendArray() types.Field
func (*UnionIp_addressEvent) AppendMap ¶
func (_ *UnionIp_addressEvent) AppendMap(key string) types.Field
func (*UnionIp_addressEvent) Finalize ¶
func (_ *UnionIp_addressEvent) Finalize()
func (*UnionIp_addressEvent) MarshalJSON ¶
func (r *UnionIp_addressEvent) MarshalJSON() ([]byte, error)
func (*UnionIp_addressEvent) NullField ¶
func (_ *UnionIp_addressEvent) NullField(i int)
func (*UnionIp_addressEvent) SetBoolean ¶
func (_ *UnionIp_addressEvent) SetBoolean(v bool)
func (*UnionIp_addressEvent) SetBytes ¶
func (_ *UnionIp_addressEvent) SetBytes(v []byte)
func (*UnionIp_addressEvent) SetDefault ¶
func (_ *UnionIp_addressEvent) SetDefault(i int)
func (*UnionIp_addressEvent) SetDouble ¶
func (_ *UnionIp_addressEvent) SetDouble(v float64)
func (*UnionIp_addressEvent) SetFloat ¶
func (_ *UnionIp_addressEvent) SetFloat(v float32)
func (*UnionIp_addressEvent) SetInt ¶
func (_ *UnionIp_addressEvent) SetInt(v int32)
func (*UnionIp_addressEvent) SetLong ¶
func (r *UnionIp_addressEvent) SetLong(v int64)
func (*UnionIp_addressEvent) SetString ¶
func (_ *UnionIp_addressEvent) SetString(v string)
func (*UnionIp_addressEvent) UnmarshalJSON ¶
func (r *UnionIp_addressEvent) UnmarshalJSON(data []byte) error
type UnionIp_addressEventTypeEnum ¶
type UnionIp_addressEventTypeEnum int
const ( UnionIp_addressEventTypeEnumIp_address UnionIp_addressEventTypeEnum = 0 UnionIp_addressEventTypeEnumEvent UnionIp_addressEventTypeEnum = 1 )
Click to show internal directories.
Click to hide internal directories.