Continue refresh the configuration after a failure.

This commit is contained in:
Ludovic Fernandez 2018-02-12 09:28:03 +01:00 committed by Traefiker
parent 1e71f52b72
commit 2fde3e8679

View file

@ -55,12 +55,12 @@ func (p *Provider) Provide(configurationChan chan<- types.ConfigMessage, pool *s
safe.Go(func() { safe.Go(func() {
for t := range ticker.C { for t := range ticker.C {
log.Debug("Refreshing Provider " + t.String()) log.Debugf("Refreshing Provider %s", t.String())
configuration, err := p.buildConfiguration() configuration, err := p.buildConfiguration()
if err != nil { if err != nil {
log.Errorf("Failed to refresh Provider configuration, error: %s", err) log.Errorf("Failed to refresh Provider configuration, error: %s", err)
return continue
} }
configurationChan <- types.ConfigMessage{ configurationChan <- types.ConfigMessage{