hub / github.com/devaccuracy/ledgerforge / NewQueuedTransactionRecoveryProcessor

Function NewQueuedTransactionRecoveryProcessor

queue_recovery.go:47–58 · view source on GitHub ↗

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

(ledgerforge *LedgerForge)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 6

workerCommandsFunction · 0.92

RecoverQueuedTransactionsMethod · 0.85

TestNewQueuedTransactionRecoveryProcessor_UsesSingleWorkerFunction · 0.85

TestProcessStuckTransaction_UsesCoalescingBeforeDirectReplayFunction · 0.85

TestProcessStuckTransaction_UsesHotLaneCoalescingWhenMarkedHotFunction · 0.85

TestProcessStuckTransaction_FallsBackToDirectReplayWhenBatchNotHandledFunction · 0.85

Calls

no outgoing calls

Tested by 4

TestNewQueuedTransactionRecoveryProcessor_UsesSingleWorkerFunction · 0.68

TestProcessStuckTransaction_UsesCoalescingBeforeDirectReplayFunction · 0.68

TestProcessStuckTransaction_UsesHotLaneCoalescingWhenMarkedHotFunction · 0.68

TestProcessStuckTransaction_FallsBackToDirectReplayWhenBatchNotHandledFunction · 0.68