Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AckResp ¶
type AckResp struct {
Ack string `json:"ack" msg:"ack"`
}
func (AckResp) MarshalMsg ¶
MarshalMsg implements msgp.Marshaler
type Entry ¶
type Entry struct {
Time int64 `msg:"time"`
Record interface{} `msg:"record"`
}
func (Entry) MarshalMsg ¶
MarshalMsg implements msgp.Marshaler
type EventTime ¶
EventTime is an extension to the serialized time value. It builds in support for sub-second (nanosecond) precision in serialized timestamps.
You can find the full specification for the msgpack message payload here: https://github.com/fluent/fluentd/wiki/Forward-Protocol-Specification-v1.
You can find more information on msgpack extension types here: https://github.com/tinylib/msgp/wiki/Using-Extensions.
func (*EventTime) ExtensionType ¶
func (*EventTime) MarshalBinaryTo ¶
func (*EventTime) UnmarshalBinary ¶
Although decoding messages is not officially supported by this library, UnmarshalBinary is implemented for testing and general completeness.
type Forward ¶
type Forward struct {
Tag string `msg:"tag"`
Entries []Entry `msg:"entries"`
Option map[string]string
}
func (*Forward) MarshalMsg ¶
MarshalMsg implements msgp.Marshaler
type Message ¶
type Message struct {
Tag string `msg:"tag"`
Time int64 `msg:"time"`
Record interface{} `msg:"record"`
Option map[string]string
}
func (*Message) MarshalMsg ¶
MarshalMsg implements msgp.Marshaler
type MessageExt ¶
type MessageExt struct {
Tag string `msg:"tag"`
Time EventTime `msg:"time,extension"`
Record interface{} `msg:"record"`
Option map[string]string
}
func (*MessageExt) DecodeMsg ¶
func (z *MessageExt) DecodeMsg(dc *msgp.Reader) (err error)
DecodeMsg implements msgp.Decodable
func (*MessageExt) EncodeMsg ¶
func (z *MessageExt) EncodeMsg(en *msgp.Writer) (err error)
EncodeMsg implements msgp.Encodable
func (*MessageExt) MarshalMsg ¶
func (z *MessageExt) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*MessageExt) Msgsize ¶
func (z *MessageExt) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*MessageExt) UnmarshalMsg ¶
func (z *MessageExt) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type TestMessage ¶
type TestMessage struct {
Foo string `msg:"foo" json:"foo,omitempty"`
Hoge string `msg:"hoge" json:"hoge,omitempty"`
}
func (*TestMessage) DecodeMsg ¶
func (z *TestMessage) DecodeMsg(dc *msgp.Reader) (err error)
DecodeMsg implements msgp.Decodable
func (TestMessage) EncodeMsg ¶
func (z TestMessage) EncodeMsg(en *msgp.Writer) (err error)
EncodeMsg implements msgp.Encodable
func (TestMessage) MarshalMsg ¶
func (z TestMessage) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (TestMessage) Msgsize ¶
func (z TestMessage) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*TestMessage) UnmarshalMsg ¶
func (z *TestMessage) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
Source Files