metric

Documentation

Index

• func HandleMetrics(step int64)
• func MetricAnalysis(file string, num int64)
• func MetricAnalysisSucc(file string, num int64)
• func MetricDropLine(file string, num int64)
• func MetricLoop(step int64)
• func MetricMem(size int64)
• func MetricPushCnt(num int64, succ bool)
• func MetricPushLatency(latency int64)
• func MetricReadLine(file string, num int64)
• type MetricTags
  • func (m *MetricTags) AddCount(k string, v int64)
  • func (m *MetricTags) HasKey(k string) bool
• type SelfMonitMetrics

Functions

func HandleMetrics

func HandleMetrics(step int64)

将统计落实成一个个的监控点 此处只打印日志，若需要上报自监控指标，可以修改此方法 TODO:此处只对齐至最近的时间点，统计并非十分精准

func MetricAnalysis

func MetricAnalysis(file string, num int64)

func MetricAnalysisSucc

func MetricAnalysisSucc(file string, num int64)

func MetricDropLine

func MetricDropLine(file string, num int64)

func MetricLoop

func MetricLoop(step int64)

func MetricMem

func MetricMem(size int64)

func MetricPushCnt

func MetricPushCnt(num int64, succ bool)

func MetricPushLatency

func MetricPushLatency(latency int64)

func MetricReadLine

func MetricReadLine(file string, num int64)

Types

type MetricTags

type MetricTags struct {
	sync.RWMutex
	Counters map[string]int64
}

func (*MetricTags) AddCount

func (m *MetricTags) AddCount(k string, v int64)

func (*MetricTags) HasKey

func (m *MetricTags) HasKey(k string) bool

type SelfMonitMetrics

type SelfMonitMetrics struct {
	MemUsedMB       int64       `json:"mem_used_mb"`
	ReadLineCnt     *MetricTags `json:"read_line_cnt"`
	DropLineCnt     *MetricTags `json:"drop_line_cnt"`
	AnalysisCnt     *MetricTags `json:"analysis_cnt"`
	AnalysisSuccCnt *MetricTags `json:"analysis_succ_cnt"`
	PushCnt         int64       `json:"push_cnt"`
	PushErrorCnt    int64       `json:"push_err_cnt"`
	PushLatency     int64       `json:"push_latency"`
	NewTms          int64
}

自监控结构体