1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
use lazy_static::*;
use prometheus::*;
lazy_static! {
pub static ref CDC_RESOLVED_TS_GAP_HISTOGRAM: Histogram = register_histogram!(
"tikv_cdc_resolved_ts_gap_seconds",
"Bucketed histogram of the gap between cdc resolved ts and current tso",
exponential_buckets(0.001, 2.0, 24).unwrap()
)
.unwrap();
pub static ref CDC_SCAN_DURATION_HISTOGRAM: Histogram = register_histogram!(
"tikv_cdc_scan_duration_seconds",
"Bucketed histogram of cdc async scan duration",
exponential_buckets(0.005, 2.0, 20).unwrap()
)
.unwrap();
pub static ref CDC_SCAN_BYTES: IntCounter = register_int_counter!(
"tikv_cdc_scan_bytes_total",
"Total bytes of CDC incremental scan"
)
.unwrap();
pub static ref CDC_SCAN_TASKS: IntGaugeVec = register_int_gauge_vec!(
"tikv_cdc_scan_tasks",
"Total number of CDC incremental scan tasks",
&["type"]
)
.unwrap();
pub static ref CDC_MIN_RESOLVED_TS_REGION: IntGauge = register_int_gauge!(
"tikv_cdc_min_resolved_ts_region",
"The region which has minimal resolved ts"
)
.unwrap();
pub static ref CDC_MIN_RESOLVED_TS: IntGauge = register_int_gauge!(
"tikv_cdc_min_resolved_ts",
"The minimal resolved ts for current regions"
)
.unwrap();
pub static ref CDC_PENDING_BYTES_GAUGE: IntGauge = register_int_gauge!(
"tikv_cdc_pending_bytes",
"Bytes in memory of a pending region"
)
.unwrap();
pub static ref CDC_CAPTURED_REGION_COUNT: IntGauge = register_int_gauge!(
"tikv_cdc_captured_region_total",
"Total number of CDC captured regions"
)
.unwrap();
pub static ref CDC_OLD_VALUE_CACHE_LEN: IntGauge = register_int_gauge!(
"tikv_cdc_old_value_cache_length",
"Number of elements in old value cache"
)
.unwrap();
pub static ref CDC_OLD_VALUE_CACHE_CAP: IntGauge = register_int_gauge!(
"tikv_cdc_old_value_cache_capacity",
"Capacity of old value cache"
)
.unwrap();
pub static ref CDC_REGION_RESOLVE_STATUS_GAUGE_VEC: IntGaugeVec = register_int_gauge_vec!(
"tikv_cdc_region_resolve_status",
"The status of CDC captured regions",
&["status"]
)
.unwrap();
pub static ref CDC_OLD_VALUE_CACHE_MISS: IntGauge = register_int_gauge!(
"tikv_cdc_old_value_cache_miss",
"Count of old value cache missing"
)
.unwrap();
pub static ref CDC_OLD_VALUE_CACHE_MISS_NONE: IntGauge = register_int_gauge!(
"tikv_cdc_old_value_cache_miss_none",
"Count of None old value cache missing"
)
.unwrap();
pub static ref CDC_OLD_VALUE_CACHE_ACCESS: IntGauge = register_int_gauge!(
"tikv_cdc_old_value_cache_access",
"Count of old value cache accessing"
)
.unwrap();
pub static ref CDC_OLD_VALUE_CACHE_BYTES: IntGauge =
register_int_gauge!("tikv_cdc_old_value_cache_bytes", "Bytes of old value cache").unwrap();
pub static ref CDC_OLD_VALUE_SCAN_DETAILS: IntCounterVec = register_int_counter_vec!(
"tikv_cdc_old_value_scan_details",
"Bucketed counter of scan details for old value",
&["cf", "tag"]
)
.unwrap();
pub static ref CDC_OLD_VALUE_DURATION_HISTOGRAM: HistogramVec = register_histogram_vec!(
"tikv_cdc_old_value_duration",
"Bucketed histogram of cdc old value scan duration",
&["tag"],
exponential_buckets(0.0001, 2.0, 20).unwrap()
)
.unwrap();
pub static ref CDC_RESOLVED_TS_ADVANCE_METHOD: IntGauge = register_int_gauge!(
"tikv_cdc_resolved_ts_advance_method",
"Resolved Ts advance method, 0 = advanced through raft command, 1 = advanced through store RPC"
)
.unwrap();
}