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")
	//added by vincent.zhang for sending to kafka
	SendToKafkaCnt      = nproc.NewSCounterQps("SendToKafkaCnt")      // 转发到Kafka消息数(vipfalcon)
	SendToKafkaCntTotal = nproc.NewSCounterQps("SendToKafkaCntTotal") // 转发到Kafka消息总数
	SendToKafkaCntMap   = make(map[string]*nproc.SCounterQps)
	SendToKafkaLogCnt   = nproc.NewSCounterQps("SendToKafkaLogCnt") // 转发到Kafka Log消息数(vipfalcon-log)

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

	// added by terry.zeng for send to redis
	SendToRedisFailCnt = nproc.NewSCounterQps("SendToRedisFailCnt")
	SendToRedisCnt     = nproc.NewSCounterQps("SendToRedisCnt")

	//added by vincent.zhang for sending to kafka
	SendToKafkaDropCnt    = nproc.NewSCounterQps("SendToKafkaDropCnt")    // Kafka缓存队列丢弃数(vipfalcon)
	SendToKafkaDropCntMap = make(map[string]*nproc.SCounterQps)           // 对应topic的缓存队列丢弃数
	SendToKafkaLogDropCnt = nproc.NewSCounterQps("SendToKafkaLogDropCnt") // Kafka Log队列丢弃数(vipfalcon-log)

	SendToJudgeFailCnt = nproc.NewSCounterQps("SendToJudgeFailCnt")
	SendToTsdbFailCnt  = nproc.NewSCounterQps("SendToTsdbFailCnt")
	SendToGraphFailCnt = nproc.NewSCounterQps("SendToGraphFailCnt")
	//added by vincent.zhang for sending to kafka
	SendToKafkaFailCnt      = nproc.NewSCounterQps("SendToKafkaFailCnt")      // 转发到Kafka失败数(vipfalcon)
	SendToKafkaFailCntTotal = nproc.NewSCounterQps("SendToKafkaFailCntTotal") // 转发到Kafka失败总数
	SendToKafkaFailCntMap   = make(map[string]*nproc.SCounterQps)
	SendToKafkaLogFailCnt   = nproc.NewSCounterQps("SendToKafkaLogFailCnt") // 转发到Kafka Log失败数(vipfalcon-log)

	// 发送缓存大小
	JudgeQueuesCnt = nproc.NewSCounterBase("JudgeSendCacheCnt")
	TsdbQueuesCnt  = nproc.NewSCounterBase("TsdbSendCacheCnt")
	GraphQueuesCnt = nproc.NewSCounterBase("GraphSendCacheCnt")
	//added by vincent.zhang for sending to kafka
	KafkaQueuesCnt    = nproc.NewSCounterBase("KafkaSendCacheCnt")    // Kafka缓存队列大小(vipfalcon)
	KafkaQueuesCntMap = make(map[string]*nproc.SCounterBase)          // 对应topic的缓存队列大小
	KafkaLogQueuesCnt = nproc.NewSCounterBase("KafkaLogSendCacheCnt") // Kafka Log缓存队列大小(vipfalcon-log)

	// http请求次数
	HistoryRequestCnt = nproc.NewSCounterQps("HistoryRequestCnt")
	InfoRequestCnt    = nproc.NewSCounterQps("InfoRequestCnt")
	LastRequestCnt    = nproc.NewSCounterQps("LastRequestCnt")
	LastRawRequestCnt = nproc.NewSCounterQps("LastRawRequestCnt")

	// http回执的监控数据条数
	HistoryResponseCounterCnt = nproc.NewSCounterQps("HistoryResponseCounterCnt")
	HistoryResponseItemCnt    = nproc.NewSCounterQps("HistoryResponseItemCnt")
	LastRequestItemCnt        = nproc.NewSCounterQps("LastRequestItemCnt")
	LastRawRequestItemCnt     = nproc.NewSCounterQps("LastRawRequestItemCnt")
)

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

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