diff --git a/app/router/config.go b/app/router/config.go index 53a0e4b88..d8348b691 100644 --- a/app/router/config.go +++ b/app/router/config.go @@ -160,7 +160,7 @@ func (rr *RoutingRule) BuildCondition() (Condition, error) { // Build builds the balancing rule func (br *BalancingRule) Build(ohm outbound.Manager, dispatcher routing.Dispatcher) (*Balancer, error) { switch br.Strategy { - case "leastPing": + case "leastping": i, err := br.StrategySettings.GetInstance() if err != nil { return nil, err @@ -174,7 +174,7 @@ func (br *BalancingRule) Build(ohm outbound.Manager, dispatcher routing.Dispatch strategy: &LeastPingStrategy{config: s}, ohm: ohm, }, nil - case "leastLoad": + case "leastload": i, err := br.StrategySettings.GetInstance() if err != nil { return nil, err @@ -191,11 +191,13 @@ func (br *BalancingRule) Build(ohm outbound.Manager, dispatcher routing.Dispatch }, nil case "random": fallthrough - default: + case "": return &Balancer{ selectors: br.OutboundSelector, ohm: ohm, fallbackTag: br.FallbackTag, strategy: &RandomStrategy{}, }, nil + default: + return nil, newError("unrecognized balancer type") } }