forked from ava-labs/avalanchego
-
Notifications
You must be signed in to change notification settings - Fork 0
/
metrics.go
85 lines (78 loc) · 2.7 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
75
76
77
78
79
80
81
82
83
84
85
// (c) 2019-2020, Ava Labs, Inc. All rights reserved.
// See the file LICENSE for licensing terms.
package snowman
import (
"github.com/prometheus/client_golang/prometheus"
"github.com/ava-labs/gecko/utils/logging"
)
type metrics struct {
numPendingRequests, numBlocked prometheus.Gauge
numBootstrapped, numDropped prometheus.Counter
numPolls, numBlkRequests, numBlockedBlk prometheus.Gauge
}
// Initialize implements the Engine interface
func (m *metrics) Initialize(log logging.Logger, namespace string, registerer prometheus.Registerer) {
m.numPendingRequests = prometheus.NewGauge(
prometheus.GaugeOpts{
Namespace: namespace,
Name: "sm_bs_requests",
Help: "Number of pending bootstrap requests",
})
m.numBlocked = prometheus.NewGauge(
prometheus.GaugeOpts{
Namespace: namespace,
Name: "sm_bs_blocked",
Help: "Number of blocked bootstrap blocks",
})
m.numBootstrapped = prometheus.NewCounter(
prometheus.CounterOpts{
Namespace: namespace,
Name: "sm_bs_accepted",
Help: "Number of accepted bootstrap blocks",
})
m.numDropped = prometheus.NewCounter(
prometheus.CounterOpts{
Namespace: namespace,
Name: "sm_bs_dropped",
Help: "Number of dropped bootstrap blocks",
})
m.numPolls = prometheus.NewGauge(
prometheus.GaugeOpts{
Namespace: namespace,
Name: "sm_polls",
Help: "Number of pending network polls",
})
m.numBlkRequests = prometheus.NewGauge(
prometheus.GaugeOpts{
Namespace: namespace,
Name: "sm_blk_requests",
Help: "Number of pending vertex requests",
})
m.numBlockedBlk = prometheus.NewGauge(
prometheus.GaugeOpts{
Namespace: namespace,
Name: "sm_blocked_blks",
Help: "Number of blocked vertices",
})
if err := registerer.Register(m.numPendingRequests); err != nil {
log.Error("Failed to register sm_bs_requests statistics due to %s", err)
}
if err := registerer.Register(m.numBlocked); err != nil {
log.Error("Failed to register sm_bs_blocked statistics due to %s", err)
}
if err := registerer.Register(m.numBootstrapped); err != nil {
log.Error("Failed to register sm_bs_accepted statistics due to %s", err)
}
if err := registerer.Register(m.numDropped); err != nil {
log.Error("Failed to register sm_bs_dropped statistics due to %s", err)
}
if err := registerer.Register(m.numPolls); err != nil {
log.Error("Failed to register sm_polls statistics due to %s", err)
}
if err := registerer.Register(m.numBlkRequests); err != nil {
log.Error("Failed to register sm_blk_requests statistics due to %s", err)
}
if err := registerer.Register(m.numBlockedBlk); err != nil {
log.Error("Failed to register sm_blocked_blks statistics due to %s", err)
}
}