reaping

Documentation

Index

• Constants
• type Reaper
  • func NewReaper(exec coreexecutor.Executor, sequencer coresequencer.Sequencer, ...) (*Reaper, error)
  • func (r *Reaper) Start(ctx context.Context) error
  • func (r *Reaper) Stop() error
  • func (r *Reaper) SubmitTxs() error

Constants

const (
	// DefaultInterval is the default reaper interval
	DefaultInterval = 1 * time.Second
	// MaxBackoffInterval is the maximum backoff interval for retries
	MaxBackoffInterval = 30 * time.Second
	// BackoffMultiplier is the multiplier for exponential backoff
	BackoffMultiplier = 2
)

Types

type Reaper

type Reaper struct {
	// contains filtered or unexported fields
}

Reaper is responsible for periodically retrieving transactions from the executor, filtering out already seen transactions, and submitting new transactions to the sequencer.

func NewReaper

func NewReaper(
	exec coreexecutor.Executor,
	sequencer coresequencer.Sequencer,
	genesis genesis.Genesis,
	logger zerolog.Logger,
	executor *executing.Executor,
	cache cache.Manager,
	scrapeInterval time.Duration,
) (*Reaper, error)

NewReaper creates a new Reaper instance.

func (*Reaper) Start

func (r *Reaper) Start(ctx context.Context) error

Start begins the execution component

func (*Reaper) Stop

func (r *Reaper) Stop() error

Stop shuts down the reaper component

func (*Reaper) SubmitTxs

func (r *Reaper) SubmitTxs() error

SubmitTxs retrieves transactions from the executor and submits them to the sequencer. Returns an error if any critical operation fails.