PhEventMsg

Documentation

Index

• func NewEventMsgWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
• type ByteWriter
• type EventMsg
  • func DeserializeEventMsg(r io.Reader) (*EventMsg, error)
  • func DeserializeEventMsgFromSchema(r io.Reader, schema string) (*EventMsg, error)
  • func NewEventMsg() *EventMsg
  • func (_ *EventMsg) AppendArray() types.Field
  • func (_ *EventMsg) AppendMap(key string) types.Field
  • func (_ *EventMsg) Finalize()
  • func (r *EventMsg) Get(i int) types.Field
  • func (r *EventMsg) Schema() string
  • func (r *EventMsg) SchemaName() string
  • func (r *EventMsg) Serialize(w io.Writer) error
  • func (_ *EventMsg) SetBoolean(v bool)
  • func (_ *EventMsg) SetBytes(v []byte)
  • func (r *EventMsg) SetDefault(i int)
  • func (_ *EventMsg) SetDouble(v float64)
  • func (_ *EventMsg) SetFloat(v float32)
  • func (_ *EventMsg) SetInt(v int32)
  • func (_ *EventMsg) SetLong(v int64)
  • func (_ *EventMsg) SetString(v string)
  • func (_ *EventMsg) SetUnionElem(v int64)
• type EventMsgReader
  • func NewEventMsgReader(r io.Reader) (*EventMsgReader, error)
  • func (r *EventMsgReader) Read() (*EventMsg, error)
• type StringWriter

Functions

func NewEventMsgWriter

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

Types

type ByteWriter

type ByteWriter interface {
	Grow(int)
	WriteByte(byte) error
}

type EventMsg

type EventMsg struct {
	JobId   string
	TraceId string
	Type    string
	Data    string
}

func DeserializeEventMsg

func DeserializeEventMsg(r io.Reader) (*EventMsg, error)

func DeserializeEventMsgFromSchema

func DeserializeEventMsgFromSchema(r io.Reader, schema string) (*EventMsg, error)

func NewEventMsg

func NewEventMsg() *EventMsg

func (*EventMsg) AppendArray

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

func (*EventMsg) AppendMap

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

func (*EventMsg) Finalize

func (_ *EventMsg) Finalize()

func (*EventMsg) Get

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

func (*EventMsg) Schema

func (r *EventMsg) Schema() string

func (*EventMsg) SchemaName

func (r *EventMsg) SchemaName() string

func (*EventMsg) Serialize

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

func (*EventMsg) SetBoolean

func (_ *EventMsg) SetBoolean(v bool)

func (*EventMsg) SetBytes

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

func (*EventMsg) SetDefault

func (r *EventMsg) SetDefault(i int)

func (*EventMsg) SetDouble

func (_ *EventMsg) SetDouble(v float64)

func (*EventMsg) SetFloat

func (_ *EventMsg) SetFloat(v float32)

func (*EventMsg) SetInt

func (_ *EventMsg) SetInt(v int32)

func (*EventMsg) SetLong

func (_ *EventMsg) SetLong(v int64)

func (*EventMsg) SetString

func (_ *EventMsg) SetString(v string)

func (*EventMsg) SetUnionElem

func (_ *EventMsg) SetUnionElem(v int64)

type EventMsgReader

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

func NewEventMsgReader

func NewEventMsgReader(r io.Reader) (*EventMsgReader, error)

func (*EventMsgReader) Read

func (r *EventMsgReader) Read() (*EventMsg, error)

type StringWriter

type StringWriter interface {
	WriteString(string) (int, error)
}