fluent

May 26, 2015

Changes in this version

+ type Entry struct

+ Record interface{}

+ Time int64

+ func (z *Entry) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Entry) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z Entry) EncodeMsg(en *msgp.Writer) (err error)

+ func (z Entry) MarshalMsg(b []byte) (o []byte, err error)

+ func (z Entry) Msgsize() (s int)

type Fluent

+ 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) PostRawData(data []byte)

+ type Forward struct

+ Entries []Entry

+ Option interface{}

+ Tag string

+ func (z *Forward) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Forward) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *Forward) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *Forward) Msgsize() (s int)

+ func (z *Forward) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type Message struct

+ Option interface{}

+ Record interface{}

+ Tag string

+ Time int64

+ func (z *Message) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Message) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *Message) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *Message) Msgsize() (s int)

+ func (z *Message) UnmarshalMsg(bts []byte) (o []byte, err error)

Aug 25, 2014

Changes in this version

type Config

+ TagPrefix string

Mar 26, 2014

Changes in this version

type Fluent

+ func (f *Fluent) PostWithTime(tag string, tm time.Time, message interface{})

May 16, 2013

Changes in this version

+ const Version

type Config

+ MaxRetry int

+ RetryWait int

May 16, 2013

Changes in this version

+ type Config struct

+ BufferLimit int

+ FluentHost string

+ FluentPort int

+ Timeout time.Duration

+ type Fluent struct

+ func New(config Config) (f *Fluent, err error)

+ func (f *Fluent) Close() (err error)

+ func (f *Fluent) Post(tag string, message interface{})