reaping

Documentation

Index

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

Constants

const DefaultInterval = 1 * time.Second

DefaultInterval is the default reaper interval

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,
	scrapeInterval time.Duration,
) (*Reaper, error)

NewReaper creates a new Reaper instance with persistent seenTx storage.

func (*Reaper) SeenStore

func (r *Reaper) SeenStore() ds.Datastore

SeenStore returns the datastore used to track seen transactions.

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()

SubmitTxs retrieves transactions from the executor and submits them to the sequencer.