EventBatchRecovery

internal interface EventBatchRecovery

Durable evidence and queue completion behind the batch module's internal recovery seam.

Inheritors

Functions

Link copied to clipboard
abstract suspend fun acknowledge(eventIds: List<String>)
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