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, error)
  • func (c *Chains) IsArchiveNode() bool
  • func (c *Chains) Run(ctx context.Context) error
  • func (c *Chains) ValidatorAddress() iotago.Address
• type Provider

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,
	validatorAddrStr string,
	deriveAliasOutputByQuorum bool,
	pipeliningLimit int,
	postponeRecoveryMilestones int,
	consensusDelay time.Duration,
	recoveryTimeout time.Duration,
	networkProvider peering.NetworkProvider,
	trustedNetworkManager peering.TrustedNetworkManager,
	chainStateStoreProvider database.ChainStateKVStoreProvider,
	walLoadToStore bool,
	walEnabled bool,
	walFolderPath string,
	smBlockCacheMaxSize int,
	smBlockCacheBlocksInCacheDuration time.Duration,
	smBlockCacheBlockCleaningPeriod time.Duration,
	smStateManagerGetBlockNodeCount int,
	smStateManagerGetBlockRetry time.Duration,
	smStateManagerRequestCleaningPeriod time.Duration,
	smStateManagerStatusLogPeriod time.Duration,
	smStateManagerTimerTickPeriod time.Duration,
	smPruningMinStatesToKeep int,
	smPruningMaxStatesToDelete int,
	snapshotsToLoad []string,
	snapshotPeriod uint32,
	snapshotDelay uint32,
	snapshotFolderPath string,
	snapshotNetworkPaths []string,
	chainRecordRegistryProvider registry.ChainRecordRegistryProvider,
	dkShareRegistryProvider registry.DKShareRegistryProvider,
	nodeIdentityProvider registry.NodeIdentityProvider,
	consensusStateRegistry cmt_log.ConsensusStateRegistry,
	chainListener chain.ChainListener,
	mempoolSettings mempool.Settings,
	mempoolBroadcastInterval time.Duration,
	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, error)

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

func (*Chains) IsArchiveNode

func (c *Chains) IsArchiveNode() bool

func (*Chains) Run

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

func (*Chains) ValidatorAddress

func (c *Chains) ValidatorAddress() iotago.Address

type Provider

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