reduce the deliverator hysteresis to reduce clumping
This commit is contained in:
parent
ef7880cadc
commit
aed70531ff
|
@ -115,7 +115,7 @@ func redeliverator() {
|
||||||
if !sleeper.Stop() {
|
if !sleeper.Stop() {
|
||||||
<-sleeper.C
|
<-sleeper.C
|
||||||
}
|
}
|
||||||
time.Sleep(1 * time.Minute)
|
time.Sleep(5 * time.Second)
|
||||||
case <-sleeper.C:
|
case <-sleeper.C:
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -150,7 +150,7 @@ func redeliverator() {
|
||||||
nexttime = d.When
|
nexttime = d.When
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
dur := nexttime.Sub(now).Round(time.Second) + 1*time.Minute
|
dur := nexttime.Sub(now).Round(time.Second) + 5*time.Second
|
||||||
sleeper.Reset(dur)
|
sleeper.Reset(dur)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue