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

Enhance Load-balancing method validation log.

Browse source
This commit is contained in:
Ludovic Fernandez 2018-05-22 09:20:03 +02:00 committed by Traefiker Bot
parent 0ba28bbc8b
commit bc26d9f0de
2 changed files with 14 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
server/server.go
View file

@ -1438,7 +1438,7 @@ func configureBackends(backends map[string]*types.Backend) {
} }
} }
} else { } else {
log.Debugf("Validation of load balancer method for backend %s failed: %s. Using default method wrr.", backendName, err) log.Debugf("Backend %s: %v", backendName, err)
var stickiness *types.Stickiness var stickiness *types.Stickiness
if backend.LoadBalancer != nil { if backend.LoadBalancer != nil {

17
types/types.go
View file

@ -211,16 +211,21 @@ var loadBalancerMethodNames = []string{
// NewLoadBalancerMethod create a new LoadBalancerMethod from a given LoadBalancer. // NewLoadBalancerMethod create a new LoadBalancerMethod from a given LoadBalancer.
func NewLoadBalancerMethod(loadBalancer *LoadBalancer) (LoadBalancerMethod, error) { func NewLoadBalancerMethod(loadBalancer *LoadBalancer) (LoadBalancerMethod, error) {
var method string if loadBalancer == nil {
if loadBalancer != nil { return Wrr, errors.New("no load-balancer defined, fallback to 'wrr' method")
method = loadBalancer.Method }
if len(loadBalancer.Method) == 0 {
return Wrr, errors.New("no load-balancing method defined, fallback to 'wrr' method")
}
for i, name := range loadBalancerMethodNames { for i, name := range loadBalancerMethodNames {
if strings.EqualFold(name, method) { if strings.EqualFold(name, loadBalancer.Method) {
return LoadBalancerMethod(i), nil return LoadBalancerMethod(i), nil
} }
} }
}
return Wrr, fmt.Errorf("invalid load-balancing method '%s'", method) return Wrr, fmt.Errorf("invalid load-balancing method %q, fallback to 'wrr' method", loadBalancer.Method)
} }
// Configurations is for currentConfigurations Map // Configurations is for currentConfigurations Map