-
Notifications
You must be signed in to change notification settings - Fork 171
/
metrics.go
74 lines (64 loc) · 2.33 KB
/
metrics.go
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
package metrics
import (
"github.com/prometheus/client_golang/prometheus"
"github.com/moiot/gravity/pkg/metrics"
)
var (
WorkerPoolWorkerCountGauge = prometheus.NewGaugeVec(prometheus.GaugeOpts{
Namespace: "drc_v2",
Subsystem: "scheduler_worker_pool",
Name: "nr_worker",
Help: "number of workers",
}, []string{metrics.PipelineTag})
WorkerPoolQueueSizeGauge = prometheus.NewGaugeVec(prometheus.GaugeOpts{
Namespace: "drc_v2",
Subsystem: "scheduler_worker_pool",
Name: "queue_size",
Help: "size of queue",
}, []string{metrics.PipelineTag, "idx"})
WorkerPoolProcessedMsgCount = prometheus.NewCounterVec(prometheus.CounterOpts{
Namespace: "drc_v2",
Subsystem: "scheduler_worker_pool",
Name: "processed_msg_count",
Help: "processed msg count of worker",
}, []string{metrics.PipelineTag})
WorkerPoolMsgExecLatency = prometheus.NewHistogramVec(prometheus.HistogramOpts{
Namespace: "drc_v2",
Subsystem: "scheduler_worker_pool",
Name: "msg_exec_latency",
Help: "latency of process a message",
Buckets: prometheus.ExponentialBuckets(0.001, 3, 10),
}, []string{metrics.PipelineTag})
//
// batch scheduler specific metrics
//
WorkerPoolJobBatchSizeGauge = prometheus.NewGaugeVec(prometheus.GaugeOpts{
Namespace: "drc_v2",
Subsystem: "scheduler_worker_pool",
Name: "batch_size",
Help: "batch size",
}, []string{metrics.PipelineTag, "idx"})
WorkerPoolSlidingWindowSize = prometheus.NewGaugeVec(
prometheus.GaugeOpts{
Namespace: "drc_v2",
Subsystem: "scheduler_worker_pool",
Name: "sliding_window_size",
Help: "sliding window size",
}, []string{metrics.PipelineTag, "input_stream_key"})
WorkerPoolSlidingWindowRatio = prometheus.NewGaugeVec(
prometheus.GaugeOpts{
Namespace: "drc_v2",
Subsystem: "scheduler_worker_pool",
Name: "sliding_window_ratio",
Help: "sliding window ratio",
}, []string{metrics.PipelineTag, "input_stream_key"})
)
func init() {
prometheus.MustRegister(WorkerPoolWorkerCountGauge)
prometheus.MustRegister(WorkerPoolQueueSizeGauge)
prometheus.MustRegister(WorkerPoolProcessedMsgCount)
prometheus.MustRegister(WorkerPoolMsgExecLatency)
prometheus.MustRegister(WorkerPoolJobBatchSizeGauge)
prometheus.MustRegister(WorkerPoolSlidingWindowSize)
prometheus.MustRegister(WorkerPoolSlidingWindowRatio)
}