@@ -126,15 +126,17 @@ func (br *BalancingRule) Build(ohm outbound.Manager, dispatcher routing.Dispatch
126
126
switch strings .ToLower (br .Strategy ) {
127
127
case "leastping" :
128
128
return & Balancer {
129
- selectors : br .OutboundSelector ,
130
- strategy : & LeastPingStrategy {},
131
- ohm : ohm ,
129
+ selectors : br .OutboundSelector ,
130
+ strategy : & LeastPingStrategy {},
131
+ fallbackTag : br .FallbackTag ,
132
+ ohm : ohm ,
132
133
}, nil
133
134
case "roundrobin" :
134
135
return & Balancer {
135
- selectors : br .OutboundSelector ,
136
- strategy : & RoundRobinStrategy {},
137
- ohm : ohm ,
136
+ selectors : br .OutboundSelector ,
137
+ strategy : & RoundRobinStrategy {},
138
+ fallbackTag : br .FallbackTag ,
139
+ ohm : ohm ,
138
140
}, nil
139
141
case "leastload" :
140
142
i , err := br .StrategySettings .GetInstance ()
@@ -147,17 +149,19 @@ func (br *BalancingRule) Build(ohm outbound.Manager, dispatcher routing.Dispatch
147
149
}
148
150
leastLoadStrategy := NewLeastLoadStrategy (s )
149
151
return & Balancer {
150
- selectors : br .OutboundSelector ,
151
- ohm : ohm , fallbackTag : br .FallbackTag ,
152
- strategy : leastLoadStrategy ,
152
+ selectors : br .OutboundSelector ,
153
+ ohm : ohm ,
154
+ fallbackTag : br .FallbackTag ,
155
+ strategy : leastLoadStrategy ,
153
156
}, nil
154
157
case "random" :
155
158
fallthrough
156
159
case "" :
157
160
return & Balancer {
158
- selectors : br .OutboundSelector ,
159
- ohm : ohm , fallbackTag : br .FallbackTag ,
160
- strategy : & RandomStrategy {},
161
+ selectors : br .OutboundSelector ,
162
+ ohm : ohm ,
163
+ fallbackTag : br .FallbackTag ,
164
+ strategy : & RandomStrategy {},
161
165
}, nil
162
166
default :
163
167
return nil , newError ("unrecognized balancer type" )
0 commit comments