InitMetrics registers all metrics used in owner.

InitEventServiceMetrics registers all metrics in this file.

InitMetrics registers all metrics used in owner.

InitMetrics registers all metrics used in scheduler.

InitServerMetrics registers all metrics used in processor.

InitMetrics registers all metrics in this file.

LagBucket returns the lag buckets for prometheus metric 10 seconds is the reasonable LAG for most cases, for prometheus histogram_quantile func, we use small bucket distance to do accurate approximation.

NewStatistics creates a statistics.

RecordGoRuntimeSettings records GOGC settings.

LargeRowSizeLowBound is set to 2K, only track data event with size not smaller than it.

---------- Metrics for kafka sink and backends.

---------- Metrics for kafka sink and backends.

ConflictDetectDuration records the duration of detecting conflict.

EventServiceSendEventCount is the metric that counts events sent by the event service.

EventServiceSendEventDuration is the metric that records the duration of sending events by the event service.

---------- Metrics used in Statistics.

types : kv, resolved.

types : kv, resolved.

type is for `sinkType`.

type is for `sinkType`.

---------- Metrics used in Statistics.

type is for `sinkType`.

target: its addr, type: event, command.

target: its addr, type: event, command, message: error info.

type: event, command.

target: its addr, type: event, command.

target: its addr, type: event, command.

target: its addr.

---------- Metrics for txn sink and backends.

QueueDuration = ConflictDetectDuration + (queue time in txn workers).

---------- Metrics for txn sink and backends.

---------- Metrics for txn sink and backends.

type is for `sinkType`.

WorkerBatchDuration record the time duration cost on batch messages.

WorkerBatchSize record the size of each batched messages.

---------- Metrics for txn sink and backends.

---------- Metrics for txn sink and backends.

WorkerSendMessageDuration records the duration of flushing a group messages.

---------- Metrics for txn sink and backends.

Statistics maintains some status and metrics of the Sink Note: All methods of Statistics should be thread-safe.