330 lines
9.1 KiB
Go
330 lines
9.1 KiB
Go
package openntpd
|
|
|
|
import (
|
|
"bytes"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/influxdata/telegraf/internal"
|
|
"github.com/influxdata/telegraf/testutil"
|
|
"github.com/stretchr/testify/assert"
|
|
)
|
|
|
|
var TestTimeout = internal.Duration{Duration: time.Second}
|
|
|
|
func OpenntpdCTL(output string, Timeout internal.Duration, useSudo bool) func(string, internal.Duration, bool) (*bytes.Buffer, error) {
|
|
return func(string, internal.Duration, bool) (*bytes.Buffer, error) {
|
|
return bytes.NewBuffer([]byte(output)), nil
|
|
}
|
|
}
|
|
|
|
func TestParseSimpleOutput(t *testing.T) {
|
|
acc := &testutil.Accumulator{}
|
|
v := &Openntpd{
|
|
run: OpenntpdCTL(simpleOutput, TestTimeout, false),
|
|
}
|
|
err := v.Gather(acc)
|
|
|
|
assert.NoError(t, err)
|
|
assert.True(t, acc.HasMeasurement("openntpd"))
|
|
assert.Equal(t, acc.NMetrics(), uint64(1))
|
|
|
|
assert.Equal(t, acc.NFields(), 7)
|
|
|
|
firstpeerfields := map[string]interface{}{
|
|
"wt": int64(1),
|
|
"tl": int64(10),
|
|
"next": int64(56),
|
|
"poll": int64(63),
|
|
"offset": float64(9.271),
|
|
"delay": float64(44.662),
|
|
"jitter": float64(2.678),
|
|
}
|
|
|
|
firstpeertags := map[string]string{
|
|
"remote": "212.129.9.36",
|
|
"stratum": "3",
|
|
}
|
|
|
|
acc.AssertContainsTaggedFields(t, "openntpd", firstpeerfields, firstpeertags)
|
|
}
|
|
|
|
func TestParseSimpleOutputwithStatePrefix(t *testing.T) {
|
|
acc := &testutil.Accumulator{}
|
|
v := &Openntpd{
|
|
run: OpenntpdCTL(simpleOutputwithStatePrefix, TestTimeout, false),
|
|
}
|
|
err := v.Gather(acc)
|
|
|
|
assert.NoError(t, err)
|
|
assert.True(t, acc.HasMeasurement("openntpd"))
|
|
assert.Equal(t, acc.NMetrics(), uint64(1))
|
|
|
|
assert.Equal(t, acc.NFields(), 7)
|
|
|
|
firstpeerfields := map[string]interface{}{
|
|
"wt": int64(1),
|
|
"tl": int64(10),
|
|
"next": int64(45),
|
|
"poll": int64(980),
|
|
"offset": float64(-9.901),
|
|
"delay": float64(67.573),
|
|
"jitter": float64(29.350),
|
|
}
|
|
|
|
firstpeertags := map[string]string{
|
|
"remote": "92.243.6.5",
|
|
"stratum": "2",
|
|
"state_prefix": "*",
|
|
}
|
|
|
|
acc.AssertContainsTaggedFields(t, "openntpd", firstpeerfields, firstpeertags)
|
|
}
|
|
|
|
func TestParseSimpleOutputInvalidPeer(t *testing.T) {
|
|
acc := &testutil.Accumulator{}
|
|
v := &Openntpd{
|
|
run: OpenntpdCTL(simpleOutputInvalidPeer, TestTimeout, false),
|
|
}
|
|
err := v.Gather(acc)
|
|
|
|
assert.NoError(t, err)
|
|
assert.True(t, acc.HasMeasurement("openntpd"))
|
|
assert.Equal(t, acc.NMetrics(), uint64(1))
|
|
|
|
assert.Equal(t, acc.NFields(), 4)
|
|
|
|
firstpeerfields := map[string]interface{}{
|
|
"wt": int64(1),
|
|
"tl": int64(2),
|
|
"next": int64(203),
|
|
"poll": int64(300),
|
|
}
|
|
|
|
firstpeertags := map[string]string{
|
|
"remote": "178.33.111.49",
|
|
"stratum": "-",
|
|
}
|
|
|
|
acc.AssertContainsTaggedFields(t, "openntpd", firstpeerfields, firstpeertags)
|
|
}
|
|
|
|
func TestParseSimpleOutputServersDNSError(t *testing.T) {
|
|
acc := &testutil.Accumulator{}
|
|
v := &Openntpd{
|
|
run: OpenntpdCTL(simpleOutputServersDNSError, TestTimeout, false),
|
|
}
|
|
err := v.Gather(acc)
|
|
|
|
assert.NoError(t, err)
|
|
assert.True(t, acc.HasMeasurement("openntpd"))
|
|
assert.Equal(t, acc.NMetrics(), uint64(1))
|
|
|
|
assert.Equal(t, acc.NFields(), 4)
|
|
|
|
firstpeerfields := map[string]interface{}{
|
|
"next": int64(2),
|
|
"poll": int64(15),
|
|
"wt": int64(1),
|
|
"tl": int64(2),
|
|
}
|
|
|
|
firstpeertags := map[string]string{
|
|
"remote": "pool.nl.ntp.org",
|
|
"stratum": "-",
|
|
}
|
|
|
|
acc.AssertContainsTaggedFields(t, "openntpd", firstpeerfields, firstpeertags)
|
|
|
|
secondpeerfields := map[string]interface{}{
|
|
"next": int64(2),
|
|
"poll": int64(15),
|
|
"wt": int64(1),
|
|
"tl": int64(2),
|
|
}
|
|
|
|
secondpeertags := map[string]string{
|
|
"remote": "pool.nl.ntp.org",
|
|
"stratum": "-",
|
|
}
|
|
|
|
acc.AssertContainsTaggedFields(t, "openntpd", secondpeerfields, secondpeertags)
|
|
}
|
|
|
|
func TestParseSimpleOutputServerDNSError(t *testing.T) {
|
|
acc := &testutil.Accumulator{}
|
|
v := &Openntpd{
|
|
run: OpenntpdCTL(simpleOutputServerDNSError, TestTimeout, false),
|
|
}
|
|
err := v.Gather(acc)
|
|
|
|
assert.NoError(t, err)
|
|
assert.True(t, acc.HasMeasurement("openntpd"))
|
|
assert.Equal(t, acc.NMetrics(), uint64(1))
|
|
|
|
assert.Equal(t, acc.NFields(), 4)
|
|
|
|
firstpeerfields := map[string]interface{}{
|
|
"next": int64(12),
|
|
"poll": int64(15),
|
|
"wt": int64(1),
|
|
"tl": int64(2),
|
|
}
|
|
|
|
firstpeertags := map[string]string{
|
|
"remote": "pool.fr.ntp.org",
|
|
"stratum": "-",
|
|
}
|
|
|
|
acc.AssertContainsTaggedFields(t, "openntpd", firstpeerfields, firstpeertags)
|
|
}
|
|
|
|
func TestParseFullOutput(t *testing.T) {
|
|
acc := &testutil.Accumulator{}
|
|
v := &Openntpd{
|
|
run: OpenntpdCTL(fullOutput, TestTimeout, false),
|
|
}
|
|
err := v.Gather(acc)
|
|
|
|
assert.NoError(t, err)
|
|
assert.True(t, acc.HasMeasurement("openntpd"))
|
|
assert.Equal(t, acc.NMetrics(), uint64(20))
|
|
|
|
assert.Equal(t, acc.NFields(), 113)
|
|
|
|
firstpeerfields := map[string]interface{}{
|
|
"wt": int64(1),
|
|
"tl": int64(10),
|
|
"next": int64(56),
|
|
"poll": int64(63),
|
|
"offset": float64(9.271),
|
|
"delay": float64(44.662),
|
|
"jitter": float64(2.678),
|
|
}
|
|
|
|
firstpeertags := map[string]string{
|
|
"remote": "212.129.9.36",
|
|
"stratum": "3",
|
|
}
|
|
|
|
acc.AssertContainsTaggedFields(t, "openntpd", firstpeerfields, firstpeertags)
|
|
|
|
secondpeerfields := map[string]interface{}{
|
|
"wt": int64(1),
|
|
"tl": int64(10),
|
|
"next": int64(21),
|
|
"poll": int64(64),
|
|
"offset": float64(-0.103),
|
|
"delay": float64(53.199),
|
|
"jitter": float64(9.046),
|
|
}
|
|
|
|
secondpeertags := map[string]string{
|
|
"remote": "163.172.25.19",
|
|
"stratum": "2",
|
|
}
|
|
|
|
acc.AssertContainsTaggedFields(t, "openntpd", secondpeerfields, secondpeertags)
|
|
|
|
thirdpeerfields := map[string]interface{}{
|
|
"wt": int64(1),
|
|
"tl": int64(10),
|
|
"next": int64(45),
|
|
"poll": int64(980),
|
|
"offset": float64(-9.901),
|
|
"delay": float64(67.573),
|
|
"jitter": float64(29.350),
|
|
}
|
|
|
|
thirdpeertags := map[string]string{
|
|
"remote": "92.243.6.5",
|
|
"stratum": "2",
|
|
"state_prefix": "*",
|
|
}
|
|
|
|
acc.AssertContainsTaggedFields(t, "openntpd", thirdpeerfields, thirdpeertags)
|
|
|
|
fourthpeerfields := map[string]interface{}{
|
|
"wt": int64(1),
|
|
"tl": int64(2),
|
|
"next": int64(203),
|
|
"poll": int64(300),
|
|
}
|
|
|
|
fourthpeertags := map[string]string{
|
|
"remote": "178.33.111.49",
|
|
"stratum": "-",
|
|
}
|
|
|
|
acc.AssertContainsTaggedFields(t, "openntpd", fourthpeerfields, fourthpeertags)
|
|
}
|
|
|
|
var simpleOutput = `peer
|
|
wt tl st next poll offset delay jitter
|
|
212.129.9.36 from pool 0.debian.pool.ntp.org
|
|
1 10 3 56s 63s 9.271ms 44.662ms 2.678ms`
|
|
|
|
var simpleOutputwithStatePrefix = `peer
|
|
wt tl st next poll offset delay jitter
|
|
92.243.6.5 from pool 0.debian.pool.ntp.org
|
|
* 1 10 2 45s 980s -9.901ms 67.573ms 29.350ms`
|
|
|
|
var simpleOutputInvalidPeer = `peer
|
|
wt tl st next poll offset delay jitter
|
|
178.33.111.49 from pool 0.debian.pool.ntp.org
|
|
1 2 - 203s 300s ---- peer not valid ----`
|
|
|
|
var simpleOutputServersDNSError = `peer
|
|
wt tl st next poll offset delay jitter
|
|
not resolved from pool pool.nl.ntp.org
|
|
1 2 - 2s 15s ---- peer not valid ----
|
|
`
|
|
var simpleOutputServerDNSError = `peer
|
|
wt tl st next poll offset delay jitter
|
|
not resolved pool.fr.ntp.org
|
|
1 2 - 12s 15s ---- peer not valid ----
|
|
`
|
|
|
|
var fullOutput = `peer
|
|
wt tl st next poll offset delay jitter
|
|
212.129.9.36 from pool 0.debian.pool.ntp.org
|
|
1 10 3 56s 63s 9.271ms 44.662ms 2.678ms
|
|
163.172.25.19 from pool 0.debian.pool.ntp.org
|
|
1 10 2 21s 64s -0.103ms 53.199ms 9.046ms
|
|
92.243.6.5 from pool 0.debian.pool.ntp.org
|
|
* 1 10 2 45s 980s -9.901ms 67.573ms 29.350ms
|
|
178.33.111.49 from pool 0.debian.pool.ntp.org
|
|
1 2 - 203s 300s ---- peer not valid ----
|
|
62.210.122.129 from pool 1.debian.pool.ntp.org
|
|
1 10 3 4s 60s 5.372ms 53.690ms 14.700ms
|
|
163.172.225.159 from pool 1.debian.pool.ntp.org
|
|
1 10 3 38s 61s 12.276ms 40.631ms 1.282ms
|
|
5.196.192.58 from pool 1.debian.pool.ntp.org
|
|
1 2 - 0s 300s ---- peer not valid ----
|
|
129.250.35.250 from pool 1.debian.pool.ntp.org
|
|
1 10 2 28s 63s 11.236ms 43.874ms 1.381ms
|
|
2001:41d0:a:5a7::1 from pool 2.debian.pool.ntp.org
|
|
1 2 - 5s 15s ---- peer not valid ----
|
|
2001:41d0:8:188d::16 from pool 2.debian.pool.ntp.org
|
|
1 2 - 3s 15s ---- peer not valid ----
|
|
2001:4b98:dc0:41:216:3eff:fe69:46e3 from pool 2.debian.pool.ntp.org
|
|
1 2 - 14s 15s ---- peer not valid ----
|
|
2a01:e0d:1:3:58bf:fa61:0:1 from pool 2.debian.pool.ntp.org
|
|
1 2 - 9s 15s ---- peer not valid ----
|
|
163.172.179.38 from pool 2.debian.pool.ntp.org
|
|
1 10 2 51s 65s -19.229ms 85.404ms 48.734ms
|
|
5.135.3.88 from pool 2.debian.pool.ntp.org
|
|
1 2 - 173s 300s ---- peer not valid ----
|
|
195.154.41.195 from pool 2.debian.pool.ntp.org
|
|
1 10 2 84s 1004s -3.956ms 54.549ms 13.658ms
|
|
62.210.81.130 from pool 2.debian.pool.ntp.org
|
|
1 10 2 158s 1043s -42.593ms 124.353ms 94.230ms
|
|
149.202.97.123 from pool 3.debian.pool.ntp.org
|
|
1 2 - 205s 300s ---- peer not valid ----
|
|
51.15.175.224 from pool 3.debian.pool.ntp.org
|
|
1 10 2 9s 64s 8.861ms 46.640ms 0.668ms
|
|
37.187.5.167 from pool 3.debian.pool.ntp.org
|
|
1 2 - 105s 300s ---- peer not valid ----
|
|
194.57.169.1 from pool 3.debian.pool.ntp.org
|
|
1 10 2 32s 63s 6.589ms 52.051ms 2.057ms`
|