Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WithRefreshInterval ¶
WithRefreshInterval sets the interval in which the peer cache is refreshed
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, channelID string, opts ...coptions.Opt) (*ChannelService, error)
NewChannelService creates a Discovery Service to query the list of member peers on a given channel.
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) Initialize ¶
func (s *LocalService) Initialize(ctx contextAPI.Local) error
Initialize initializes the service with local context