mirror of
https://github.com/eosswedenorg/antelope-api-healthcheck
synced 2026-07-04 12:03:43 +02:00
src/api/v1.go: Adding SetTime() and GetTime()
This commit is contained in:
parent
513beee79a
commit
f16dced21c
1 changed files with 14 additions and 1 deletions
|
|
@ -11,6 +11,7 @@ import (
|
||||||
type EosioV1 struct {
|
type EosioV1 struct {
|
||||||
params eosapi.ReqParams
|
params eosapi.ReqParams
|
||||||
block_time float64
|
block_time float64
|
||||||
|
ts time.Time
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewEosioV1(url string, host string, block_time float64) EosioV1 {
|
func NewEosioV1(url string, host string, block_time float64) EosioV1 {
|
||||||
|
|
@ -38,6 +39,18 @@ func (e EosioV1) LogInfo() LogParams {
|
||||||
return p
|
return p
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (e *EosioV1) SetTime(t time.Time) {
|
||||||
|
e.ts = t
|
||||||
|
}
|
||||||
|
|
||||||
|
func (e EosioV1) GetTime() time.Time {
|
||||||
|
|
||||||
|
if e.ts.IsZero() {
|
||||||
|
return time.Now().In(time.UTC)
|
||||||
|
}
|
||||||
|
return e.ts
|
||||||
|
}
|
||||||
|
|
||||||
func (e EosioV1) Call() (agentcheck.Response, string) {
|
func (e EosioV1) Call() (agentcheck.Response, string) {
|
||||||
|
|
||||||
info, err := eosapi.GetInfo(e.params)
|
info, err := eosapi.GetInfo(e.params)
|
||||||
|
|
@ -56,7 +69,7 @@ func (e EosioV1) Call() (agentcheck.Response, string) {
|
||||||
}
|
}
|
||||||
|
|
||||||
// Validate head block.
|
// Validate head block.
|
||||||
now := time.Now().In(time.UTC)
|
now := e.GetTime()
|
||||||
diff := now.Sub(info.HeadBlockTime).Seconds()
|
diff := now.Sub(info.HeadBlockTime).Seconds()
|
||||||
|
|
||||||
if diff > e.block_time {
|
if diff > e.block_time {
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue