statistics

var (

	// ConsumeMsgsTotal = ParseMsgsErrorTotal + FlushMsgsTotal + FlushMsgsErrorTotal
	ConsumeMsgsTotal = prometheus.NewCounterVec(
		prometheus.CounterOpts{
			Name: prefix + "consume_msgs_total",
			Help: "total num of consumed msgs",
		},
		[]string{"task"},
	)
	ParseMsgsErrorTotal = prometheus.NewCounterVec(
		prometheus.CounterOpts{
			Name: prefix + "parse_msgs_error_total",
			Help: "total num of msgs with parse failure",
		},
		[]string{"task"},
	)
	FlushMsgsTotal = prometheus.NewCounterVec(
		prometheus.CounterOpts{
			Name: prefix + "flush_msgs_total",
			Help: "total num of flushed msgs",
		},
		[]string{"task"},
	)
	FlushMsgsErrorTotal = prometheus.NewCounterVec(
		prometheus.CounterOpts{
			Name: prefix + "flush_msgs_error_total",
			Help: "total num of msgs failed to flush to ck",
		},
		[]string{"task"},
	)
	ConsumeOffsets = prometheus.NewGaugeVec(
		prometheus.GaugeOpts{
			Name: prefix + "consume_offsets",
			Help: "last committed offset for each topic partition pair",
		},
		[]string{"consumer", "topic", "partition"},
	)
	ConsumeLags = prometheus.NewGaugeVec(
		prometheus.GaugeOpts{
			Name: prefix + "consume_lags",
			Help: "message lags for each task, work with cluster of sinker",
		},
		[]string{"consumer", "topic", "task"},
	)
	ShardMsgs = prometheus.NewGaugeVec(
		prometheus.GaugeOpts{
			Name: prefix + "shard_msgs",
			Help: "num of msgs in shard",
		},
		[]string{"task"},
	)
	WritingPoolBacklog = prometheus.NewGaugeVec(
		prometheus.GaugeOpts{
			Name: prefix + "writing_pool_backlog",
			Help: "GlobalWritingPool backlog",
		},
		[]string{"task"},
	)
	WritingDurations = prometheus.NewHistogramVec(
		prometheus.HistogramOpts{
			Name:    prefix + "writing_durations",
			Help:    "writing durations",
			Buckets: []float64{1.0, 2.0, 4.0, 8.0, 16.0, 32.0, 64.0, 128.0},
		},
		[]string{"task", "table"},
	)
	WriteSeriesAllowNew = prometheus.NewCounterVec(
		prometheus.CounterOpts{
			Name: prefix + "write_series_allow_new",
			Help: "num of allowed new series",
		},
		[]string{"task"},
	)
	WriteSeriesAllowChanged = prometheus.NewCounterVec(
		prometheus.CounterOpts{
			Name: prefix + "write_series_allow_changed",
			Help: "num of allowed changed series",
		},
		[]string{"task"},
	)
	WriteSeriesDropQuota = prometheus.NewCounterVec(
		prometheus.CounterOpts{
			Name: prefix + "write_series_drop_quota",
			Help: "num of disallowed write_series due to quota",
		},
		[]string{"task"},
	)
	WriteSeriesDropUnchanged = prometheus.NewCounterVec(
		prometheus.CounterOpts{
			Name: prefix + "write_series_drop_unchanged",
			Help: "num of disallowed write_series due to unchanged",
		},
		[]string{"task"},
	)
	// WriteSeriesSucceed = WriteSeriesAllowNew + WriteSeriesAllowChanged
	WriteSeriesSucceed = prometheus.NewCounterVec(
		prometheus.CounterOpts{
			Name: prefix + "write_series_succeed",
			Help: "num of series handled by writeSeries",
		},
		[]string{"task"},
	)
)