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
use lazy_static::lazy_static;
use prometheus::*;
lazy_static! {
pub static ref PD_REQUEST_HISTOGRAM_VEC: HistogramVec = register_histogram_vec!(
"tikv_pd_request_duration_seconds",
"Bucketed histogram of PD requests duration",
&["type"]
)
.unwrap();
pub static ref PD_HEARTBEAT_COUNTER_VEC: IntCounterVec = register_int_counter_vec!(
"tikv_pd_heartbeat_message_total",
"Total number of PD heartbeat messages.",
&["type"]
)
.unwrap();
pub static ref PD_RECONNECT_COUNTER_VEC: IntCounterVec = register_int_counter_vec!(
"tikv_pd_reconnect_total",
"Total number of PD reconnections.",
&["type"]
)
.unwrap();
pub static ref PD_PENDING_HEARTBEAT_GAUGE: IntGauge = register_int_gauge!(
"tikv_pd_pending_heartbeat_total",
"Total number of pending region heartbeat"
)
.unwrap();
pub static ref PD_VALIDATE_PEER_COUNTER_VEC: IntCounterVec = register_int_counter_vec!(
"tikv_pd_validate_peer_total",
"Total number of pd worker validate peer task.",
&["type"]
)
.unwrap();
pub static ref STORE_SIZE_GAUGE_VEC: IntGaugeVec =
register_int_gauge_vec!("tikv_store_size_bytes", "Size of storage.", &["type"]).unwrap();
pub static ref REGION_READ_KEYS_HISTOGRAM: Histogram = register_histogram!(
"tikv_region_read_keys",
"Histogram of keys written for regions",
exponential_buckets(1.0, 2.0, 20).unwrap()
)
.unwrap();
pub static ref REGION_READ_BYTES_HISTOGRAM: Histogram = register_histogram!(
"tikv_region_read_bytes",
"Histogram of bytes written for regions",
exponential_buckets(256.0, 2.0, 20).unwrap()
)
.unwrap();
pub static ref REGION_WRITTEN_BYTES_HISTOGRAM: Histogram = register_histogram!(
"tikv_region_written_bytes",
"Histogram of bytes written for regions",
exponential_buckets(256.0, 2.0, 20).unwrap()
)
.unwrap();
pub static ref REGION_WRITTEN_KEYS_HISTOGRAM: Histogram = register_histogram!(
"tikv_region_written_keys",
"Histogram of keys written for regions",
exponential_buckets(1.0, 2.0, 20).unwrap()
)
.unwrap();
pub static ref REQUEST_FORWARDED_GAUGE_VEC: IntGaugeVec = register_int_gauge_vec!(
"tikv_pd_request_forwarded",
"The status to indicate if the request is forwarded",
&["host"]
)
.unwrap();
}