EventBatchRecovery
Durable evidence and queue completion behind the batch module's internal recovery seam.
Inheritors
Functions
Link copied to clipboard
Link copied to clipboard
abstract suspend fun recordProcessed(context: CryptoTransactionContext, events: List<EventEnvelope>)
Link copied to clipboard
abstract suspend fun wereEffectsProcessed(context: CryptoTransactionContext, envelope: EventEnvelope): Boolean