cybercyst/traefik
1
0
Fork 0
mirror of https://github.com/traefik/traefik.git synced 2025-05-14 11:44:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

Finish kubernetes throttling refactoring

Browse Source
This commit is contained in:
mpl 2019-08-31 14:10:04 +02:00 committed by Traefiker Bot
parent 43af0b051f
commit 1388266102
2 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
pkg/provider/kubernetes/crd/kubernetes.go
View File

@ -110,13 +110,16 @@ func (p *Provider) Provide(configurationChan chan<- dynamic.Message, pool *safe.
} }
throttleDuration := time.Duration(p.ThrottleDuration) throttleDuration := time.Duration(p.ThrottleDuration)
eventsChanToRead := throttleEvents(ctxLog, throttleDuration, stop, eventsChan) throttledChan := throttleEvents(ctxLog, throttleDuration, stop, eventsChan)
if throttledChan != nil {
eventsChan = throttledChan
}
for { for {
select { select {
case <-stop: case <-stop:
return nil return nil
case event := <-eventsChanToRead: case event := <-eventsChan:
// Note that event is the *first* event that came in during this // Note that event is the *first* event that came in during this
// throttling interval -- if we're hitting our throttle, we may have // throttling interval -- if we're hitting our throttle, we may have
// dropped events. This is fine, because we don't treat different // dropped events. This is fine, because we don't treat different

7
pkg/provider/kubernetes/ingress/kubernetes.go
View File

@ -121,13 +121,16 @@ func (p *Provider) Provide(configurationChan chan<- dynamic.Message, pool *safe.
} }
throttleDuration := time.Duration(p.ThrottleDuration) throttleDuration := time.Duration(p.ThrottleDuration)
eventsChanToRead := throttleEvents(ctxLog, throttleDuration, stop, eventsChan) throttledChan := throttleEvents(ctxLog, throttleDuration, stop, eventsChan)
if throttledChan != nil {
eventsChan = throttledChan
}
for { for {
select { select {
case <-stop: case <-stop:
return nil return nil
case event := <-eventsChanToRead: case event := <-eventsChan:
// Note that event is the *first* event that came in during this // Note that event is the *first* event that came in during this
// throttling interval -- if we're hitting our throttle, we may have // throttling interval -- if we're hitting our throttle, we may have
// dropped events. This is fine, because we don't treat different // dropped events. This is fine, because we don't treat different