fabricselection

Documentation

Index

• Constants
• func WithErrorHandler(value fab.ErrorHandler) coptions.Opt
• func WithRefreshInterval(value time.Duration) coptions.Opt
• func WithResponseTimeout(value time.Duration) coptions.Opt
• func WithRetryOpts(value retry.Opts) coptions.Opt
• type DiscoveryClient
• type DiscoveryError
  • func (e DiscoveryError) IsAccessDenied() bool
  • func (e DiscoveryError) IsTransient() bool
• type Service
  • func New(ctx contextAPI.Client, channelID string, discovery fab.DiscoveryService, ...) (*Service, error)
  • func (s *Service) Close()
  • func (s *Service) GetEndorsersForChaincode(chaincodes []*fab.ChaincodeCall, opts ...coptions.Opt) ([]fab.Peer, error)

Constants

const (

	// AccessDenied indicates that the user does not have permission to perform the operation
	AccessDenied = "access denied"
)

Functions

func WithErrorHandler

func WithErrorHandler(value fab.ErrorHandler) coptions.Opt

WithErrorHandler sets the error handler

func WithRefreshInterval

func WithRefreshInterval(value time.Duration) coptions.Opt

WithRefreshInterval sets the interval in which the peer cache is refreshed

func WithResponseTimeout

func WithResponseTimeout(value time.Duration) coptions.Opt

WithResponseTimeout sets the Discover service response timeout

func WithRetryOpts

func WithRetryOpts(value retry.Opts) coptions.Opt

WithRetryOpts sets retry options for retries on transient errors from the Discovery Server

Types

type DiscoveryClient

type DiscoveryClient interface {
	Send(ctx context.Context, req *fabdiscovery.Request, targets ...fab.PeerConfig) (<-chan fabdiscovery.Response, error)
}

DiscoveryClient is the client to the discovery service

type DiscoveryError

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

DiscoveryError is an error originating at the Discovery service

func (DiscoveryError) IsAccessDenied

func (e DiscoveryError) IsAccessDenied() bool

IsAccessDenied checks if response contains access denied msg

func (DiscoveryError) IsTransient

func (e DiscoveryError) IsTransient() bool

IsTransient checks if error is about peer being unable to ding chaincode or endorsement combination wasn't satisfied

type Service

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

Service chooses endorsing peers for a given set of chaincodes using Fabric's Discovery Service

func New

func New(ctx contextAPI.Client, channelID string, discovery fab.DiscoveryService, opts ...coptions.Opt) (*Service, error)

New creates a new dynamic selection service using Fabric's Discovery Service

func (*Service) Close

func (s *Service) Close()

Close closes all resources associated with the service

func (*Service) GetEndorsersForChaincode

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

GetEndorsersForChaincode returns the endorsing peers for the given chaincodes