upstream/icingadb
1
0
Fork 0
mirror of https://github.com/Icinga/icingadb.git synced 2026-05-28 04:35:54 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Use time.NewTicker(), not time.Tick()

Browse source
This commit is contained in:
Alexander A. Klimov 2021-05-28 14:00:23 +02:00
parent 5a084ba7a9
commit 35349262ce
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
pkg/icingaredis/heartbeat.go
View file

@ -84,7 +84,9 @@ func (h Heartbeat) controller() {
// Message producer loop
g.Go(func() error {
// We expect heartbeats every second but only read them every 3 seconds
throttle := time.Tick(time.Second * 3)
throttle := time.NewTicker(time.Second * 3)
defer throttle.Stop()
for {
cmd := h.client.XRead(ctx, &redis.XReadArgs{
Streams: []string{"icinga:stats", "$"},
@ -102,7 +104,7 @@ func (h Heartbeat) controller() {
return ctx.Err()
}
<-throttle
<-throttle.C
}
})