tablesink

Documentation

Index

• Variables
• func InitMetrics(registry *prometheus.Registry)

Variables

var TableSinkFlushLagDuration = prometheus.NewHistogramVec(
	prometheus.HistogramOpts{
		Namespace: "ticdc",
		Subsystem: "sink",
		Name:      "flush_lag_histogram",
		Help:      "flush lag histogram of rows that are processed by table sink",
		Buckets:   metrics.LagBucket(),
	}, []string{"namespace", "changefeed"})

TableSinkFlushLagDuration is the per event flush lag calculated by ts_after_event_flushed_to_downstream - commit_ts_of_event

var TotalRowsCountCounter = prometheus.NewCounterVec(
	prometheus.CounterOpts{
		Namespace: "ticdc",
		Subsystem: "sink",
		Name:      "table_sink_total_rows_count",
		Help:      "The total count of rows that are processed by table sink",
	}, []string{"namespace", "changefeed"})

TotalRowsCountCounter is the total count of rows that are processed by sink.

Functions

func InitMetrics

func InitMetrics(registry *prometheus.Registry)

InitMetrics registers all metrics in this file.