forked from hyperledger/fabric-sdk-go
-
Notifications
You must be signed in to change notification settings - Fork 0
/
config.go
30 lines (25 loc) · 827 Bytes
/
config.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
/*
Copyright SecureKey Technologies Inc. All Rights Reserved.
SPDX-License-Identifier: Apache-2.0
*/
package peerresolver
import (
"github.com/hyperledger/fabric-sdk-go/pkg/common/logging"
"github.com/hyperledger/fabric-sdk-go/pkg/common/providers/fab"
"github.com/hyperledger/fabric-sdk-go/pkg/fab/events/client/lbp"
)
var logger = logging.NewLogger("fabsdk/fab")
// GetBalancer returns the configured load balancer
func GetBalancer(policy fab.EventServicePolicy) lbp.LoadBalancePolicy {
switch policy.Balancer {
case fab.RoundRobin:
logger.Debugf("Using round-robin load balancer.")
return lbp.NewRoundRobin()
case fab.Random:
logger.Debugf("Using random load balancer.")
return lbp.NewRandom()
default:
logger.Debugf("Balancer not specified. Using random load balancer.")
return lbp.NewRandom()
}
}