From 4cae8bcb104a515d32c6174687ac0624bb047908 Mon Sep 17 00:00:00 2001 From: mpl Date: Sat, 31 Aug 2019 14:10:04 +0200 Subject: [PATCH] Finish kubernetes throttling refactoring --- provider/kubernetes/kubernetes.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/provider/kubernetes/kubernetes.go b/provider/kubernetes/kubernetes.go index 2bbbca04c..a9b1403fd 100644 --- a/provider/kubernetes/kubernetes.go +++ b/provider/kubernetes/kubernetes.go @@ -141,13 +141,16 @@ func (p *Provider) Provide(configurationChan chan<- types.ConfigMessage, pool *s } throttleDuration := time.Duration(p.ThrottleDuration) - eventsChanToRead := throttleEvents(throttleDuration, stop, eventsChan) + throttledChan := throttleEvents(throttleDuration, stop, eventsChan) + if throttledChan != nil { + eventsChan = throttledChan + } for { select { case <-stop: return nil - case event := <-eventsChanToRead: + case event := <-eventsChan: // Note that event is the *first* event that came in during this // throttling interval -- if we're hitting our throttle, we may have // dropped events. This is fine, because we don't treat different