flume_log

Documentation

Index

• type DetailInfo
  • func NewDetailInfo(m string) *DetailInfo
  • func (d *DetailInfo) AddKeyValue(key string, value interface{})
  • func (d *DetailInfo) SetExtraInfo(extra interface{})
• type ExtraInfo
• type FlumeClient
  • func NewFlumeClient(agentIP string) *FlumeClient
  • func (c *FlumeClient) SendLog(d []byte) error
  • func (c *FlumeClient) Stop()
• type FlumeLogger
  • func NewFlumeLogger() *FlumeLogger
  • func NewFlumeLoggerWithAddr(agentAddr string) *FlumeLogger
  • func (l *FlumeLogger) Error(logInfo string, detail *DetailInfo) error
  • func (l *FlumeLogger) Info(logInfo string, detail *DetailInfo) error
  • func (l *FlumeLogger) Stop()
  • func (l *FlumeLogger) Warn(logInfo string, detail *DetailInfo) error
• type LogInfo
  • func NewLogInfo() *LogInfo
  • func (l *LogInfo) Serialize() []byte
  • func (l *LogInfo) String() string
• type LogInfoJson

Types

type DetailInfo

type DetailInfo struct {
	// contains filtered or unexported fields
}

func NewDetailInfo

func NewDetailInfo(m string) *DetailInfo

func (*DetailInfo) AddKeyValue

func (d *DetailInfo) AddKeyValue(key string, value interface{})

func (*DetailInfo) SetExtraInfo

func (d *DetailInfo) SetExtraInfo(extra interface{})

type ExtraInfo

type ExtraInfo map[string]interface{}

type FlumeClient

type FlumeClient struct {
	// contains filtered or unexported fields
}

func NewFlumeClient

func NewFlumeClient(agentIP string) *FlumeClient

func (*FlumeClient) SendLog

func (c *FlumeClient) SendLog(d []byte) error

func (*FlumeClient) Stop

func (c *FlumeClient) Stop()

type FlumeLogger

type FlumeLogger struct {
	// contains filtered or unexported fields
}

func NewFlumeLogger

func NewFlumeLogger() *FlumeLogger

func NewFlumeLoggerWithAddr

func NewFlumeLoggerWithAddr(agentAddr string) *FlumeLogger

func (*FlumeLogger) Error

func (l *FlumeLogger) Error(logInfo string, detail *DetailInfo) error

func (*FlumeLogger) Info

func (l *FlumeLogger) Info(logInfo string, detail *DetailInfo) error

func (*FlumeLogger) Stop

func (l *FlumeLogger) Stop()

func (*FlumeLogger) Warn

func (l *FlumeLogger) Warn(logInfo string, detail *DetailInfo) error

type LogInfo

type LogInfo struct {
	// contains filtered or unexported fields
}

func NewLogInfo

func NewLogInfo() *LogInfo

func (*LogInfo) Serialize

func (l *LogInfo) Serialize() []byte

func (*LogInfo) String

func (l *LogInfo) String() string

type LogInfoJson

type LogInfoJson struct {
	Type     string      `json:"type"`
	Tag      string      `json:"tag"`
	PlatForm string      `json:"platform"`
	Level    string      `json:"level"`
	App      string      `json:"app"`
	Module   string      `json:"module"`
	Detail   interface{} `json:"detail"`
}