fluent

Documentation

Index

• Variables
• type Config
• type EventTimeExtension
  • func (e *EventTimeExtension) ReadExt(dst interface{}, src []byte)
  • func (e *EventTimeExtension) WriteExt(v interface{}) []byte
• 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) RefreshConnection() error
  • func (f *Fluent) Send(buffer []byte) (err error)
  • func (f *Fluent) Shutdown()
  • func (f *Fluent) String() string
• type FluentRecord
  • func (r *FluentRecord) GetAllData() map[string]interface{}
  • func (r *FluentRecord) GetData(key string) (interface{}, bool)
  • func (r FluentRecord) Pack() ([]byte, error)
  • func (r *FluentRecord) String() string
• 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) GetAllData() map[string]interface{}
  • func (r *TinyFluentMessage) GetData(key string) (interface{}, bool)
  • func (r *TinyFluentMessage) Pack() ([]byte, error)
  • func (r *TinyFluentMessage) String() string
• type TinyFluentRecord
  • func (r *TinyFluentRecord) GetAllData() map[string]interface{}
  • func (r *TinyFluentRecord) GetData(key string) (interface{}, bool)
  • func (r *TinyFluentRecord) Pack() ([]byte, error)
  • func (r *TinyFluentRecord) String() string

Variables

var (
	EnableEventTime = false
)

var Rand = rand.New(rand.NewSource(time.Now().UnixNano()))

Types

type Config

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

type EventTimeExtension

type EventTimeExtension struct{}

func (*EventTimeExtension) ReadExt

func (e *EventTimeExtension) ReadExt(dst interface{}, src []byte)

func (*EventTimeExtension) WriteExt

func (e *EventTimeExtension) WriteExt(v interface{}) []byte

type Fluent

type Fluent struct {
	Config

	Sent int64
	// 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) RefreshConnection

func (f *Fluent) RefreshConnection() error

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 time.Time
	Data      map[string]interface{}
}

func (*FluentRecord) GetAllData

func (r *FluentRecord) GetAllData() map[string]interface{}

func (*FluentRecord) GetData

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

func (FluentRecord) Pack

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

func (*FluentRecord) String

func (r *FluentRecord) String() string

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)
	GetAllData() map[string]interface{}
	String() string
}

type TinyFluentMessage

type TinyFluentMessage struct {
	Timestamp time.Time
	FieldName string
	Message   []byte
}

func (*TinyFluentMessage) GetAllData

func (r *TinyFluentMessage) GetAllData() map[string]interface{}

func (*TinyFluentMessage) GetData

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

func (*TinyFluentMessage) Pack

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

func (*TinyFluentMessage) String

func (r *TinyFluentMessage) String() string

type TinyFluentRecord

type TinyFluentRecord struct {
	Timestamp time.Time
	Data      map[string]interface{}
}

func (*TinyFluentRecord) GetAllData

func (r *TinyFluentRecord) GetAllData() map[string]interface{}

func (*TinyFluentRecord) GetData

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

func (*TinyFluentRecord) Pack

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

func (*TinyFluentRecord) String

func (r *TinyFluentRecord) String() string