blob: 6533c694cabfc841b7ccf6c9cc2329aaa3ef6947 (
plain)
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
|
// SPDX-License-Identifier: GPL-3.0-or-later
package cassandra
// https://cassandra.apache.org/doc/latest/cassandra/operating/metrics.html#table-metrics
// https://www.datadoghq.com/blog/how-to-collect-cassandra-metrics/
// https://docs.opennms.com/horizon/29/deployment/time-series-storage/newts/cassandra-jmx.html
func newCassandraMetrics() *cassandraMetrics {
return &cassandraMetrics{
threadPools: make(map[string]*threadPoolMetrics),
}
}
type cassandraMetrics struct {
clientReqTotalLatencyReads metricValue
clientReqTotalLatencyWrites metricValue
clientReqLatencyReads metricValue
clientReqLatencyWrites metricValue
clientReqTimeoutsReads metricValue
clientReqTimeoutsWrites metricValue
clientReqUnavailablesReads metricValue
clientReqUnavailablesWrites metricValue
clientReqFailuresReads metricValue
clientReqFailuresWrites metricValue
clientReqReadLatencyP50 metricValue
clientReqReadLatencyP75 metricValue
clientReqReadLatencyP95 metricValue
clientReqReadLatencyP98 metricValue
clientReqReadLatencyP99 metricValue
clientReqReadLatencyP999 metricValue
clientReqWriteLatencyP50 metricValue
clientReqWriteLatencyP75 metricValue
clientReqWriteLatencyP95 metricValue
clientReqWriteLatencyP98 metricValue
clientReqWriteLatencyP99 metricValue
clientReqWriteLatencyP999 metricValue
rowCacheHits metricValue
rowCacheMisses metricValue
rowCacheCapacity metricValue
rowCacheSize metricValue
keyCacheHits metricValue
keyCacheMisses metricValue
keyCacheCapacity metricValue
keyCacheSize metricValue
// https://cassandra.apache.org/doc/latest/cassandra/operating/metrics.html#dropped-metrics
droppedMessages metricValue
// https://cassandra.apache.org/doc/latest/cassandra/operating/metrics.html#storage-metrics
storageLoad metricValue
storageExceptions metricValue
// https://cassandra.apache.org/doc/latest/cassandra/operating/metrics.html#compaction-metrics
compactionBytesCompacted metricValue
compactionPendingTasks metricValue
compactionCompletedTasks metricValue
// https://cassandra.apache.org/doc/latest/cassandra/operating/metrics.html#memory
jvmMemoryHeapUsed metricValue
jvmMemoryNonHeapUsed metricValue
// https://cassandra.apache.org/doc/latest/cassandra/operating/metrics.html#garbagecollector
jvmGCParNewCount metricValue
jvmGCParNewTime metricValue
jvmGCCMSCount metricValue
jvmGCCMSTime metricValue
threadPools map[string]*threadPoolMetrics
}
type threadPoolMetrics struct {
name string
hasCharts bool
activeTasks metricValue
pendingTasks metricValue
blockedTasks metricValue
totalBlockedTasks metricValue
}
type metricValue struct {
isSet bool
value float64
}
func (mv *metricValue) add(v float64) {
mv.isSet = true
mv.value += v
}
func (mv *metricValue) write(mx map[string]int64, key string) {
if mv.isSet {
mx[key] = int64(mv.value)
}
}
func (mv *metricValue) write1k(mx map[string]int64, key string) {
if mv.isSet {
mx[key] = int64(mv.value * 1000)
}
}
|
