AccountOperations

Durable outgoing-operation state and observation.

Functions

Link copied to clipboard
suspend fun cancel(commandId: CommandId): OperationSnapshot

Cancel every unclaimed recipient copy that is still safe to cancel.

Link copied to clipboard
suspend fun get(commandId: CommandId): OperationSnapshot

Return one aggregate recipient-complete delivery state.

Link copied to clipboard
fun observe(commandId: CommandId): Flow<OperationSnapshot>

Observe one aggregate operation after durable account changes.

fun observe(limit: Int = 50): Flow<List<OperationSnapshot>>

Observe a bounded newest-first operation page.

Link copied to clipboard
suspend fun page(limit: Int = 50): List<OperationSnapshot>

Return a bounded newest-first page of all durable outgoing operations.

Link copied to clipboard
suspend fun retry(commandId: CommandId): OperationSnapshot

Requeue only terminally rejected recipient copies for explicit retry.