Documentation
¶
Index ¶
- func NewResolver() peerresolver.Provider
- func WithBlockHeightLagThreshold(value int) options.Opt
- func WithReconnectBlockHeightThreshold(value int) options.Opt
- type PeerResolver
- func (r *PeerResolver) Filter(peers []fab.Peer) []fab.Peer
- func (r *PeerResolver) Resolve(peers []fab.Peer) (fab.Peer, error)
- func (p PeerResolver) SetBlockHeightLagThreshold(value int)
- func (p PeerResolver) SetFromBlock(value uint64)
- func (p PeerResolver) SetLoadBalancePolicy(value lbp.LoadBalancePolicy)
- func (p PeerResolver) SetReconnectBlockHeightLagThreshold(value int)
- func (p PeerResolver) SetSnapshot(value fab.EventSnapshot) error
- func (r *PeerResolver) ShouldDisconnect(peers []fab.Peer, connectedPeer fab.Peer) bool
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewResolver ¶
func NewResolver() peerresolver.Provider
NewResolver returns a new "min block height" peer resolver provider.
func WithBlockHeightLagThreshold ¶
WithBlockHeightLagThreshold sets the block height lag threshold. If a peer is lagging behind the most up-to-date peer by more than the given number of blocks then it will be excluded. If set to 0 then only the most up-to-date peers are considered. If set to -1 then all peers (regardless of block height) are considered for selection.
func WithReconnectBlockHeightThreshold ¶
WithReconnectBlockHeightThreshold indicates that the event client is to disconnect from the peer if the peer's block height falls too far behind the other peers. If the connected peer lags more than the given number of blocks then the client will disconnect from that peer and reconnect to another peer at a more acceptable block height. If set to 0 then this feature is disabled. NOTE: Setting this value too low may cause the event client to disconnect/reconnect too frequently, thereby affecting performance.
Types ¶
type PeerResolver ¶
type PeerResolver struct {
// contains filtered or unexported fields
}
PeerResolver is a peer resolver that chooses the best peer according to a block height lag threshold. The maximum block height of all peers is determined and the peers whose block heights are under the maximum height but above a provided "lag" threshold are load balanced. The other peers are not considered.
func New ¶
func New(dispatcher service.Dispatcher, context context.Client, channelID string, opts ...options.Opt) *PeerResolver
New returns a new "min block height" peer resolver.
func (*PeerResolver) Filter ¶
func (r *PeerResolver) Filter(peers []fab.Peer) []fab.Peer
Filter returns the peers that are within a provided "lag" threshold from the highest block height of all peers.
func (*PeerResolver) Resolve ¶
Resolve returns the best peer according to a block height lag threshold. The maximum block height of all peers is determined and the peers that are within a provided "lag" threshold are load balanced.
func (PeerResolver) SetBlockHeightLagThreshold ¶
func (p PeerResolver) SetBlockHeightLagThreshold(value int)
func (PeerResolver) SetFromBlock ¶
func (p PeerResolver) SetFromBlock(value uint64)
func (PeerResolver) SetLoadBalancePolicy ¶
func (p PeerResolver) SetLoadBalancePolicy(value lbp.LoadBalancePolicy)
func (PeerResolver) SetReconnectBlockHeightLagThreshold ¶
func (p PeerResolver) SetReconnectBlockHeightLagThreshold(value int)
func (PeerResolver) SetSnapshot ¶
func (p PeerResolver) SetSnapshot(value fab.EventSnapshot) error
func (*PeerResolver) ShouldDisconnect ¶
ShouldDisconnect checks the current peer's block height relative to the block heights of the other peers and disconnects the peer if the configured threshold is reached. Returns false if the block height is acceptable; true if the client should be disconnected from the peer
Source Files