package fabricselection

import "github.com/hyperledger/fabric-sdk-go/pkg/client/common/selection/fabricselection"

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, opts ...coptions.Opt) (*Service, error)
• func (s *Service) Close()
• func (s *Service) GetEndorsersForChaincode(chaincodes []*fab.ChaincodeCall, opts ...coptions.Opt) ([]fab.Peer, error)

Package Files ¶

cachekey.go fabricselection.go opts.go selectionfilter.go

Constants ¶

const (

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

func WithErrorHandler ¶ Uses

func WithErrorHandler(value fab.ErrorHandler) coptions.Opt

WithErrorHandler sets the error handler

func WithRefreshInterval ¶ Uses

func WithRefreshInterval(value time.Duration) coptions.Opt

WithRefreshInterval sets the interval in which the peer cache is refreshed

func WithResponseTimeout ¶ Uses

func WithResponseTimeout(value time.Duration) coptions.Opt

WithResponseTimeout sets the Discover service response timeout

func WithRetryOpts ¶ Uses

func WithRetryOpts(value retry.Opts) coptions.Opt

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

type DiscoveryClient ¶ Uses

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 ¶ Uses

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

DiscoveryError is an error originating at the Discovery service

func (DiscoveryError) IsAccessDenied ¶ Uses

func (e DiscoveryError) IsAccessDenied() bool

IsAccessDenied checks if response contains access denied msg

func (DiscoveryError) IsTransient ¶ Uses

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 ¶ Uses

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 ¶ Uses

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 ¶ Uses

func (s *Service) Close()

Close closes all resources associated with the service

func (*Service) GetEndorsersForChaincode ¶ Uses

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

GetEndorsersForChaincode returns the endorsing peers for the given chaincodes