mq

Documentation

Index

• Variables
• func GetMetricRegistry() *prometheus.Registry
• func IncPublishedDDLCount(topic, changefeed string, message *common.Message)
• func IncPublishedDDLFail(topic, changefeed string, message *common.Message)
• func IncPublishedDDLSuccess(topic, changefeed string, message *common.Message)
• func IncPublishedDMLCount(topic, changefeed, schema string)
• func IncPublishedDMLFail(topic, changefeed, schema string)
• func IncPublishedDMLSuccess(topic, changefeed, schema string)
• func InitMetrics(registry *prometheus.Registry)

Variables

var (
	// WorkerSendMessageDuration records the duration of flushing a group messages.
	WorkerSendMessageDuration = prometheus.NewHistogramVec(
		prometheus.HistogramOpts{
			Namespace: "ticdc",
			Subsystem: "sink",
			Name:      "mq_worker_send_message_duration",
			Help:      "Send Message duration(s) for MQ worker.",
			Buckets:   prometheus.ExponentialBuckets(0.001, 2, 20),
		}, []string{"namespace", "changefeed"})
	// WorkerBatchSize record the size of each batched messages.
	WorkerBatchSize = prometheus.NewHistogramVec(
		prometheus.HistogramOpts{
			Namespace: "ticdc",
			Subsystem: "sink",
			Name:      "mq_worker_batch_size",
			Help:      "Batch size for MQ worker.",
			Buckets:   prometheus.ExponentialBuckets(4, 2, 10),
		}, []string{"namespace", "changefeed"})
	// WorkerBatchDuration record the time duration cost on batch messages.
	WorkerBatchDuration = prometheus.NewHistogramVec(
		prometheus.HistogramOpts{
			Namespace: "ticdc",
			Subsystem: "sink",
			Name:      "mq_worker_batch_duration",
			Help:      "Batch duration for MQ worker.",
			Buckets:   prometheus.ExponentialBuckets(0.004, 2, 10),
		}, []string{"namespace", "changefeed"})
)

Functions

func GetMetricRegistry

func GetMetricRegistry() *prometheus.Registry

GetMetricRegistry for add pulsar default metrics

func IncPublishedDDLCount

func IncPublishedDDLCount(topic, changefeed string, message *common.Message)

IncPublishedDDLCount DDL

func IncPublishedDDLFail

func IncPublishedDDLFail(topic, changefeed string, message *common.Message)

IncPublishedDDLFail fail

func IncPublishedDDLSuccess

func IncPublishedDDLSuccess(topic, changefeed string, message *common.Message)

IncPublishedDDLSuccess success

func IncPublishedDMLCount

func IncPublishedDMLCount(topic, changefeed, schema string)

IncPublishedDMLCount count

func IncPublishedDMLFail

func IncPublishedDMLFail(topic, changefeed, schema string)

IncPublishedDMLFail fail

func IncPublishedDMLSuccess

func IncPublishedDMLSuccess(topic, changefeed, schema string)

IncPublishedDMLSuccess success

func InitMetrics

func InitMetrics(registry *prometheus.Registry)

InitMetrics registers all metrics in this file.