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) 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,
	deriveAliasOutputByQuorum bool,
	pipeliningLimit int,
	networkProvider peering.NetworkProvider,
	trustedNetworkManager peering.TrustedNetworkManager,
	chainStateStoreProvider database.ChainStateKVStoreProvider,
	walEnabled bool,
	walFolderPath string,
	chainRecordRegistryProvider registry.ChainRecordRegistryProvider,
	dkShareRegistryProvider registry.DKShareRegistryProvider,
	nodeIdentityProvider registry.NodeIdentityProvider,
	consensusStateRegistry cmtLog.ConsensusStateRegistry,
	chainListener chain.ChainListener,
	shutdownCoordinator *shutdown.Coordinator,
	chainMetricsProvider *metrics.ChainMetricsProvider,
) *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) 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