Documentation ¶
Index ¶
- func NewEventMsgWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
- type ByteWriter
- type 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
- type StringWriter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ByteWriter ¶
type EventMsg ¶
func NewEventMsg ¶
func NewEventMsg() *EventMsg
func (*EventMsg) AppendArray ¶
func (*EventMsg) SchemaName ¶
func (*EventMsg) SetBoolean ¶
func (*EventMsg) SetDefault ¶
func (*EventMsg) SetUnionElem ¶
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 ¶
Click to show internal directories.
Click to hide internal directories.