passthrough

Documentation

Index

• func NewProvider() module.Provider[*engine.Engine, scheduler.Scheduler]
• type Scheduler
  • func New(subModule module.Module) *Scheduler
  • func (s *Scheduler) AddBlock(block *blocks.Block)
  • func (s *Scheduler) BasicBufferSize() int
  • func (s *Scheduler) IsBlockIssuerReady(_ iotago.AccountID, _ ...iotago.WorkScore) bool
  • func (s *Scheduler) IssuerQueueBlockCount(_ iotago.AccountID) int
  • func (s *Scheduler) IssuerQueueWork(_ iotago.AccountID) iotago.WorkScore
  • func (s *Scheduler) ReadyBlocksCount() int
  • func (s *Scheduler) Reset()
  • func (s *Scheduler) ValidatorBufferSize() int
  • func (s *Scheduler) ValidatorQueueBlockCount(_ iotago.AccountID) int

Functions

func NewProvider

func NewProvider() module.Provider[*engine.Engine, scheduler.Scheduler]

Types

type Scheduler

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

func New

func New(subModule module.Module) *Scheduler

func (*Scheduler) AddBlock

func (s *Scheduler) AddBlock(block *blocks.Block)

func (*Scheduler) BasicBufferSize

func (s *Scheduler) BasicBufferSize() int

func (*Scheduler) IsBlockIssuerReady

func (s *Scheduler) IsBlockIssuerReady(_ iotago.AccountID, _ ...iotago.WorkScore) bool

func (*Scheduler) IssuerQueueBlockCount

func (s *Scheduler) IssuerQueueBlockCount(_ iotago.AccountID) int

func (*Scheduler) IssuerQueueWork

func (s *Scheduler) IssuerQueueWork(_ iotago.AccountID) iotago.WorkScore

func (*Scheduler) ReadyBlocksCount

func (s *Scheduler) ReadyBlocksCount() int

func (*Scheduler) Reset

func (s *Scheduler) Reset()

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

func (*Scheduler) ValidatorBufferSize

func (s *Scheduler) ValidatorBufferSize() int

func (*Scheduler) ValidatorQueueBlockCount

func (s *Scheduler) ValidatorQueueBlockCount(_ iotago.AccountID) int