Documentation
¶
Index ¶
Constants ¶
View Source
const ( // MaxBackoffInterval is the maximum backoff interval for retries MaxBackoffInterval = 30 * time.Second // CleanupInterval is how often the reaper sweeps expired hashes // out of the seen-tx cache. CleanupInterval = max(cache.DefaultTxCacheRetention/10, 15*time.Second) )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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, cache cache.CacheManager, scrapeInterval time.Duration, onTxsSubmitted func(), ) (*Reaper, error)
Source Files
Click to show internal directories.
Click to hide internal directories.