Documentation
¶
Index ¶
- Constants
- type Config
- type Entry
- type EventTime
- type Fluent
- func (f *Fluent) Close() (err error)
- func (f *Fluent) EncodeAndPostData(tag string, tm time.Time, message interface{}) error
- func (f *Fluent) EncodeData(tag string, tm time.Time, message interface{}) (data []byte, err error)
- func (f *Fluent) Post(tag string, message interface{}) error
- func (f *Fluent) PostRawData(data []byte)deprecated
- func (f *Fluent) PostWithTime(tag string, tm time.Time, message interface{}) error
- func (f *Fluent) Stats() interface{}
- type Forward
- type Message
- type MessageChunk
- type MessageExt
- type Stats
- type TestMessage
Constants ¶
const Version = "1.3.0"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
FluentPort int `json:"fluent_port"`
FluentHost string `json:"fluent_host"`
FluentNetwork string `json:"fluent_network"`
FluentSocketPath string `json:"fluent_socket_path"`
Timeout time.Duration `json:"timeout"`
WriteTimeout time.Duration `json:"write_timeout"`
SocketMaxDuration time.Duration `json:"socket_max_duration"`
BufferLimit int `json:"buffer_limit"`
RetryWait int `json:"retry_wait"`
MaxRetry int `json:"max_retry"`
MaxRetryWait int `json:"max_retry_wait"`
TagPrefix string `json:"tag_prefix"`
Async bool `json:"async"`
// Deprecated: Use Async instead
AsyncConnect bool `json:"async_connect"`
MarshalAsJSON bool `json:"marshal_as_json"`
// Sub-second precision timestamps are only possible for those using fluentd
// v0.14+ and serializing their messages with msgpack.
SubSecondPrecision bool `json:"sub_second_precision"`
}
type Entry ¶ added in v1.0.0
type Entry struct {
Time int64 `msg:"time"`
Record interface{} `msg:"record"`
}
func (Entry) MarshalMsg ¶ added in v1.0.0
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 ¶
UnmarshalBinary is not implemented since decoding messages is not supported by this library.
type Fluent ¶
type Fluent struct {
Config
// contains filtered or unexported fields
}
func (*Fluent) EncodeAndPostData ¶ added in v1.0.0
func (*Fluent) EncodeData ¶ added in v1.0.0
func (*Fluent) Post ¶
Post writes the output for a logging event.
Examples:
// send map[string]
mapStringData := map[string]string{
"foo": "bar",
}
f.Post("tag_name", mapStringData)
// send message with specified time
mapStringData := map[string]string{
"foo": "bar",
}
tm := time.Now()
f.PostWithTime("tag_name", tm, mapStringData)
// send struct
structData := struct {
Name string `msg:"name"`
} {
"john smith",
}
f.Post("tag_name", structData)
func (*Fluent) PostRawData
deprecated
added in
v1.0.0
func (*Fluent) PostWithTime ¶ added in v0.4.3
type Forward ¶ added in v1.0.0
type Forward struct {
Tag string `msg:"tag"`
Entries []Entry `msg:"entries"`
Option interface{} `msg:"option"`
}
func (*Forward) MarshalMsg ¶ added in v1.0.0
MarshalMsg implements msgp.Marshaler
type Message ¶ added in v1.0.0
type Message struct {
Tag string `msg:"tag"`
Time int64 `msg:"time"`
Record interface{} `msg:"record"`
Option interface{} `msg:"option"`
}
func (*Message) MarshalMsg ¶ added in v1.0.0
MarshalMsg implements msgp.Marshaler
type MessageChunk ¶ added in v1.2.0
type MessageChunk struct {
// contains filtered or unexported fields
}
For sending forward protocol adopted JSON
func (*MessageChunk) MarshalJSON ¶ added in v1.2.0
func (chunk *MessageChunk) MarshalJSON() ([]byte, error)
Golang default marshaler does not support ["value", "value2", {"key":"value"}] style marshaling. So, it should write JSON marshaler by hand.
type MessageExt ¶
type MessageExt struct {
Tag string `msg:"tag"`
Time EventTime `msg:"time,extension"`
Record interface{} `msg:"record"`
Option interface{} `msg:"option"`
}
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 Stats ¶
type Stats struct {
PendingLogs uint32 // number of logs waiting to be sent
}
Stats contains information about Fluent client.
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