Merge pull request #6546 from nic-6443/ewma-cananry-fix
bugfix: update trafficShapingPolicy not working in ewma load-balance
This commit is contained in:
commit
baf2afc5de
1 changed files with 3 additions and 2 deletions
|
@ -193,6 +193,9 @@ function _M.after_balance(_)
|
||||||
end
|
end
|
||||||
|
|
||||||
function _M.sync(self, backend)
|
function _M.sync(self, backend)
|
||||||
|
self.traffic_shaping_policy = backend.trafficShapingPolicy
|
||||||
|
self.alternative_backends = backend.alternativeBackends
|
||||||
|
|
||||||
local normalized_endpoints_added, normalized_endpoints_removed =
|
local normalized_endpoints_added, normalized_endpoints_removed =
|
||||||
util.diff_endpoints(self.peers, backend.endpoints)
|
util.diff_endpoints(self.peers, backend.endpoints)
|
||||||
|
|
||||||
|
@ -203,8 +206,6 @@ function _M.sync(self, backend)
|
||||||
|
|
||||||
ngx_log(INFO, string_format("[%s] peers have changed for backend %s", self.name, backend.name))
|
ngx_log(INFO, string_format("[%s] peers have changed for backend %s", self.name, backend.name))
|
||||||
|
|
||||||
self.traffic_shaping_policy = backend.trafficShapingPolicy
|
|
||||||
self.alternative_backends = backend.alternativeBackends
|
|
||||||
self.peers = backend.endpoints
|
self.peers = backend.endpoints
|
||||||
|
|
||||||
for _, endpoint_string in ipairs(normalized_endpoints_removed) do
|
for _, endpoint_string in ipairs(normalized_endpoints_removed) do
|
||||||
|
|
Loading…
Reference in a new issue