fabric-sdk-go: github.com/hyperledger/fabric-sdk-go/pkg/fab/events/client/peerresolver Index | Files | Directories

package peerresolver

import "github.com/hyperledger/fabric-sdk-go/pkg/fab/events/client/peerresolver"

Index

Package Files

config.go peerresolver.go

func GetBalancer Uses

func GetBalancer(policy fab.EventServicePolicy) lbp.LoadBalancePolicy

GetBalancer returns the configured load balancer

type Provider Uses

type Provider func(ed service.Dispatcher, context context.Client, channelID string, opts ...options.Opt) Resolver

Provider creates a peer Resolver

type Resolver Uses

type Resolver interface {
    // Resolve chooses a peer from the given set of peers
    Resolve(peers []fab.Peer) (fab.Peer, error)
    // ShouldDisconnect returns true to disconnect from the connected peer
    ShouldDisconnect(peers []fab.Peer, connectedPeer fab.Peer) bool
}

Resolver decided which peer to connect to and when to disconnect from that peer

Directories

PathSynopsis
balanced
minblockheight
preferorg
preferpeer

Package peerresolver imports 6 packages (graph) and is imported by 5 packages. Updated 2018-11-13. Refresh now. Tools for package owners.