processBatch performs one periodic stuck-queue recovery pass using the configured threshold.
(ctx context.Context)
| 120 | |
| 121 | // processBatch performs one periodic stuck-queue recovery pass using the configured threshold. |
| 122 | func (p *QueuedTransactionRecoveryProcessor) processBatch(ctx context.Context) { |
| 123 | p.recoverWithThreshold(ctx, p.stuckThreshold) |
| 124 | } |
| 125 | |
| 126 | // RecoverQueuedTransactions triggers an immediate recovery of stuck queued transactions |
| 127 | // using the provided threshold. This is exposed for the manual trigger API endpoint. |
no test coverage detected