EventDAO

interface EventDAO

Functions

abstract suspend fun deleteProcessedEventsBefore(id: Long)

abstract suspend fun getEventById(id: String): EventEntity?

abstract suspend fun insertEvents(events: List<NewEventEntity>)

abstract suspend fun markEventAsProcessed(eventId: String)

abstract suspend fun observeEvents(fromIdExclusive: Long): <Error class: unknown class><List<EventEntity>>

abstract suspend fun observeUnprocessedEvents(): <Error class: unknown class><List<EventEntity>>