From f5d55038b69a2ba19c3ae001a542ca71b2e97243 Mon Sep 17 00:00:00 2001 From: Prajjawalk Date: Wed, 7 Dec 2022 22:15:32 +0530 Subject: [PATCH] Add: NTP utils Signed-off-by: Prajjawalk --- go.mod | 1 + go.sum | 2 ++ utils/ntp.go | 38 ++++++++++++++++++++++++++++++++++++++ 3 files changed, 41 insertions(+) create mode 100644 utils/ntp.go diff --git a/go.mod b/go.mod index a0eb2a5a..0e9c7522 100644 --- a/go.mod +++ b/go.mod @@ -40,6 +40,7 @@ require ( require ( github.com/StackExchange/wmi v0.0.0-20180116203802-5d049714c4a6 // indirect github.com/VictoriaMetrics/fastcache v1.6.0 // indirect + github.com/beevik/ntp v0.3.0 github.com/benbjohnson/clock v1.3.0 // indirect github.com/beorn7/perks v1.0.1 // indirect github.com/btcsuite/btcd v0.20.1-beta // indirect diff --git a/go.sum b/go.sum index 307bfcd0..a6f0521c 100644 --- a/go.sum +++ b/go.sum @@ -197,6 +197,8 @@ github.com/aws/aws-sdk-go-v2/service/sts v1.7.2/go.mod h1:8EzeIqfWt2wWT4rJVu3f21 github.com/aws/smithy-go v1.1.0/go.mod h1:EzMw8dbp/YJL4A5/sbhGddag+NPT7q084agLbB9LgIw= github.com/aws/smithy-go v1.7.0/go.mod h1:SObp3lf9smib00L/v3U2eAKG8FyQ7iLrJnQiAmR5n+E= github.com/aws/smithy-go v1.8.0/go.mod h1:SObp3lf9smib00L/v3U2eAKG8FyQ7iLrJnQiAmR5n+E= +github.com/beevik/ntp v0.3.0 h1:xzVrPrE4ziasFXgBVBZJDP0Wg/KpMwk2KHJ4Ba8GrDw= +github.com/beevik/ntp v0.3.0/go.mod h1:hIHWr+l3+/clUnF44zdK+CWW7fO8dR5cIylAQ76NRpg= github.com/benbjohnson/clock v1.0.3/go.mod h1:bGMdMPoPVvcYyt1gHDf4J2KE153Yf9BuiUKYMaxlTDM= github.com/benbjohnson/clock v1.1.0/go.mod h1:J11/hYXuz8f4ySSvYwY0FKfm+ezbsZBKZxNJlLklBHA= github.com/benbjohnson/clock v1.3.0 h1:ip6w0uFQkncKQ979AypyG0ER7mqUSBdKLOgAle/AT8A= diff --git a/utils/ntp.go b/utils/ntp.go new file mode 100644 index 00000000..4033094a --- /dev/null +++ b/utils/ntp.go @@ -0,0 +1,38 @@ +package utils + +import ( + "time" + + "github.com/beevik/ntp" +) + +var NTPServer = "pool.ntp.org" + +func GetNTPTime() (time.Time, error) { + t, err := ntp.Time(NTPServer) + if err != nil { + return t, err + } + + return t, nil +} + +func GetNTPMetadata() (*ntp.Response, error) { + options := ntp.QueryOptions{Timeout: 60 * time.Second, TTL: 10} + response, err := ntp.QueryWithOptions(NTPServer, options) + if err != nil { + return nil, err + } + + return response, nil +} + +func GetTimeOffset() (time.Duration, error) { + options := ntp.QueryOptions{Timeout: 60 * time.Second, TTL: 10} + response, err := ntp.QueryWithOptions(NTPServer, options) + if err != nil { + return 0, err + } + + return response.ClockOffset, nil +}