inmemoryblockdag

Documentation

Index

• func NewProvider(opts ...options.Option[BlockDAG]) module.Provider[*engine.Engine, blockdag.BlockDAG]
• type BlockDAG
  • func New(logger log.Logger, workers *workerpool.Group, unsolidCommitmentBufferSize int, ...) (newBlockDAG *BlockDAG)
  • func (b *BlockDAG) Attach(data *model.Block) (block *blocks.Block, wasAttached bool, err error)
  • func (b *BlockDAG) GetOrRequestBlock(blockID iotago.BlockID) (block *blocks.Block, requested bool)
  • func (b *BlockDAG) Reset()
  • func (b *BlockDAG) Shutdown()

Functions

func NewProvider

func NewProvider(opts ...options.Option[BlockDAG]) module.Provider[*engine.Engine, blockdag.BlockDAG]

Types

type BlockDAG

type BlockDAG struct {
	module.Module

	log.Logger
	// contains filtered or unexported fields
}

BlockDAG is a causally ordered DAG that forms the central data structure of the IOTA protocol.

func New

func New(logger log.Logger, workers *workerpool.Group, unsolidCommitmentBufferSize int, evictionState *eviction.State, blockCache *blocks.Blocks, errorHandler func(error), opts ...options.Option[BlockDAG]) (newBlockDAG *BlockDAG)

New is the constructor for the BlockDAG and creates a new BlockDAG instance.

func (*BlockDAG) Attach

func (b *BlockDAG) Attach(data *model.Block) (block *blocks.Block, wasAttached bool, err error)

Attach is used to attach new Blocks to the BlockDAG. It is the main function of the BlockDAG that triggers Events.

func (*BlockDAG) GetOrRequestBlock

func (b *BlockDAG) GetOrRequestBlock(blockID iotago.BlockID) (block *blocks.Block, requested bool)

GetOrRequestBlock returns the Block with the given BlockID from the BlockDAG (and requests it from the network if it is missing). If the requested Block is below the eviction threshold, then this method will return a nil block without creating it.

func (*BlockDAG) Reset

func (b *BlockDAG) Reset()

Reset resets the component to a clean state as if it was created at the last commitment.

func (*BlockDAG) Shutdown

func (b *BlockDAG) Shutdown()