avro

package
v1.4.16 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 26, 2023 License: MIT Imports: 7 Imported by: 0

Documentation

Overview

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

  • SOURCE:
  • v1.avsc

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

  • SOURCE:
  • v1.avsc

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

  • SOURCE:
  • v1.avsc

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

  • SOURCE:
  • v1.avsc

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

  • SOURCE:
  • v1.avsc

Index

Constants

View Source 
const AccessLogAvroCRC64Fingerprint = "6/gH\xee\x1e\a\x9e"

Variables

This section is empty.

Functions

func NewAccessLogWriter 

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

Types

type AccessLog 

type AccessLog struct {
	Timestamp *UnionNullLong `json:"timestamp"`

	Id *UnionNullString `json:"id"`

	TraceId *UnionNullString `json:"traceId"`

	Ip *UnionNullString `json:"ip"`

	UserAgent *UnionNullString `json:"userAgent"`

	Method *UnionNullString `json:"method"`

	Path *UnionNullString `json:"path"`

	Query *UnionNullString `json:"query"`

	Status *UnionNullInt `json:"status"`

	Duration *UnionNullInt `json:"duration"`

	RequestSize *UnionNullInt `json:"requestSize"`

	ResponseSize *UnionNullInt `json:"responseSize"`
}

func DeserializeAccessLog 

func DeserializeAccessLog(r io.Reader) (AccessLog, error)

func DeserializeAccessLogFromSchema 

func DeserializeAccessLogFromSchema(r io.Reader, schema string) (AccessLog, error)

func NewAccessLog 

func NewAccessLog() AccessLog

func (AccessLog) AppendArray 

func (_ AccessLog) AppendArray() types.Field

func (AccessLog) AppendMap 

func (_ AccessLog) AppendMap(key string) types.Field

func (AccessLog) AvroCRC64Fingerprint 

func (_ AccessLog) AvroCRC64Fingerprint() []byte

func (AccessLog) Finalize 

func (_ AccessLog) Finalize()

func (*AccessLog) Get 

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

func (AccessLog) HintSize 

func (_ AccessLog) HintSize(int)

func (AccessLog) MarshalJSON 

func (r AccessLog) MarshalJSON() ([]byte, error)

func (*AccessLog) NullField 

func (r *AccessLog) NullField(i int)

func (AccessLog) Schema 

func (r AccessLog) Schema() string

func (AccessLog) SchemaName 

func (r AccessLog) SchemaName() string

func (AccessLog) Serialize 

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

func (AccessLog) SetBoolean 

func (_ AccessLog) SetBoolean(v bool)

func (AccessLog) SetBytes 

func (_ AccessLog) SetBytes(v []byte)

func (*AccessLog) SetDefault 

func (r *AccessLog) SetDefault(i int)

func (AccessLog) SetDouble 

func (_ AccessLog) SetDouble(v float64)

func (AccessLog) SetFloat 

func (_ AccessLog) SetFloat(v float32)

func (AccessLog) SetInt 

func (_ AccessLog) SetInt(v int32)

func (AccessLog) SetLong 

func (_ AccessLog) SetLong(v int64)

func (AccessLog) SetString 

func (_ AccessLog) SetString(v string)

func (AccessLog) SetUnionElem 

func (_ AccessLog) SetUnionElem(v int64)

func (*AccessLog) UnmarshalJSON 

func (r *AccessLog) UnmarshalJSON(data []byte) error

type AccessLogReader 

type AccessLogReader struct {
	// contains filtered or unexported fields
}

container reader

func NewAccessLogReader 

func NewAccessLogReader(r io.Reader) (*AccessLogReader, error)

func (AccessLogReader) Read 

func (r AccessLogReader) Read() (AccessLog, error)

type UnionNullInt 

type UnionNullInt struct {
	Null      *types.NullVal
	Int       int32
	UnionType UnionNullIntTypeEnum
}

func DeserializeUnionNullInt 

func DeserializeUnionNullInt(r io.Reader) (*UnionNullInt, error)

func DeserializeUnionNullIntFromSchema 

func DeserializeUnionNullIntFromSchema(r io.Reader, schema string) (*UnionNullInt, error)

func NewUnionNullInt 

func NewUnionNullInt() *UnionNullInt

func (*UnionNullInt) AppendArray 

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

func (*UnionNullInt) AppendMap 

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

func (*UnionNullInt) Finalize 

func (_ *UnionNullInt) Finalize()

func (*UnionNullInt) Get 

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

func (*UnionNullInt) HintSize 

func (_ *UnionNullInt) HintSize(i int)

func (*UnionNullInt) MarshalJSON 

func (r *UnionNullInt) MarshalJSON() ([]byte, error)

func (*UnionNullInt) NullField 

func (_ *UnionNullInt) NullField(i int)

func (*UnionNullInt) Schema 

func (r *UnionNullInt) Schema() string

func (*UnionNullInt) Serialize 

func (r *UnionNullInt) Serialize(w io.Writer) error

func (*UnionNullInt) SetBoolean 

func (_ *UnionNullInt) SetBoolean(v bool)

func (*UnionNullInt) SetBytes 

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

func (*UnionNullInt) SetDefault 

func (_ *UnionNullInt) SetDefault(i int)

func (*UnionNullInt) SetDouble 

func (_ *UnionNullInt) SetDouble(v float64)

func (*UnionNullInt) SetFloat 

func (_ *UnionNullInt) SetFloat(v float32)

func (*UnionNullInt) SetInt 

func (_ *UnionNullInt) SetInt(v int32)

func (*UnionNullInt) SetLong 

func (r *UnionNullInt) SetLong(v int64)

func (*UnionNullInt) SetString 

func (_ *UnionNullInt) SetString(v string)

func (*UnionNullInt) UnmarshalJSON 

func (r *UnionNullInt) UnmarshalJSON(data []byte) error

type UnionNullIntTypeEnum 

type UnionNullIntTypeEnum int
const (
	UnionNullIntTypeEnumInt UnionNullIntTypeEnum = 1
)

type UnionNullLong 

type UnionNullLong struct {
	Null      *types.NullVal
	Long      int64
	UnionType UnionNullLongTypeEnum
}

func DeserializeUnionNullLong 

func DeserializeUnionNullLong(r io.Reader) (*UnionNullLong, error)

func DeserializeUnionNullLongFromSchema 

func DeserializeUnionNullLongFromSchema(r io.Reader, schema string) (*UnionNullLong, error)

func NewUnionNullLong 

func NewUnionNullLong() *UnionNullLong

func (*UnionNullLong) AppendArray 

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

func (*UnionNullLong) AppendMap 

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

func (*UnionNullLong) Finalize 

func (_ *UnionNullLong) Finalize()

func (*UnionNullLong) Get 

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

func (*UnionNullLong) HintSize 

func (_ *UnionNullLong) HintSize(i int)

func (*UnionNullLong) MarshalJSON 

func (r *UnionNullLong) MarshalJSON() ([]byte, error)

func (*UnionNullLong) NullField 

func (_ *UnionNullLong) NullField(i int)

func (*UnionNullLong) Schema 

func (r *UnionNullLong) Schema() string

func (*UnionNullLong) Serialize 

func (r *UnionNullLong) Serialize(w io.Writer) error

func (*UnionNullLong) SetBoolean 

func (_ *UnionNullLong) SetBoolean(v bool)

func (*UnionNullLong) SetBytes 

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

func (*UnionNullLong) SetDefault 

func (_ *UnionNullLong) SetDefault(i int)

func (*UnionNullLong) SetDouble 

func (_ *UnionNullLong) SetDouble(v float64)

func (*UnionNullLong) SetFloat 

func (_ *UnionNullLong) SetFloat(v float32)

func (*UnionNullLong) SetInt 

func (_ *UnionNullLong) SetInt(v int32)

func (*UnionNullLong) SetLong 

func (r *UnionNullLong) SetLong(v int64)

func (*UnionNullLong) SetString 

func (_ *UnionNullLong) SetString(v string)

func (*UnionNullLong) UnmarshalJSON 

func (r *UnionNullLong) UnmarshalJSON(data []byte) error

type UnionNullLongTypeEnum 

type UnionNullLongTypeEnum int
const (
	UnionNullLongTypeEnumLong UnionNullLongTypeEnum = 1
)

type UnionNullString 

type UnionNullString struct {
	Null      *types.NullVal
	String    string
	UnionType UnionNullStringTypeEnum
}

func DeserializeUnionNullString 

func DeserializeUnionNullString(r io.Reader) (*UnionNullString, error)

func DeserializeUnionNullStringFromSchema 

func DeserializeUnionNullStringFromSchema(r io.Reader, schema string) (*UnionNullString, error)

func NewUnionNullString 

func NewUnionNullString() *UnionNullString

func (*UnionNullString) AppendArray 

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

func (*UnionNullString) AppendMap 

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

func (*UnionNullString) Finalize 

func (_ *UnionNullString) Finalize()

func (*UnionNullString) Get 

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

func (*UnionNullString) HintSize 

func (_ *UnionNullString) HintSize(i int)

func (*UnionNullString) MarshalJSON 

func (r *UnionNullString) MarshalJSON() ([]byte, error)

func (*UnionNullString) NullField 

func (_ *UnionNullString) NullField(i int)

func (*UnionNullString) Schema 

func (r *UnionNullString) Schema() string

func (*UnionNullString) Serialize 

func (r *UnionNullString) Serialize(w io.Writer) error

func (*UnionNullString) SetBoolean 

func (_ *UnionNullString) SetBoolean(v bool)

func (*UnionNullString) SetBytes 

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

func (*UnionNullString) SetDefault 

func (_ *UnionNullString) SetDefault(i int)

func (*UnionNullString) SetDouble 

func (_ *UnionNullString) SetDouble(v float64)

func (*UnionNullString) SetFloat 

func (_ *UnionNullString) SetFloat(v float32)

func (*UnionNullString) SetInt 

func (_ *UnionNullString) SetInt(v int32)

func (*UnionNullString) SetLong 

func (r *UnionNullString) SetLong(v int64)

func (*UnionNullString) SetString 

func (_ *UnionNullString) SetString(v string)

func (*UnionNullString) UnmarshalJSON 

func (r *UnionNullString) UnmarshalJSON(data []byte) error

type UnionNullStringTypeEnum 

type UnionNullStringTypeEnum int
const (
	UnionNullStringTypeEnumString UnionNullStringTypeEnum = 1
)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.