dynamicselection

Documentation

Index

• type CCPolicyProvider
• type Opt
  • func WithCacheTimeout(timeout time.Duration) Opt
  • func WithLoadBalancePolicy(lbp pgresolver.LoadBalancePolicy) Opt
• type SelectionService
  • func NewService(context context.Client, channelID string, discovery fab.DiscoveryService, ...) (*SelectionService, error)
  • func (s *SelectionService) Close()
  • func (s *SelectionService) GetEndorsersForChaincode(chaincodes []*fab.ChaincodeCall, opts ...copts.Opt) ([]fab.Peer, error)

Types

type CCPolicyProvider

type CCPolicyProvider interface {
	GetChaincodePolicy(chaincodeID string) (*common.SignaturePolicyEnvelope, error)
}

CCPolicyProvider retrieves policy for the given chaincode ID

type Opt

type Opt func(*SelectionService)

Opt applies a selection provider option

func WithCacheTimeout

func WithCacheTimeout(timeout time.Duration) Opt

WithCacheTimeout sets the expiration timeout of the cache

func WithLoadBalancePolicy

func WithLoadBalancePolicy(lbp pgresolver.LoadBalancePolicy) Opt

WithLoadBalancePolicy sets the load-balance policy

type SelectionService

type SelectionService struct {
	// contains filtered or unexported fields
}

SelectionService chooses endorsing peers for a given set of chaincodes using their chaincode policy

func NewService

func NewService(context context.Client, channelID string, discovery fab.DiscoveryService, opts ...Opt) (*SelectionService, error)

NewService creates a new dynamic selection service

func (*SelectionService) Close

func (s *SelectionService) Close()

Close closes all resources associated with the service

func (*SelectionService) GetEndorsersForChaincode

func (s *SelectionService) GetEndorsersForChaincode(chaincodes []*fab.ChaincodeCall, opts ...copts.Opt) ([]fab.Peer, error)

GetEndorsersForChaincode returns the endorsing peers for the given chaincodes