OpOutboxDao

interface OpOutboxDao

Functions

Link copied to clipboard
abstract suspend fun dead(): List<OpOutboxEntity>
Link copied to clipboard
abstract suspend fun delete(id: String)
Link copied to clipboard
abstract suspend fun insert(entity: OpOutboxEntity)
Link copied to clipboard
abstract suspend fun markDead(id: String, error: String?)
Link copied to clipboard
abstract fun observeLive(): Flow<List<OpOutboxEntity>>

Live (non-dead) ops, oldest-first — the observable queue for UI.

Link copied to clipboard
abstract suspend fun pending(): List<OpOutboxEntity>

PENDING ops, oldest-first — the replay drain order.

Link copied to clipboard
abstract suspend fun recordFailure(id: String, error: String?)
Link copied to clipboard
abstract suspend fun requeue(id: String)