processor

Feb 4, 2026

Changes in this version

+ const DefaultBackpressureBackoffMax

+ const DefaultBackpressureBackoffMin

+ const DefaultBackpressureHysteresis

+ const DefaultBackpressureJitterFraction

+ const DefaultConcurrency

+ const DefaultGapBatchSize

+ const DefaultGapLookbackRange

+ const DefaultGapScanInterval

+ const DefaultLeaderRenewalInterval

+ const DefaultLeaderTTL

+ const DefaultMaxProcessQueue

+ const DefaultNoWorkBackoff

+ const DefaultStaleBlockCheckInterval

type Config

+ GapDetection GapDetectionConfig

+ StaleBlockDetection StaleBlockDetectionConfig

+ TransactionStructlogAgg structlog_agg.Config

+ type GapDetectionConfig struct

+ BatchSize int

+ Enabled bool

+ LookbackRange uint64

+ ScanInterval time.Duration

+ type StaleBlockDetectionConfig struct

+ CheckInterval time.Duration

+ Enabled bool

+ StaleThreshold time.Duration

Dec 2, 2025

Changes in this version

type Config

+ TransactionSimple simple.Config

Jun 20, 2025

Changes in this version

type Manager

+ func (m *Manager) GetQueueName() string

+ func (m *Manager) QueueBlockManually(ctx context.Context, processorName string, blockNumber uint64) (*QueueResult, error)

+ type QueueResult struct

+ TasksCreated int

+ TransactionCount int

Jun 4, 2025

Changes in this version

type Config

+ BackpressureHysteresis float64

+ MaxProcessQueueSize int

Jun 1, 2025

Changes in this version

+ type Config struct

+ Concurrency int

+ Interval time.Duration

+ LeaderElection LeaderElectionConfig

+ Mode string

+ TransactionStructlog structlog.Config

+ func (c *Config) Validate() error

+ type LeaderElectionConfig struct

+ Enabled bool

+ NodeID string

+ RenewalInterval time.Duration

+ TTL time.Duration

+ type Manager struct

+ func NewManager(log logrus.FieldLogger, config *Config, pool *ethereum.Pool, state *s.Manager, ...) (*Manager, error)

+ func (m *Manager) Start(ctx context.Context) error

+ func (m *Manager) Stop(ctx context.Context) error

+ type WorkerConfig struct

+ Concurrency int

+ Enabled bool