discovery

Documentation

Index

• Variables
• func NewLocalConfigProvider(options config.DiscoveryConfigOpts, tlsMapper tlsConfigMapper) (api.DiscoveryProvider, error)
• 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
• type TLSCertsMapper
  • func NewTLSCertsMapper(certsCfg []config.TLSCertsMapperConfig) *TLSCertsMapper
  • func (m *TLSCertsMapper) TlsConfigForAddress(address string) *config.TlsConfig

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 tlsConfigMapper) (api.DiscoveryProvider, error)

Types

type GossipDiscoveryProvider

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

func NewGossipDiscoveryProvider

func NewGossipDiscoveryProvider(
	ctx context.Context,
	connCfg config.ConnectionConfig,
	log *zap.Logger,
	identitySigner discClient.Signer,
	clientIdentity []byte,
	tlsMapper tlsConfigMapper,
) (*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"
)

type TLSCertsMapper

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

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

func NewTLSCertsMapper

func NewTLSCertsMapper(certsCfg []config.TLSCertsMapperConfig) *TLSCertsMapper

func (*TLSCertsMapper) TlsConfigForAddress

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

tlsConfigForAddress - get tls config for provided address if config wasnt provided on startup time return disabled tls