processor

type Config struct {
	// Processing interval
	Interval time.Duration `yaml:"interval"`

	// Processing mode: forwards, backwards
	Mode string `yaml:"mode"`

	// Maximum concurrent transactions to process
	Concurrency int `yaml:"concurrency"`

	// Leader election configuration
	LeaderElection LeaderElectionConfig `yaml:"leaderElection"`

	// Queue control configuration
	MaxProcessQueueSize    int     `yaml:"maxProcessQueueSize"`
	BackpressureHysteresis float64 `yaml:"backpressureHysteresis"`

	// Stale block detection configuration
	StaleBlockDetection StaleBlockDetectionConfig `yaml:"staleBlockDetection"`

	// Gap detection configuration
	GapDetection GapDetectionConfig `yaml:"gapDetection"`

	// Processor configurations
	TransactionStructlog    structlog.Config     `yaml:"transactionStructlog"`
	TransactionSimple       simple.Config        `yaml:"transactionSimple"`
	TransactionStructlogAgg structlog_agg.Config `yaml:"transactionStructlogAgg"`
}

type GapDetectionConfig struct {
	// Enabled enables gap detection (default: false)
	Enabled bool `yaml:"enabled"`

	// ScanInterval is how often to scan for gaps (default: 5m)
	ScanInterval time.Duration `yaml:"scanInterval"`

	// BatchSize is max gaps to process per scan (default: 10)
	BatchSize int `yaml:"batchSize"`

	// LookbackRange is max blocks to look back, 0 = unlimited (default: 10000)
	LookbackRange uint64 `yaml:"lookbackRange"`
}

type LeaderElectionConfig struct {
	// Enable leader election (default: true)
	Enabled bool `yaml:"enabled"`

	// TTL for leader lock (default: 10s)
	TTL time.Duration `yaml:"ttl"`

	// Renewal interval (default: 3s)
	RenewalInterval time.Duration `yaml:"renewalInterval"`

	// Optional node ID (auto-generated if empty)
	NodeID string `yaml:"nodeId"`
}

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

type QueueResult struct {
	TransactionCount int
	TasksCreated     int
}

type StaleBlockDetectionConfig struct {
	// Enabled enables stale block detection (default: true)
	Enabled bool `yaml:"enabled"`

	// StaleThreshold is the time after which a block is considered stale (default: 5m)
	StaleThreshold time.Duration `yaml:"staleThreshold"`

	// CheckInterval is how often to check for stale blocks (default: 1m)
	CheckInterval time.Duration `yaml:"checkInterval"`
}

type WorkerConfig struct {
	Enabled     bool `yaml:"enabled"`
	Concurrency int  `yaml:"concurrency"`
}