discovery

Documentation

Index

• Variables
• func NewLocalConfigProvider(options config.DiscoveryConfigOpts, tlsMapper connectionMapper) (api.DiscoveryProvider, error)
• type EndpointsMapper
  • func NewEndpointsMapper(endpoints []config.Endpoint) *EndpointsMapper
  • func (m *EndpointsMapper) MapConnection(address string) *api.Endpoint
  • func (m *EndpointsMapper) TlsConfigForAddress(address string) config.TlsConfig
  • func (m *EndpointsMapper) TlsEndpointForAddress(address string) string
• type GossipDiscoveryProvider
  • func NewGossipDiscoveryProvider(ctx context.Context, connCfg config.ConnectionConfig, log *zap.Logger, ...) (*GossipDiscoveryProvider, error)
  • func (d *GossipDiscoveryProvider) Chaincode(ctx context.Context, channelName string, ccName string) (api.ChaincodeDiscoverer, error)
  • func (d *GossipDiscoveryProvider) Channel(ctx context.Context, channelName string) (api.ChannelDiscoverer, error)
  • func (d *GossipDiscoveryProvider) LocalPeers(ctx context.Context) (api.LocalPeersDiscoverer, error)
• type LocalConfigProvider
  • func (d *LocalConfigProvider) Chaincode(_ context.Context, channelName, ccName string) (api.ChaincodeDiscoverer, error)
  • func (d *LocalConfigProvider) Channel(_ context.Context, channelName string) (api.ChannelDiscoverer, error)
  • func (d *LocalConfigProvider) LocalPeers(_ context.Context) (api.LocalPeersDiscoverer, error)
• type ServiceDiscoveryType

Variables

var (
	ErrNoChannels      = errors.New(`channels not found`)
	ErrChannelNotFound = errors.New(`channel not found`)
	ErrNoChaincodes    = errors.New(`no chaincodes on channel`)
	ErrUnknownProvider = errors.New(`unknown discovery provider (forgotten import?)`)
)

Functions

func NewLocalConfigProvider

func NewLocalConfigProvider(options config.DiscoveryConfigOpts, tlsMapper connectionMapper) (api.DiscoveryProvider, error)

Types

type EndpointsMapper

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

EndpointsMapper - if tls is enabled with gossip maps provided from cfg TLS certs to discovered peers

func NewEndpointsMapper

func NewEndpointsMapper(endpoints []config.Endpoint) *EndpointsMapper

func (*EndpointsMapper) MapConnection

func (m *EndpointsMapper) MapConnection(address string) *api.Endpoint

func (*EndpointsMapper) TlsConfigForAddress

func (m *EndpointsMapper) TlsConfigForAddress(address string) config.TlsConfig

TlsConfigForAddress - get tls config for provided address if config wasn't provided on startup time return disabled tls

func (*EndpointsMapper) TlsEndpointForAddress

func (m *EndpointsMapper) TlsEndpointForAddress(address string) string

type GossipDiscoveryProvider

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

func NewGossipDiscoveryProvider

func NewGossipDiscoveryProvider(
	ctx context.Context,
	connCfg config.ConnectionConfig,
	log *zap.Logger,
	identitySigner discoveryclient.Signer,
	clientIdentity []byte,
	tlsMapper connectionMapper,
) (*GossipDiscoveryProvider, error)

func (*GossipDiscoveryProvider) Chaincode

func (d *GossipDiscoveryProvider) Chaincode(ctx context.Context, channelName string, ccName string) (api.ChaincodeDiscoverer, error)

func (*GossipDiscoveryProvider) Channel

func (d *GossipDiscoveryProvider) Channel(ctx context.Context, channelName string) (api.ChannelDiscoverer, error)

func (*GossipDiscoveryProvider) LocalPeers

func (d *GossipDiscoveryProvider) LocalPeers(ctx context.Context) (api.LocalPeersDiscoverer, error)

type LocalConfigProvider

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

func (*LocalConfigProvider) Chaincode

func (d *LocalConfigProvider) Chaincode(_ context.Context, channelName, ccName string) (api.ChaincodeDiscoverer, error)

func (*LocalConfigProvider) Channel

func (d *LocalConfigProvider) Channel(_ context.Context, channelName string) (api.ChannelDiscoverer, error)

func (*LocalConfigProvider) LocalPeers

func (d *LocalConfigProvider) LocalPeers(_ context.Context) (api.LocalPeersDiscoverer, error)

type ServiceDiscoveryType

type ServiceDiscoveryType string

ServiceDiscoveryType - what types of discovery we support

const (
	LocalConfigServiceDiscoveryType ServiceDiscoveryType = "local"
	GossipServiceDiscoveryType      ServiceDiscoveryType = "gossip"
)