diff options
author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-08-26 08:15:20 +0000 |
---|---|---|
committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-08-26 08:15:20 +0000 |
commit | 87d772a7d708fec12f48cd8adc0dedff6e1025da (patch) | |
tree | 1fee344c64cc3f43074a01981e21126c8482a522 /src/go/collectors/go.d.plugin/modules/chrony/client.go | |
parent | Adding upstream version 1.46.3. (diff) | |
download | netdata-upstream.tar.xz netdata-upstream.zip |
Adding upstream version 1.47.0.upstream/1.47.0upstream
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to '')
-rw-r--r-- | src/go/collectors/go.d.plugin/modules/chrony/client.go | 61 |
1 files changed, 0 insertions, 61 deletions
diff --git a/src/go/collectors/go.d.plugin/modules/chrony/client.go b/src/go/collectors/go.d.plugin/modules/chrony/client.go deleted file mode 100644 index e850ff239..000000000 --- a/src/go/collectors/go.d.plugin/modules/chrony/client.go +++ /dev/null @@ -1,61 +0,0 @@ -// SPDX-License-Identifier: GPL-3.0-or-later - -package chrony - -import ( - "fmt" - "net" - - "github.com/facebook/time/ntp/chrony" -) - -func newChronyClient(c Config) (chronyClient, error) { - conn, err := net.DialTimeout("udp", c.Address, c.Timeout.Duration()) - if err != nil { - return nil, err - } - - client := &simpleClient{ - conn: conn, - client: &chrony.Client{Connection: conn}, - } - return client, nil -} - -type simpleClient struct { - conn net.Conn - client *chrony.Client -} - -func (sc *simpleClient) Tracking() (*chrony.ReplyTracking, error) { - reply, err := sc.client.Communicate(chrony.NewTrackingPacket()) - if err != nil { - return nil, err - } - - tracking, ok := reply.(*chrony.ReplyTracking) - if !ok { - return nil, fmt.Errorf("unexpected reply type, want=%T, got=%T", &chrony.ReplyTracking{}, reply) - } - return tracking, nil -} - -func (sc *simpleClient) Activity() (*chrony.ReplyActivity, error) { - reply, err := sc.client.Communicate(chrony.NewActivityPacket()) - if err != nil { - return nil, err - } - - activity, ok := reply.(*chrony.ReplyActivity) - if !ok { - return nil, fmt.Errorf("unexpected reply type, want=%T, got=%T", &chrony.ReplyActivity{}, reply) - } - return activity, nil -} - -func (sc *simpleClient) Close() { - if sc.conn != nil { - _ = sc.conn.Close() - sc.conn = nil - } -} |