vbatts/registry
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Release ticker resources

Browse source 
Signed-off-by: Matin Rahmanian <itsmatinx@gmail.com>
This commit is contained in:
Matin Rahmanian 2021-04-26 23:26:48 +02:00
parent a9d8a05d08
commit 835651e513
No known key found for this signature in database
GPG key ID: 74443649F1F0D2D1
1 changed files with 2 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
health/health.go
View file

@ -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())