From 866caaf1c8a95b1379c6cf01b712dd8609cecb85 Mon Sep 17 00:00:00 2001 From: Trial97 Date: Fri, 9 Aug 2019 17:31:27 +0300 Subject: [PATCH] Updated *load dispatcher strategy --- dispatchers/libdispatcher.go | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/dispatchers/libdispatcher.go b/dispatchers/libdispatcher.go index aa0f4fffc..197498773 100644 --- a/dispatchers/libdispatcher.go +++ b/dispatchers/libdispatcher.go @@ -84,15 +84,15 @@ func newDispatcher(dm *engine.DataManager, pfl *engine.DispatcherProfile) (d Dis } case utils.MetaLoad: hosts := pfl.Hosts.Clone() - if ls, err := newLoadStrattegyDispatcher(hosts); err != nil { + ls, err := newLoadStrattegyDispatcher(hosts) + if err != nil { return nil, err - } else { - d = &WeightDispatcher{ - dm: dm, - tnt: pfl.Tenant, - hosts: hosts, - strategy: ls, - } + } + d = &WeightDispatcher{ + dm: dm, + tnt: pfl.Tenant, + hosts: hosts, + strategy: ls, } default: err = fmt.Errorf("unsupported dispatch strategy: <%s>", pfl.Strategy)