monitor

Documentation

Index

• Variables
• type Codes
• type Log
  • func LogFromBytes(msg []byte) *Log
  • func (a *Log) CalCode()
  • func (a *Log) LogData() (appID string, logType string, kv []log.D, err error)
• type MonitorConfig
• type MonitorHandler
  • func NewMonitor(c *MonitorConfig) (a *MonitorHandler)
  • func (h *MonitorHandler) Close() (err error)
  • func (h *MonitorHandler) Error(ctx context.Context, appID string, args ...log.D)
  • func (h *MonitorHandler) Info(ctx context.Context, appID string, args ...log.D)
  • func (h *MonitorHandler) Log(ctx context.Context, lv log.Level, appID string, args ...log.D)
  • func (h *MonitorHandler) SetFormat(string)
  • func (h *MonitorHandler) Warn(ctx context.Context, appID string, args ...log.D)

Variables

var ErrIncompleteLog = errors.New("Incomplete log")

ErrIncompleteLog .

Types

type Codes

type Codes struct {
	HTTPCode         interface{} `json:"http_code"`
	HTTPInnerCode    interface{} `json:"http_inner_code"`
	HTTPBusinessCode interface{} `json:"http_business_code"`
}

Codes .

type Log

type Log struct {
	// from app log
	RequestURI   string           `form:"request_uri" json:"request_uri"`
	TimeIso      string           `form:"time_iso" json:"time_iso"`
	IP           string           `form:"ip" json:"ip"`
	Version      string           `form:"version" json:"version"`
	Buvid        string           `form:"buvid" json:"buvid"`
	Fts          string           `form:"fts" json:"fts"`
	Proid        string           `form:"proid" json:"proid"`
	Chid         string           `form:"chid" json:"chid"`
	Pid          string           `form:"pid" json:"pid"`
	Brand        string           `form:"brand" json:"brand"`
	Deviceid     string           `form:"deviceid" json:"deviceid"`
	Model        string           `form:"model" json:"model"`
	Osver        string           `form:"osver" json:"osver"`
	Ctime        string           `form:"ctime" json:"ctime"`
	Mid          string           `form:"mid" json:"mid"`
	Ver          string           `form:"ver" json:"ver"`
	Net          string           `form:"net" json:"net"`
	Oid          string           `form:"oid" json:"oid"`
	Product      string           `form:"product" json:"product"`
	Createtime   string           `form:"createtime" json:"createtime"`
	Event        string           `form:"event" json:"event"`
	SubEvent     string           `form:"sub_event" json:"sub_event"`
	LogType      string           `form:"log_type" json:"log_type"`
	Duration     string           `form:"duration" json:"duration"`
	Message      string           `form:"message" json:"message"`
	Result       string           `form:"result" json:"result"`
	ExtJSON      string           `form:"ext_json" json:"ext_json"`
	Traceid      string           `form:"traceid" json:"traceid"`
	Desc         string           `form:"desc" json:"desc"`
	Network      string           `form:"network" json:"network"`
	TraceidEnd   string           `form:"traceid_end" json:"traceid_end"`
	HTTPCode     string           `form:"http_code" json:"http_code"`
	SubProduct   string           `form:"sub_product" json:"sub_product"`
	Codes        string           `json:"codes"`
	BusinessCode string           `json:"business_code"`
	InnerCode    string           `json:"inner_code"`
	TraceidSvr   string           `json:"traceid_svr"`
	Type         string           `json:"type"`
	Query        string           `json:"query"`
	UserAgent    string           `json:"user_agent"`
	Details      map[string]int64 `json:"details"`
}

Log .

func LogFromBytes

func LogFromBytes(msg []byte) *Log

LogFromBytes .

func (*Log) CalCode

func (a *Log) CalCode()

CalCode handle codes.

func (*Log) LogData

func (a *Log) LogData() (appID string, logType string, kv []log.D, err error)

LogData .

type MonitorConfig

type MonitorConfig struct {
	TaskID  string
	Buffer  int
	Proto   string         `dsn:"network"`
	Addr    string         `dsn:"address"`
	Chan    int            `dsn:"query.chan"`
	Timeout xtime.Duration `dsn:"query.timeout"`
}

MonitorConfig agent config.

type MonitorHandler

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

MonitorHandler .

func NewMonitor

func NewMonitor(c *MonitorConfig) (a *MonitorHandler)

NewMonitor a MonitorHandler.

func (*MonitorHandler) Close

func (h *MonitorHandler) Close() (err error)

Close close the connection.

func (*MonitorHandler) Error

func (h *MonitorHandler) Error(ctx context.Context, appID string, args ...log.D)

Error .

func (*MonitorHandler) Info

func (h *MonitorHandler) Info(ctx context.Context, appID string, args ...log.D)

Info .

func (*MonitorHandler) Log

func (h *MonitorHandler) Log(ctx context.Context, lv log.Level, appID string, args ...log.D)

Log log to udp statsd daemon.

func (*MonitorHandler) SetFormat

func (h *MonitorHandler) SetFormat(string)

SetFormat .

func (*MonitorHandler) Warn

func (h *MonitorHandler) Warn(ctx context.Context, appID string, args ...log.D)

Warn .