Function NewQueuedTransactionRecoveryProcessor

queue_recovery.go:47–58

NewQueuedTransactionRecoveryProcessor creates the stuck queued-transaction recovery loop with conservative single-worker defaults to avoid recovery-induced lock storms.

(ledgerforge *LedgerForge)

// NewQueuedTransactionRecoveryProcessor creates the stuck queued-transaction recovery loop
// with conservative single-worker defaults to avoid recovery-induced lock storms.
func NewQueuedTransactionRecoveryProcessor(ledgerforge *LedgerForge) *QueuedTransactionRecoveryProcessor {
	return &QueuedTransactionRecoveryProcessor{
		ledgerforge:              ledgerforge,
		batchSize:                100,
		maxWorkers:               1,
		pollInterval:             30 * time.Second,
		stuckThreshold:           2 * time.Hour,
		maxRecoveryAttempts:      3,
		stopCh:                   make(chan struct{}),
		processQueuedTransaction: ledgerforge.processQueuedTransaction,
	}
}

// Start begins the background recovery loop for stuck queued transactions.
func (p *QueuedTransactionRecoveryProcessor) Start(ctx context.Context) {