Documentation ¶
Index ¶
- func NewChainsListener(parent chain.ChainListener, ...) chain.ChainListener
- type ChainProvider
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewChainsListener ¶ added in v1.0.3
func NewChainsListener(parent chain.ChainListener, accessNodesCB func(chainID isc.ChainID, accessNodes []*cryptolib.PublicKey)) chain.ChainListener
Types ¶
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, offledgerBroadcastUpToNPeers int, offledgerBroadcastInterval time.Duration, pullMissingRequestsFromCommittee bool, deriveAliasOutputByQuorum bool, pipeliningLimit int, consensusDelay 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, smStateManagerGetBlockRetry time.Duration, smStateManagerRequestCleaningPeriod time.Duration, smStateManagerTimerTickPeriod time.Duration, smPruningMinStatesToKeep int, smPruningMaxStatesToDelete int, snapshotPeriod uint32, snapshotFolderPath string, snapshotNetworkPaths []string, snapshotUpdatePeriod time.Duration, chainRecordRegistryProvider registry.ChainRecordRegistryProvider, dkShareRegistryProvider registry.DKShareRegistryProvider, nodeIdentityProvider registry.NodeIdentityProvider, consensusStateRegistry cmt_log.ConsensusStateRegistry, chainListener chain.ChainListener, shutdownCoordinator *shutdown.Coordinator, chainMetricsProvider *metrics.ChainMetricsProvider, ) *Chains
func (*Chains) Deactivate ¶
Deactivate a chain in the node.
func (*Chains) IsArchiveNode ¶ added in v1.0.3
func (*Chains) ValidatorAddress ¶ added in v1.0.3
Click to show internal directories.
Click to hide internal directories.