commit
d0deff9cd6
1 changed files with 2 additions and 0 deletions
|
@ -135,6 +135,7 @@ func PeriodicChecker(check Checker, period time.Duration) Checker {
|
||||||
u := NewStatusUpdater()
|
u := NewStatusUpdater()
|
||||||
go func() {
|
go func() {
|
||||||
t := time.NewTicker(period)
|
t := time.NewTicker(period)
|
||||||
|
defer t.Stop()
|
||||||
for {
|
for {
|
||||||
<-t.C
|
<-t.C
|
||||||
u.Update(check.Check())
|
u.Update(check.Check())
|
||||||
|
@ -150,6 +151,7 @@ func PeriodicThresholdChecker(check Checker, period time.Duration, threshold int
|
||||||
tu := NewThresholdStatusUpdater(threshold)
|
tu := NewThresholdStatusUpdater(threshold)
|
||||||
go func() {
|
go func() {
|
||||||
t := time.NewTicker(period)
|
t := time.NewTicker(period)
|
||||||
|
defer t.Stop()
|
||||||
for {
|
for {
|
||||||
<-t.C
|
<-t.C
|
||||||
tu.Update(check.Check())
|
tu.Update(check.Check())
|
||||||
|
|
Loading…
Reference in a new issue