/
metrics.go
217 lines (207 loc) · 7.53 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
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
package localstore
import (
m "github.com/FavorLabs/favorX/pkg/metrics"
"github.com/prometheus/client_golang/prometheus"
)
type metrics struct {
TotalTimeGCLock prometheus.Counter
TotalTimeGCFirstItem prometheus.Counter
TotalTimeCollectGarbage prometheus.Counter
TotalTimeGet prometheus.Counter
TotalTimeUpdateGC prometheus.Counter
TotalTimeGetMulti prometheus.Counter
TotalTimeHas prometheus.Counter
TotalTimeHasMulti prometheus.Counter
TotalTimePut prometheus.Counter
TotalTimeSet prometheus.Counter
GCCounter prometheus.Counter
GCErrorCounter prometheus.Counter
GCCollectedCounter prometheus.Counter
GCCommittedCounter prometheus.Counter
GCUpdate prometheus.Counter
GCUpdateError prometheus.Counter
ModeGet prometheus.Counter
ModeGetFailure prometheus.Counter
ModeGetMulti prometheus.Counter
ModeGetMultiChunks prometheus.Counter
ModeGetMultiFailure prometheus.Counter
ModePut prometheus.Counter
ModePutFailure prometheus.Counter
ModeSet prometheus.Counter
ModeSetFailure prometheus.Counter
ModeHas prometheus.Counter
ModeHasFailure prometheus.Counter
ModeHasMulti prometheus.Counter
ModeHasMultiFailure prometheus.Counter
GCSize prometheus.Gauge
GCStoreTimeStamps prometheus.Gauge
GCStoreAccessTimeStamps prometheus.Gauge
}
func newMetrics() metrics {
subsystem := "localstore"
return metrics{
TotalTimeGCLock: prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: subsystem,
Name: "gc_lock_time",
Help: "Total time under lock in gc.",
}),
TotalTimeGCFirstItem: prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: subsystem,
Name: "gc_first_item_time",
Help: "Total time taken till first item in gc comes out of gcIndex iterator.",
}),
TotalTimeCollectGarbage: prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: subsystem,
Name: "gc_time",
Help: "Total time taken to collect garbage.",
}),
TotalTimeGet: prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: subsystem,
Name: "get_chunk_time",
Help: "Total time taken to get chunk from DB.",
}),
TotalTimeUpdateGC: prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: subsystem,
Name: "in_gc_time",
Help: "Total time taken to in gc.",
}),
TotalTimeGetMulti: prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: subsystem,
Name: "get_multi_time",
Help: "Total time taken to get multiple chunks from DB.",
}),
TotalTimeHas: prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: subsystem,
Name: "has_time",
Help: "Total time taken to check if the key is present in DB.",
}),
TotalTimeHasMulti: prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: subsystem,
Name: "has_multi_time",
Help: "Total time taken to check if multiple keys are present in DB.",
}),
TotalTimePut: prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: subsystem,
Name: "put_time",
Help: "Total time taken to put a chunk in DB.",
}),
TotalTimeSet: prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: subsystem,
Name: "set_time",
Help: "Total time taken to set chunk in DB.",
}),
GCCounter: prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: subsystem,
Name: "gc_count",
Help: "Number of times the GC operation is done.",
}),
GCErrorCounter: prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: subsystem,
Name: "gc_fail_count",
Help: "Number of times the GC operation failed.",
}),
GCCollectedCounter: prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: subsystem,
Name: "gc_collected_count",
Help: "Number of times the GC_COLLECTED operation is done.",
}),
GCCommittedCounter: prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: subsystem,
Name: "gc_committed_count",
Help: "Number of gc items to commit.",
}),
GCUpdate: prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: subsystem,
Name: "gc_update_count",
Help: "Number of times the gc is updated.",
}),
GCUpdateError: prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: subsystem,
Name: "gc_update_error_count",
Help: "Number of times the gc update had error.",
}),
ModeGet: prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: subsystem,
Name: "mode_get_count",
Help: "Number of times MODE_GET is invoked.",
}),
ModeGetFailure: prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: subsystem,
Name: "mode_get_failure_count",
Help: "Number of times MODE_GET invocation failed.",
}),
ModeGetMulti: prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: subsystem,
Name: "mode_get_multi_count",
Help: "Number of times MODE_MULTI_GET is invoked.",
}),
ModeGetMultiChunks: prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: subsystem,
Name: "mode_get_multi_chunks_count",
Help: "Number of chunks requested through MODE_MULTI_GET.",
}),
ModeGetMultiFailure: prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: subsystem,
Name: "mode_get_multi_failure_count",
Help: "Number of times MODE_GET invocation failed.",
}),
ModePut: prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: subsystem,
Name: "mode_put_count",
Help: "Number of times MODE_PUT is invoked.",
}),
ModePutFailure: prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: subsystem,
Name: "mode_put_failure_count",
Help: "Number of times MODE_PUT invocation failed.",
}),
ModeSet: prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: subsystem,
Name: "mode_set_count",
Help: "Number of times MODE_SET is invoked.",
}),
ModeSetFailure: prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: subsystem,
Name: "mode_set_failure_count",
Help: "Number of times MODE_SET invocation failed.",
}),
ModeHas: prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: subsystem,
Name: "mode_has_count",
Help: "Number of times MODE_HAS is invoked.",
}),
ModeHasFailure: prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: subsystem,
Name: "mode_has_failure_count",
Help: "Number of times MODE_HAS invocation failed.",
}),
ModeHasMulti: prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: subsystem,
Name: "mode_has_multi_count",
Help: "Number of times MODE_HAS_MULTI is invoked.",
}),
ModeHasMultiFailure: prometheus.NewCounter(prometheus.CounterOpts{
Subsystem: subsystem,
Name: "mode_has_multi_failure_count",
Help: "Number of times MODE_HAS_MULTI invocation failed.",
}),
GCSize: prometheus.NewGauge(prometheus.GaugeOpts{
Subsystem: subsystem,
Name: "gc_size",
Help: "Number of elements in Garbage collection index.",
}),
GCStoreTimeStamps: prometheus.NewGauge(prometheus.GaugeOpts{
Subsystem: subsystem,
Name: "gc_time_stamp",
Help: "Storage timestamp in Garbage collection iteration.",
}),
GCStoreAccessTimeStamps: prometheus.NewGauge(prometheus.GaugeOpts{
Subsystem: subsystem,
Name: "gc_access_time_stamp",
Help: "Access timestamp in Garbage collection iteration.",
}),
}
}
func (db *DB) Metrics() []prometheus.Collector {
return m.PrometheusCollectorsFromFields(db.metrics)
}