influx/telegraf
1
0
Fork 0
Code Issues Activity
telegraf/plugins/inputs/mongodb/mongostat_test.go
Daniel Baumann 4978089aab
Adding upstream version 1.34.4. 
Signed-off-by: Daniel Baumann <daniel@debian.org>
2025-05-24 07:26:29 +02:00

597 lines
12 KiB
Go
Raw Permalink Blame History

package mongodb
import (
"testing"
"github.com/stretchr/testify/require"
)
func TestLatencyStats(t *testing.T) {
sl := newStatLine(
mongoStatus{
ServerStatus: &serverStatus{
Connections: &connectionStats{},
Mem: &memStats{
Bits: 0,
Resident: 0,
Virtual: 0,
Supported: false,
Mapped: 0,
MappedWithJournal: 0,
},
},
},
mongoStatus{
ServerStatus: &serverStatus{
Connections: &connectionStats{},
Mem: &memStats{
Bits: 0,
Resident: 0,
Virtual: 0,
Supported: false,
Mapped: 0,
MappedWithJournal: 0,
},
OpLatencies: &opLatenciesStats{
Reads: &latencyStats{
Ops: 0,
Latency: 0,
},
Writes: &latencyStats{
Ops: 0,
Latency: 0,
},
Commands: &latencyStats{
Ops: 0,
Latency: 0,
},
},
},
},
"foo",
60,
)
require.Equal(t, int64(0), sl.CommandLatency)
require.Equal(t, int64(0), sl.ReadLatency)
require.Equal(t, int64(0), sl.WriteLatency)
require.Equal(t, int64(0), sl.CommandOpsCnt)
require.Equal(t, int64(0), sl.ReadOpsCnt)
require.Equal(t, int64(0), sl.WriteOpsCnt)
}
func TestLatencyStatsDiffZero(t *testing.T) {
sl := newStatLine(
mongoStatus{
ServerStatus: &serverStatus{
Connections: &connectionStats{},
Mem: &memStats{
Bits: 0,
Resident: 0,
Virtual: 0,
Supported: false,
Mapped: 0,
MappedWithJournal: 0,
},
OpLatencies: &opLatenciesStats{
Reads: &latencyStats{
Ops: 0,
Latency: 0,
},
Writes: &latencyStats{
Ops: 0,
Latency: 0,
},
Commands: &latencyStats{
Ops: 0,
Latency: 0,
},
},
},
},
mongoStatus{
ServerStatus: &serverStatus{
Connections: &connectionStats{},
Mem: &memStats{
Bits: 0,
Resident: 0,
Virtual: 0,
Supported: false,
Mapped: 0,
MappedWithJournal: 0,
},
OpLatencies: &opLatenciesStats{
Reads: &latencyStats{
Ops: 0,
Latency: 0,
},
Writes: &latencyStats{
Ops: 0,
Latency: 0,
},
Commands: &latencyStats{
Ops: 0,
Latency: 0,
},
},
},
},
"foo",
60,
)
require.Equal(t, int64(0), sl.CommandLatency)
require.Equal(t, int64(0), sl.ReadLatency)
require.Equal(t, int64(0), sl.WriteLatency)
require.Equal(t, int64(0), sl.CommandOpsCnt)
require.Equal(t, int64(0), sl.ReadOpsCnt)
require.Equal(t, int64(0), sl.WriteOpsCnt)
}
func TestLatencyStatsDiff(t *testing.T) {
sl := newStatLine(
mongoStatus{
ServerStatus: &serverStatus{
Connections: &connectionStats{},
Mem: &memStats{
Bits: 0,
Resident: 0,
Virtual: 0,
Supported: false,
Mapped: 0,
MappedWithJournal: 0,
},
OpLatencies: &opLatenciesStats{
Reads: &latencyStats{
Ops: 4189041956,
Latency: 2255922322753,
},
Writes: &latencyStats{
Ops: 1691019457,
Latency: 494478256915,
},
Commands: &latencyStats{
Ops: 1019150402,
Latency: 59177710371,
},
},
},
},
mongoStatus{
ServerStatus: &serverStatus{
Connections: &connectionStats{},
Mem: &memStats{
Bits: 0,
Resident: 0,
Virtual: 0,
Supported: false,
Mapped: 0,
MappedWithJournal: 0,
},
OpLatencies: &opLatenciesStats{
Reads: &latencyStats{
Ops: 4189049884,
Latency: 2255946760057,
},
Writes: &latencyStats{
Ops: 1691021287,
Latency: 494479456987,
},
Commands: &latencyStats{
Ops: 1019152861,
Latency: 59177981552,
},
},
},
},
"foo",
60,
)
require.Equal(t, int64(59177981552), sl.CommandLatency)
require.Equal(t, int64(2255946760057), sl.ReadLatency)
require.Equal(t, int64(494479456987), sl.WriteLatency)
require.Equal(t, int64(1019152861), sl.CommandOpsCnt)
require.Equal(t, int64(4189049884), sl.ReadOpsCnt)
require.Equal(t, int64(1691021287), sl.WriteOpsCnt)
}
func TestLocksStatsNilWhenLocksMissingInOldStat(t *testing.T) {
sl := newStatLine(
mongoStatus{
ServerStatus: &serverStatus{
Connections: &connectionStats{},
Mem: &memStats{
Supported: false,
},
},
},
mongoStatus{
ServerStatus: &serverStatus{
Connections: &connectionStats{},
Mem: &memStats{
Supported: false,
},
Locks: map[string]lockStats{
"Global": {
AcquireCount: &readWriteLockTimes{},
},
},
},
},
"foo",
60,
)
require.Nil(t, sl.CollectionLocks)
}
func TestLocksStatsNilWhenGlobalLockStatsMissingInOldStat(t *testing.T) {
sl := newStatLine(
mongoStatus{
ServerStatus: &serverStatus{
Connections: &connectionStats{},
Mem: &memStats{
Supported: false,
},
Locks: map[string]lockStats{},
},
},
mongoStatus{
ServerStatus: &serverStatus{
Connections: &connectionStats{},
Mem: &memStats{
Supported: false,
},
Locks: map[string]lockStats{
"Global": {
AcquireCount: &readWriteLockTimes{},
},
},
},
},
"foo",
60,
)
require.Nil(t, sl.CollectionLocks)
}
func TestLocksStatsNilWhenGlobalLockStatsEmptyInOldStat(t *testing.T) {
sl := newStatLine(
mongoStatus{
ServerStatus: &serverStatus{
Connections: &connectionStats{},
Mem: &memStats{
Supported: false,
},
Locks: map[string]lockStats{
"Global": {},
},
},
},
mongoStatus{
ServerStatus: &serverStatus{
Connections: &connectionStats{},
Mem: &memStats{
Supported: false,
},
Locks: map[string]lockStats{
"Global": {
AcquireCount: &readWriteLockTimes{},
},
},
},
},
"foo",
60,
)
require.Nil(t, sl.CollectionLocks)
}
func TestLocksStatsNilWhenCollectionLockStatsMissingInOldStat(t *testing.T) {
sl := newStatLine(
mongoStatus{
ServerStatus: &serverStatus{
Connections: &connectionStats{},
Mem: &memStats{
Supported: false,
},
Locks: map[string]lockStats{
"Global": {
AcquireCount: &readWriteLockTimes{},
},
},
},
},
mongoStatus{
ServerStatus: &serverStatus{
Connections: &connectionStats{},
Mem: &memStats{
Supported: false,
},
Locks: map[string]lockStats{
"Global": {
AcquireCount: &readWriteLockTimes{},
},
},
},
},
"foo",
60,
)
require.Nil(t, sl.CollectionLocks)
}
func TestLocksStatsNilWhenCollectionLockStatsEmptyInOldStat(t *testing.T) {
sl := newStatLine(
mongoStatus{
ServerStatus: &serverStatus{
Connections: &connectionStats{},
Mem: &memStats{
Supported: false,
},
Locks: map[string]lockStats{
"Global": {
AcquireCount: &readWriteLockTimes{},
},
"Collection": {},
},
},
},
mongoStatus{
ServerStatus: &serverStatus{
Connections: &connectionStats{},
Mem: &memStats{
Supported: false,
},
Locks: map[string]lockStats{
"Global": {
AcquireCount: &readWriteLockTimes{},
},
},
},
},
"foo",
60,
)
require.Nil(t, sl.CollectionLocks)
}
func TestLocksStatsNilWhenLocksMissingInNewStat(t *testing.T) {
sl := newStatLine(
mongoStatus{
ServerStatus: &serverStatus{
Connections: &connectionStats{},
Mem: &memStats{
Supported: false,
},
Locks: map[string]lockStats{
"Global": {
AcquireCount: &readWriteLockTimes{},
},
},
},
},
mongoStatus{
ServerStatus: &serverStatus{
Connections: &connectionStats{},
Mem: &memStats{
Supported: false,
},
},
},
"foo",
60,
)
require.Nil(t, sl.CollectionLocks)
}
func TestLocksStatsNilWhenGlobalLockStatsMissingInNewStat(t *testing.T) {
sl := newStatLine(
mongoStatus{
ServerStatus: &serverStatus{
Connections: &connectionStats{},
Mem: &memStats{
Supported: false,
},
Locks: map[string]lockStats{
"Global": {
AcquireCount: &readWriteLockTimes{},
},
},
},
},
mongoStatus{
ServerStatus: &serverStatus{
Connections: &connectionStats{},
Mem: &memStats{
Supported: false,
},
Locks: map[string]lockStats{},
},
},
"foo",
60,
)
require.Nil(t, sl.CollectionLocks)
}
func TestLocksStatsNilWhenGlobalLockStatsEmptyInNewStat(t *testing.T) {
sl := newStatLine(
mongoStatus{
ServerStatus: &serverStatus{
Connections: &connectionStats{},
Mem: &memStats{
Supported: false,
},
Locks: map[string]lockStats{
"Global": {
AcquireCount: &readWriteLockTimes{},
},
},
},
},
mongoStatus{
ServerStatus: &serverStatus{
Connections: &connectionStats{},
Mem: &memStats{
Supported: false,
},
Locks: map[string]lockStats{
"Global": {},
},
},
},
"foo",
60,
)
require.Nil(t, sl.CollectionLocks)
}
func TestLocksStatsNilWhenCollectionLockStatsMissingInNewStat(t *testing.T) {
sl := newStatLine(
mongoStatus{
ServerStatus: &serverStatus{
Connections: &connectionStats{},
Mem: &memStats{
Supported: false,
},
Locks: map[string]lockStats{
"Global": {
AcquireCount: &readWriteLockTimes{},
},
},
},
},
mongoStatus{
ServerStatus: &serverStatus{
Connections: &connectionStats{},
Mem: &memStats{
Supported: false,
},
Locks: map[string]lockStats{
"Global": {
AcquireCount: &readWriteLockTimes{},
},
},
},
},
"foo",
60,
)
require.Nil(t, sl.CollectionLocks)
}
func TestLocksStatsNilWhenCollectionLockStatsEmptyInNewStat(t *testing.T) {
sl := newStatLine(
mongoStatus{
ServerStatus: &serverStatus{
Connections: &connectionStats{},
Mem: &memStats{
Supported: false,
},
Locks: map[string]lockStats{
"Global": {
AcquireCount: &readWriteLockTimes{},
},
},
},
},
mongoStatus{
ServerStatus: &serverStatus{
Connections: &connectionStats{},
Mem: &memStats{
Supported: false,
},
Locks: map[string]lockStats{
"Global": {
AcquireCount: &readWriteLockTimes{},
},
"Collection": {},
},
},
},
"foo",
60,
)
require.Nil(t, sl.CollectionLocks)
}
func TestLocksStatsPopulated(t *testing.T) {
sl := newStatLine(
mongoStatus{
ServerStatus: &serverStatus{
Connections: &connectionStats{},
Mem: &memStats{
Supported: false,
},
Locks: map[string]lockStats{
"Global": {
AcquireCount: &readWriteLockTimes{},
},
"Collection": {
AcquireWaitCount: &readWriteLockTimes{
Read: 1,
Write: 2,
},
AcquireCount: &readWriteLockTimes{
Read: 5,
Write: 10,
},
TimeAcquiringMicros: readWriteLockTimes{
Read: 100,
Write: 200,
},
},
},
},
},
mongoStatus{
ServerStatus: &serverStatus{
Connections: &connectionStats{},
Mem: &memStats{
Supported: false,
},
Locks: map[string]lockStats{
"Global": {
AcquireCount: &readWriteLockTimes{},
},
"Collection": {
AcquireWaitCount: &readWriteLockTimes{
Read: 2,
Write: 4,
},
AcquireCount: &readWriteLockTimes{
Read: 10,
Write: 30,
},
TimeAcquiringMicros: readWriteLockTimes{
Read: 250,
Write: 310,
},
},
},
},
},
"foo",
60,
)
expected := &collectionLockStatus{
ReadAcquireWaitsPercentage: 20,
WriteAcquireWaitsPercentage: 10,
ReadAcquireTimeMicros: 150,
WriteAcquireTimeMicros: 55,
}
require.Equal(t, expected, sl.CollectionLocks)
}
View git blame Copy permalink