chains

Documentation

Index

• func NewChainsListener(parent chain.ChainListener, ...) chain.ChainListener
• type ChainProvider
• type Chains
  • func New(log *logger.Logger, nodeConnection chain.NodeConnection, ...) *Chains
  • func (c *Chains) Activate(chainID isc.ChainID) error
  • func (c *Chains) Close()
  • func (c *Chains) Deactivate(chainID isc.ChainID) error
  • func (c *Chains) Get(chainID isc.ChainID) chain.Chain
  • func (c *Chains) GetNodeConnectionMetrics() nodeconnmetrics.NodeConnectionMetrics
  • func (c *Chains) Run(ctx context.Context) error
• type Provider
  • func (chains Provider) ChainProvider() func(chainID isc.ChainID) chain.Chain

Functions

func NewChainsListener

func NewChainsListener(parent chain.ChainListener, accessNodesCB func(chainID isc.ChainID, accessNodes []*cryptolib.PublicKey)) chain.ChainListener

Types

type ChainProvider

type ChainProvider func(chainID isc.ChainID) chain.Chain

type Chains

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

func New

func New(
	log *logger.Logger,
	nodeConnection chain.NodeConnection,
	processorConfig *processors.Config,
	offledgerBroadcastUpToNPeers int,
	offledgerBroadcastInterval time.Duration,
	pullMissingRequestsFromCommittee bool,
	networkProvider peering.NetworkProvider,
	trustedNetworkManager peering.TrustedNetworkManager,
	chainStateStoreProvider database.ChainStateKVStoreProvider,
	walEnabled bool,
	walDir string,
	chainRecordRegistryProvider registry.ChainRecordRegistryProvider,
	dkShareRegistryProvider registry.DKShareRegistryProvider,
	nodeIdentityProvider registry.NodeIdentityProvider,
	consensusStateRegistry cmtLog.ConsensusStateRegistry,
	chainListener chain.ChainListener,
	shutdownCoordinator *shutdowncoordinator.ShutdownCoordinator,
) *Chains

func (*Chains) Activate

func (c *Chains) Activate(chainID isc.ChainID) error

Activate activates a chain in the node.

func (*Chains) Close

func (c *Chains) Close()

func (*Chains) Deactivate

func (c *Chains) Deactivate(chainID isc.ChainID) error

Deactivate a chain in the node.

func (*Chains) Get

func (c *Chains) Get(chainID isc.ChainID) chain.Chain

Get returns active chain object or nil if it doesn't exist lazy unsubscribing

func (*Chains) GetNodeConnectionMetrics

func (c *Chains) GetNodeConnectionMetrics() nodeconnmetrics.NodeConnectionMetrics

func (*Chains) Run

func (c *Chains) Run(ctx context.Context) error

type Provider

type Provider func() *Chains // TODO: Use DI instead of that.

func (Provider) ChainProvider

func (chains Provider) ChainProvider() func(chainID isc.ChainID) chain.Chain