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) 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 Provider) ChainProvider() func(chainID *iscp.ChainID) chain.Chain

Types

type ChainProvider

type ChainProvider func(chainID *iscp.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,
) *Chains

func (*Chains) Activate

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

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

func (*Chains) ActivateAllFromRegistry

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

func (*Chains) Attach

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

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 *iscp.ChainID) chain.Chain

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

type Provider

type Provider func() *Chains

func (Provider) ChainProvider

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