homelab/traefik
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Migrate to JobBackOff

Browse source
This commit is contained in:
Emile Vauge 2016-08-19 14:24:09 +02:00
parent 95e8f0a31e
commit d340ccd601
No known key found for this signature in database
GPG key ID: D808B4C167352E59
10 changed files with 30 additions and 72 deletions
Download patch file Download diff file Expand all files Collapse all files

6
provider/kubernetes.go
View file

@ -3,11 +3,10 @@ package provider
import (
"fmt"
log "github.com/Sirupsen/logrus"
"github.com/cenkalti/backoff"
"github.com/containous/traefik/provider/k8s"
"github.com/containous/traefik/safe"
"github.com/containous/traefik/types"
"github.com/containous/traefik/utils"
"github.com/emilevauge/backoff"
"io/ioutil"
"os"
"reflect"
@ -96,7 +95,6 @@ func (provider *Kubernetes) Provide(configurationChan chan<- types.ConfigMessage
if err != nil {
return err
}
backOff := backoff.NewExponentialBackOff()
provider.Constraints = append(provider.Constraints, constraints...)
pool.Go(func(stop chan bool) {
@ -147,7 +145,7 @@ func (provider *Kubernetes) Provide(configurationChan chan<- types.ConfigMessage
notify := func(err error, time time.Duration) {
log.Errorf("Kubernetes connection error %+v, retrying in %s", err, time)
}
err := utils.RetryNotifyJob(operation, backOff, notify)
err := backoff.RetryNotify(operation, backoff.NewJobBackOff(backoff.NewExponentialBackOff()), notify)
if err != nil {
log.Errorf("Cannot connect to Kubernetes server %+v", err)
}