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
|
// SPDX-License-Identifier: GPL-3.0-or-later
package mongo
import (
"fmt"
"reflect"
"github.com/netdata/netdata/go/go.d.plugin/agent/module"
"github.com/netdata/netdata/go/go.d.plugin/pkg/stm"
)
// collectServerStatus creates the map[string]int64 for the available dims.
// nil values will be ignored and not added to the map and thus metrics should not appear on the dashboard.
// Because mongo reports a metric only after it first appears,some dims might take a while to appear.
// For example, in order to report number of create commands, a document must be created first.
func (m *Mongo) collectServerStatus(mx map[string]int64) error {
s, err := m.conn.serverStatus()
if err != nil {
return fmt.Errorf("serverStatus command failed: %s", err)
}
m.addOptionalCharts(s)
for k, v := range stm.ToMap(s) {
mx[k] = v
}
if s.Transactions != nil && s.Transactions.CommitTypes != nil {
px := "txn_commit_types_"
v := s.Transactions.CommitTypes
mx[px+"no_shards_unsuccessful"] = v.NoShards.Initiated - v.NoShards.Successful
mx[px+"single_shard_unsuccessful"] = v.SingleShard.Initiated - v.SingleShard.Successful
mx[px+"single_write_shard_unsuccessful"] = v.SingleWriteShard.Initiated - v.SingleWriteShard.Successful
mx[px+"read_only_unsuccessful"] = v.ReadOnly.Initiated - v.ReadOnly.Successful
mx[px+"two_phase_commit_unsuccessful"] = v.TwoPhaseCommit.Initiated - v.TwoPhaseCommit.Successful
mx[px+"recover_with_token_unsuccessful"] = v.RecoverWithToken.Initiated - v.RecoverWithToken.Successful
}
return nil
}
func (m *Mongo) addOptionalCharts(s *documentServerStatus) {
m.addOptionalChart(s.OpLatencies,
&chartOperationsRate,
&chartOperationsLatencyTime,
)
m.addOptionalChart(s.WiredTiger,
&chartWiredTigerConcurrentReadTransactionsUsage,
&chartWiredTigerConcurrentWriteTransactionsUsage,
&chartWiredTigerCacheUsage,
&chartWiredTigerCacheDirtySpaceSize,
&chartWiredTigerCacheIORate,
&chartWiredTigerCacheEvictionsRate,
)
m.addOptionalChart(s.Tcmalloc,
&chartMemoryTCMallocStatsChart,
)
m.addOptionalChart(s.GlobalLock,
&chartGlobalLockActiveClientsCount,
&chartGlobalLockCurrentQueueCount,
)
m.addOptionalChart(s.Network.NumSlowDNSOperations,
&chartNetworkSlowDNSResolutionsRate,
)
m.addOptionalChart(s.Network.NumSlowSSLOperations,
&chartNetworkSlowSSLHandshakesRate,
)
m.addOptionalChart(s.Metrics.Cursor.TotalOpened,
&chartCursorsOpenedRate,
)
m.addOptionalChart(s.Metrics.Cursor.TimedOut,
&chartCursorsTimedOutRate,
)
m.addOptionalChart(s.Metrics.Cursor.Open.Total,
&chartCursorsOpenCount,
)
m.addOptionalChart(s.Metrics.Cursor.Open.NoTimeout,
&chartCursorsOpenNoTimeoutCount,
)
m.addOptionalChart(s.Metrics.Cursor.Lifespan,
&chartCursorsByLifespanCount,
)
if s.Transactions != nil {
m.addOptionalChart(s.Transactions,
&chartTransactionsCount,
&chartTransactionsRate,
)
m.addOptionalChart(s.Transactions.CommitTypes,
&chartTransactionsNoShardsCommitsRate,
&chartTransactionsNoShardsCommitsDurationTime,
&chartTransactionsSingleShardCommitsRate,
&chartTransactionsSingleShardCommitsDurationTime,
&chartTransactionsSingleWriteShardCommitsRate,
&chartTransactionsSingleWriteShardCommitsDurationTime,
&chartTransactionsReadOnlyCommitsRate,
&chartTransactionsReadOnlyCommitsDurationTime,
&chartTransactionsTwoPhaseCommitCommitsRate,
&chartTransactionsTwoPhaseCommitCommitsDurationTime,
&chartTransactionsRecoverWithTokenCommitsRate,
&chartTransactionsRecoverWithTokenCommitsDurationTime,
)
}
if s.Locks != nil {
m.addOptionalChart(s.Locks.Global, &chartGlobalLockAcquisitionsRate)
m.addOptionalChart(s.Locks.Database, &chartDatabaseLockAcquisitionsRate)
m.addOptionalChart(s.Locks.Collection, &chartCollectionLockAcquisitionsRate)
m.addOptionalChart(s.Locks.Mutex, &chartMutexLockAcquisitionsRate)
m.addOptionalChart(s.Locks.Metadata, &chartMetadataLockAcquisitionsRate)
m.addOptionalChart(s.Locks.Oplog, &chartOpLogLockAcquisitionsRate)
}
}
func (m *Mongo) addOptionalChart(iface any, charts ...*module.Chart) {
if reflect.ValueOf(iface).IsNil() {
return
}
for _, chart := range charts {
if m.optionalCharts[chart.ID] {
continue
}
m.optionalCharts[chart.ID] = true
if err := m.charts.Add(chart.Copy()); err != nil {
m.Warning(err)
}
}
}
|
