chains

Mar 6, 2024

Changes in this version

+ func NewChainsListener(parent chain.ChainListener, ...) chain.ChainListener

type Chains

+ func (c *Chains) Close()

+ func (c *Chains) IsArchiveNode() bool

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

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

Dec 10, 2021

Changes in this version

type Chains

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

+ func (c *Chains) SetNodeConn(nodeConn chain.NodeConnection)

Oct 21, 2021

Changes in this version

+ type ChainProvider func(chainID *iscp.ChainID) chain.Chain

+ type Chains struct

+ func New(log *logger.Logger, processorConfig *processors.Config, ...) *Chains

+ func (c *Chains) Activate(chr *registry.ChainRecord, registryProvider registry.Provider, ...) error

+ func (c *Chains) ActivateAllFromRegistry(registryProvider registry.Provider, allMetrics *metrics.Metrics) error

+ func (c *Chains) Attach(nodeConn *txstream.Client)

+ func (c *Chains) Deactivate(chr *registry.ChainRecord) error

+ func (c *Chains) Dismiss()

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

+ type Provider func() *Chains

+ func (chains Provider) ChainProvider() func(chainID *iscp.ChainID) chain.Chain