proc

Documentation

Index

• Variables
• func GetAll() []interface{}
• func Start()

Variables

var (
	// 计数统计,正确计数,错误计数, ...
	RecvCnt       = nproc.NewSCounterQps("RecvCnt")
	RpcRecvCnt    = nproc.NewSCounterQps("RpcRecvCnt")
	HttpRecvCnt   = nproc.NewSCounterQps("HttpRecvCnt")
	SocketRecvCnt = nproc.NewSCounterQps("SocketRecvCnt")

	SendToJudgeCnt    = nproc.NewSCounterQps("SendToJudgeCnt")
	SendToTsdbCnt     = nproc.NewSCounterQps("SendToTsdbCnt")
	SendToGraphCnt    = nproc.NewSCounterQps("SendToGraphCnt")
	SendToInfluxdbCnt = nproc.NewSCounterQps("SendToInfluxdbCnt")
	SendToNqmRpcCnt   = nproc.NewSCounterQps("SendToNqmRpcCnt")

	SendToJudgeDropCnt    = nproc.NewSCounterQps("SendToJudgeDropCnt")
	SendToTsdbDropCnt     = nproc.NewSCounterQps("SendToTsdbDropCnt")
	SendToGraphDropCnt    = nproc.NewSCounterQps("SendToGraphDropCnt")
	SendToInfluxdbDropCnt = nproc.NewSCounterQps("SendToInfluxdbDropCnt")
	SendToNqmRpcDropCnt   = nproc.NewSCounterQps("SendToNqmRpcDropCnt")

	SendToJudgeFailCnt    = nproc.NewSCounterQps("SendToJudgeFailCnt")
	SendToTsdbFailCnt     = nproc.NewSCounterQps("SendToTsdbFailCnt")
	SendToGraphFailCnt    = nproc.NewSCounterQps("SendToGraphFailCnt")
	SendToInfluxdbFailCnt = nproc.NewSCounterQps("SendToInfluxdbFailCnt")
	SendToNqmRpcFailCnt   = nproc.NewSCounterQps("SendToNqmRpcFailCnt")

	// 发送缓存大小
	JudgeQueuesCnt    = nproc.NewSCounterBase("JudgeSendCacheCnt")
	TsdbQueuesCnt     = nproc.NewSCounterBase("TsdbSendCacheCnt")
	GraphQueuesCnt    = nproc.NewSCounterBase("GraphSendCacheCnt")
	InfluxdbQueuesCnt = nproc.NewSCounterBase("InfluxdbSendCacheCnt")
	NqmRpcQueuesCnt   = nproc.NewSCounterBase("NqmRpcSendCacheCnt")
)

统计指标的整体数据

var (
	RecvDataFilter = nproc.NewDataFilter("RecvDataFilter", 5)
)

filter

var (
	RecvDataTrace = nproc.NewDataTrace("RecvDataTrace", 3)
)

trace

Functions

func GetAll

func GetAll() []interface{}

func Start

func Start()