dynamicdiscovery

Documentation

Index

• func GetEndorsers(ctx fabcontext.Client, client *discovery.Client, peerConfig fab.PeerConfig) (discclient.Endorsers, error)
• func PrintConfig(peers []*discclient.Peer, result *fabdiscovery.ConfigResult)
• func PrintPeerInfo(peers []*discclient.Peer)
• func WithRefreshInterval(value time.Duration) coptions.Opt
• func WithResponseTimeout(value time.Duration) coptions.Opt
• type ChannelService
  • func NewChannelService(ctx contextAPI.Client, membership fab.ChannelMembership, channelID string, ...) (*ChannelService, error)
  • func (s *ChannelService) Close()
  • func (s ChannelService) GetPeers() ([]fab.Peer, error)
• type LocalProvider
  • func NewLocalProvider(config fab.EndpointConfig, opts ...coptions.Opt) *LocalProvider
  • func (p *LocalProvider) Close()
  • func (p *LocalProvider) CreateLocalDiscoveryService(mspID string) (fab.DiscoveryService, error)
• type LocalService
  • func (s *LocalService) Close()
  • func (s LocalService) GetPeers() ([]fab.Peer, error)
  • func (s *LocalService) Initialize(ctx contextAPI.Local) error

Functions

func GetEndorsers

func GetEndorsers(ctx fabcontext.Client, client *discovery.Client, peerConfig fab.PeerConfig) (discclient.Endorsers, error)

func PrintConfig

func PrintConfig(peers []*discclient.Peer, result *fabdiscovery.ConfigResult)

func PrintPeerInfo

func PrintPeerInfo(peers []*discclient.Peer)

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

Types

type ChannelService

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

ChannelService implements a dynamic Discovery Service that queries Fabric's Discovery service for information about the peers that are currently joined to the given channel.

func NewChannelService

func NewChannelService(ctx contextAPI.Client, membership fab.ChannelMembership, channelID string, opts ...coptions.Opt) (*ChannelService, error)

NewChannelService creates a Discovery Service to query the list of member peers on a given channel.

func (*ChannelService) Close

func (s *ChannelService) Close()

Close releases resources

func (ChannelService) GetPeers

func (s ChannelService) GetPeers() ([]fab.Peer, error)

GetPeers returns the available peers

type LocalProvider

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

LocalProvider implements a local Dynamic Discovery LocalProvider that queries Fabric's Discovery service for information about the peers that are in the local MSP.

func NewLocalProvider

func NewLocalProvider(config fab.EndpointConfig, opts ...coptions.Opt) *LocalProvider

NewLocalProvider creates a new local dynamic discovery provider

func (*LocalProvider) Close

func (p *LocalProvider) Close()

Close will close the cache and all services contained by the cache.

func (*LocalProvider) CreateLocalDiscoveryService

func (p *LocalProvider) CreateLocalDiscoveryService(mspID string) (fab.DiscoveryService, error)

CreateLocalDiscoveryService returns a local discovery service

type LocalService

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

LocalService implements a dynamic Discovery Service that queries Fabric's Discovery service for the peers that are in the local MSP.

func (*LocalService) Close

func (s *LocalService) Close()

Close releases resources

func (LocalService) GetPeers

func (s LocalService) GetPeers() ([]fab.Peer, error)

GetPeers returns the available peers

func (*LocalService) Initialize

func (s *LocalService) Initialize(ctx contextAPI.Local) error

Initialize initializes the service with local context