proc

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")
	SendToNqmIcmpCnt    = nproc.NewSCounterQps("SendToNqmIcmpCnt")
	SendToNqmTcpCnt     = nproc.NewSCounterQps("SendToNqmTcpCnt")
	SendToNqmTcpconnCnt = nproc.NewSCounterQps("SendToNqmTcpconnCnt")
	SendToStagingCnt    = nproc.NewSCounterQps("SendToStagingCnt")

	SendToJudgeDropCnt      = nproc.NewSCounterQps("SendToJudgeDropCnt")
	SendToTsdbDropCnt       = nproc.NewSCounterQps("SendToTsdbDropCnt")
	SendToGraphDropCnt      = nproc.NewSCounterQps("SendToGraphDropCnt")
	SendToInfluxdbDropCnt   = nproc.NewSCounterQps("SendToInfluxdbDropCnt")
	SendToNqmIcmpDropCnt    = nproc.NewSCounterQps("SendToNqmIcmpDropCnt")
	SendToNqmTcpDropCnt     = nproc.NewSCounterQps("SendToNqmTcpDropCnt")
	SendToNqmTcpconnDropCnt = nproc.NewSCounterQps("SendToNqmTcpconnDropCnt")
	SendToStagingDropCnt    = nproc.NewSCounterQps("SendToStagingDropCnt")

	SendToJudgeFailCnt      = nproc.NewSCounterQps("SendToJudgeFailCnt")
	SendToTsdbFailCnt       = nproc.NewSCounterQps("SendToTsdbFailCnt")
	SendToGraphFailCnt      = nproc.NewSCounterQps("SendToGraphFailCnt")
	SendToInfluxdbFailCnt   = nproc.NewSCounterQps("SendToInfluxdbFailCnt")
	SendToNqmIcmpFailCnt    = nproc.NewSCounterQps("SendToNqmIcmpFailCnt")
	SendToNqmTcpFailCnt     = nproc.NewSCounterQps("SendToNqmTcpFailCnt")
	SendToNqmTcpconnFailCnt = nproc.NewSCounterQps("SendToNqmTcpconnFailCnt")
	SendToStagingFailCnt    = nproc.NewSCounterQps("SendToStagingFailCnt")

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

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

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