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
|
package helper
import (
"fmt"
"time"
"github.com/beevik/ntp"
)
// CheckClockSync checks if machine clock has allowed drift threshold compare to NTP service.
// ntpHost is a URL of the NTP service to query, if not set the default pool.ntp.org is used.
// driftThreshold is a time duration that is considered acceptable time offset.
func CheckClockSync(ntpHost string, driftThreshold time.Duration) (bool, error) {
if ntpHost == "" {
ntpHost = "pool.ntp.org"
}
resp, err := ntp.Query(ntpHost)
if err != nil {
return false, fmt.Errorf("query ntp host %s: %w", ntpHost, err)
}
if err := resp.Validate(); err != nil {
return false, fmt.Errorf("validate ntp response: %w", err)
}
if resp.ClockOffset > driftThreshold || resp.ClockOffset < -driftThreshold {
return false, nil
}
return true, nil
}
|
