forked from hyperledger/fabric-sdk-go
/
opts.go
28 lines (22 loc) · 770 Bytes
/
opts.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
/*
Copyright SecureKey Technologies Inc. All Rights Reserved.
SPDX-License-Identifier: Apache-2.0
*/
package balanced
import (
"github.com/hyperledger/fabric-sdk-go/pkg/common/providers/context"
"github.com/hyperledger/fabric-sdk-go/pkg/fab/events/client/lbp"
"github.com/hyperledger/fabric-sdk-go/pkg/fab/events/client/peerresolver"
)
type params struct {
loadBalancePolicy lbp.LoadBalancePolicy
}
func defaultParams(context context.Client, channelID string) *params {
return ¶ms{
loadBalancePolicy: peerresolver.GetBalancer(context.EndpointConfig().ChannelConfig(channelID).Policies.EventService),
}
}
func (p *params) SetLoadBalancePolicy(value lbp.LoadBalancePolicy) {
logger.Debugf("LoadBalancePolicy: %#v", value)
p.loadBalancePolicy = value
}