fluent

Documentation

Index

• type Config
• type Fluent
  • func New(config Config) (f *Fluent, err error)
  • func (f *Fluent) Alive() bool
  • func (f *Fluent) Close() (err error)
  • func (f *Fluent) IsReconnecting() bool
  • func (f *Fluent) LastErrorString() string
  • func (f *Fluent) Send(buffer []byte) (err error)
  • func (f *Fluent) Shutdown()
  • func (f *Fluent) String() string
• type FluentRecord
  • func (r FluentRecord) Pack() ([]byte, error)
• type FluentRecordSet
  • func DecodeEntries(conn net.Conn) ([]FluentRecordSet, error)
  • func (rs *FluentRecordSet) PackAsForward() ([]byte, error)
  • func (rs *FluentRecordSet) PackAsPackedForward() ([]byte, error)
• type FluentRecordType
• type TinyFluentMessage
  • func (r *TinyFluentMessage) GetData(key string) (interface{}, bool)
  • func (r *TinyFluentMessage) Pack() ([]byte, error)
• type TinyFluentRecord
  • func (r *TinyFluentRecord) GetData(key string) (interface{}, bool)
  • func (r *TinyFluentRecord) Pack() ([]byte, error)

Types

type Config

type Config struct {
	Server    string
	Timeout   time.Duration
	RetryWait int
	MaxRetry  int
}

type Fluent

type Fluent struct {
	Config
	// contains filtered or unexported fields
}

func New

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

New creates a new Logger.

func (*Fluent) Alive

func (f *Fluent) Alive() bool

func (*Fluent) Close

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

Close closes the connection.

func (*Fluent) IsReconnecting

func (f *Fluent) IsReconnecting() bool

IsReconnecting return true if a reconnecting process in progress.

func (*Fluent) LastErrorString

func (f *Fluent) LastErrorString() string

func (*Fluent) Send

func (f *Fluent) Send(buffer []byte) (err error)

func (*Fluent) Shutdown

func (f *Fluent) Shutdown()

func (*Fluent) String

func (f *Fluent) String() string

type FluentRecord

type FluentRecord struct {
	Tag       string
	Timestamp int64
	Data      map[string]interface{}
}

func (FluentRecord) Pack

func (r FluentRecord) Pack() ([]byte, error)

type FluentRecordSet

type FluentRecordSet struct {
	Tag     string
	Records []FluentRecordType
}

func DecodeEntries

func DecodeEntries(conn net.Conn) ([]FluentRecordSet, error)

func (*FluentRecordSet) PackAsForward

func (rs *FluentRecordSet) PackAsForward() ([]byte, error)

func (*FluentRecordSet) PackAsPackedForward

func (rs *FluentRecordSet) PackAsPackedForward() ([]byte, error)

type FluentRecordType

type FluentRecordType interface {
	Pack() ([]byte, error)
	GetData(string) (interface{}, bool)
}

type TinyFluentMessage

type TinyFluentMessage struct {
	Timestamp int64
	FieldName string
	Message   []byte
}

func (*TinyFluentMessage) GetData

func (r *TinyFluentMessage) GetData(key string) (interface{}, bool)

func (*TinyFluentMessage) Pack

func (r *TinyFluentMessage) Pack() ([]byte, error)

type TinyFluentRecord

type TinyFluentRecord struct {
	Timestamp int64
	Data      map[string]interface{}
}

func (*TinyFluentRecord) GetData

func (r *TinyFluentRecord) GetData(key string) (interface{}, bool)

func (*TinyFluentRecord) Pack

func (r *TinyFluentRecord) Pack() ([]byte, error)