presolidblockfilter

Documentation

Index

• Variables
• func NewProvider(opts ...options.Option[PreSolidBlockFilter]) module.Provider[*engine.Engine, presolidfilter.PreSolidFilter]
• type PreSolidBlockFilter
  • func New(subModule module.Module, apiProvider iotago.APIProvider, ...) *PreSolidBlockFilter
  • func (f *PreSolidBlockFilter) Init(committeeFunc func(iotago.SlotIndex) (*account.SeatedAccounts, bool))
  • func (f *PreSolidBlockFilter) ProcessReceivedBlock(block *model.Block, source peer.ID)
  • func (f *PreSolidBlockFilter) Reset()

Variables

var (
	ErrValidatorNotInCommittee = ierrors.New("validation block issuer is not in the committee")
	ErrInvalidBlockVersion     = ierrors.New("block has invalid protocol version")
)

Functions

func NewProvider

func NewProvider(opts ...options.Option[PreSolidBlockFilter]) module.Provider[*engine.Engine, presolidfilter.PreSolidFilter]

Types

type PreSolidBlockFilter

type PreSolidBlockFilter struct {
	module.Module
	// contains filtered or unexported fields
}

PreSolidBlockFilter filters blocks.

func New

func New(subModule module.Module, apiProvider iotago.APIProvider, opts ...options.Option[PreSolidBlockFilter]) *PreSolidBlockFilter

New creates a new PreSolidBlockFilter.

func (*PreSolidBlockFilter) Init

func (f *PreSolidBlockFilter) Init(committeeFunc func(iotago.SlotIndex) (*account.SeatedAccounts, bool))

Init initializes the PreSolidBlockFilter.

func (*PreSolidBlockFilter) ProcessReceivedBlock

func (f *PreSolidBlockFilter) ProcessReceivedBlock(block *model.Block, source peer.ID)

ProcessReceivedBlock processes block from the given source.

func (*PreSolidBlockFilter) Reset

func (f *PreSolidBlockFilter) Reset()

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