avro

package

v6.3.1-wip-refactoring Latest Latest Go to latest Published: Mar 3, 2020 License: MIT Imports: 6 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/actgardner/gogen-avro

Documentation ¶

Overview ¶

Code generated by github.com/actgardner/gogen-avro. DO NOT EDIT.

SOURCE:
union.avsc

Code generated by github.com/actgardner/gogen-avro. DO NOT EDIT.

SOURCE:
union.avsc

Code generated by github.com/actgardner/gogen-avro. DO NOT EDIT.

SOURCE:
union.avsc

Code generated by github.com/actgardner/gogen-avro. DO NOT EDIT.

SOURCE:
union.avsc

Index ¶

func NewEventWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
type Event
- func DeserializeEvent(r io.Reader) (t Event, err error)
- func DeserializeEventFromSchema(r io.Reader, schema string) (t Event, err error)
type EventReader
- func NewEventReader(r io.Reader) (*EventReader, error)
- func (r EventReader) Read() (t Event, err error)
type Ip_address
type UnionIp_addressEvent
type UnionIp_addressEventTypeEnum

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewEventWriter ¶

func NewEventWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)

Types ¶

type Event ¶

type Event struct {
	Id string

	Start_ip Ip_address

	End_ip Ip_address
}

The test record

func DeserializeEvent ¶

func DeserializeEvent(r io.Reader) (t Event, err error)

func DeserializeEventFromSchema ¶

func DeserializeEventFromSchema(r io.Reader, schema string) (t Event, err error)

func (*Event) AppendArray ¶

func (_ *Event) AppendArray() types.Field

func (*Event) AppendMap ¶

func (_ *Event) AppendMap(key string) types.Field

func (*Event) Clear ¶

func (r *Event) Clear(i int)

func (*Event) Finalize ¶

func (_ *Event) Finalize()

func (*Event) Get ¶

func (r *Event) Get(i int) types.Field

func (Event) Schema ¶

func (r Event) Schema() string

func (Event) SchemaName ¶

func (r Event) SchemaName() string

func (Event) Serialize ¶

func (r Event) Serialize(w io.Writer) error

func (*Event) SetBoolean ¶

func (_ *Event) SetBoolean(v bool)

func (*Event) SetBytes ¶

func (_ *Event) SetBytes(v []byte)

func (*Event) SetDefault ¶

func (r *Event) SetDefault(i int)

func (*Event) SetDouble ¶

func (_ *Event) SetDouble(v float64)

func (*Event) SetFloat ¶

func (_ *Event) SetFloat(v float32)

func (*Event) SetInt ¶

func (_ *Event) SetInt(v int32)

func (*Event) SetLong ¶

func (_ *Event) SetLong(v int64)

func (*Event) SetString ¶

func (_ *Event) SetString(v string)

func (*Event) SetUnionElem ¶

func (_ *Event) SetUnionElem(v int64)

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() (t Event, err error)

type Ip_address ¶

type Ip_address [16]byte

func (*Ip_address) AppendArray ¶

func (_ *Ip_address) AppendArray() types.Field

func (*Ip_address) AppendMap ¶

func (_ *Ip_address) AppendMap(key string) types.Field

func (*Ip_address) Clear ¶

func (_ *Ip_address) Clear(i int)

func (*Ip_address) Finalize ¶

func (_ *Ip_address) Finalize()

func (*Ip_address) Get ¶

func (_ *Ip_address) Get(i int) types.Field

func (*Ip_address) SetBoolean ¶

func (_ *Ip_address) SetBoolean(v bool)

func (*Ip_address) SetBytes ¶

func (r *Ip_address) SetBytes(v []byte)

func (*Ip_address) SetDefault ¶

func (_ *Ip_address) SetDefault(i int)

func (*Ip_address) SetDouble ¶

func (_ *Ip_address) SetDouble(v float64)

func (*Ip_address) SetFloat ¶

func (_ *Ip_address) SetFloat(v float32)

func (*Ip_address) SetInt ¶

func (_ *Ip_address) SetInt(v int32)

func (*Ip_address) SetLong ¶

func (_ *Ip_address) SetLong(v int64)

func (*Ip_address) SetString ¶

func (_ *Ip_address) SetString(v string)

func (*Ip_address) SetUnionElem ¶

func (_ *Ip_address) SetUnionElem(v int64)

type UnionIp_addressEvent ¶

type UnionIp_addressEvent struct {
	Ip_address Ip_address

	Event Event

	UnionType UnionIp_addressEventTypeEnum
}

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) Clear ¶

func (r *UnionIp_addressEvent) Clear(i int)

func (*UnionIp_addressEvent) Finalize ¶

func (_ *UnionIp_addressEvent) Finalize()

func (*UnionIp_addressEvent) Get ¶

func (r *UnionIp_addressEvent) Get(i int) types.Field

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)

type UnionIp_addressEventTypeEnum ¶

type UnionIp_addressEventTypeEnum int

const (
	UnionIp_addressEventTypeEnumIp_address UnionIp_addressEventTypeEnum = 0

	UnionIp_addressEventTypeEnumEvent UnionIp_addressEventTypeEnum = 1
)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL