chains

Documentation

Index

• type ChainProvider
• type Chains
  • 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, w *wal.WAL) error
  • func (c *Chains) Deactivate(chr *registry.ChainRecord) error
  • func (c *Chains) Dismiss()
  • func (c *Chains) Get(chainID *isc.ChainID, includeDeactivated ...bool) chain.Chain
  • func (c *Chains) GetNodeConnectionMetrics() nodeconnmetrics.NodeConnectionMetrics
  • func (c *Chains) SetNodeConn(nodeConn chain.NodeConnection)
• type Provider
  • func (chains Provider) ChainProvider() func(chainID *isc.ChainID) chain.Chain

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,
	processorConfig *processors.Config,
	offledgerBroadcastUpToNPeers int,
	offledgerBroadcastInterval time.Duration,
	pullMissingRequestsFromCommittee bool,
	networkProvider peering.NetworkProvider,
	getOrCreateKVStore dbmanager.ChainKVStoreProvider,
	rawBlocksEnabled bool,
	rawBlocksDir string,
) *Chains

func (*Chains) Activate

func (c *Chains) Activate(chr *registry.ChainRecord, registryProvider registry.Provider, allMetrics *metrics.Metrics, w *wal.WAL) error

Activate activates chain on the Wasp node: - creates chain object - insert it into the runtime registry - subscribes for related transactions in the L1 node

func (*Chains) ActivateAllFromRegistry

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

func (*Chains) Deactivate

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

Deactivate deactivates chain in the node

func (*Chains) Dismiss

func (c *Chains) Dismiss()

func (*Chains) Get

func (c *Chains) Get(chainID *isc.ChainID, includeDeactivated ...bool) 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) SetNodeConn

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

type Provider

type Provider func() *Chains

func (Provider) ChainProvider

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