EventDAO

interface EventDAO

Types

abstract suspend fun deleteProcessedEventsBefore(id: Long)

abstract suspend fun deleteUnprocessedLiveEventsByIds(ids: List<String>)

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

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

abstract suspend fun markEventAsProcessed(eventId: String)

abstract suspend fun markEventsAsProcessed(eventIds: List<String>)

abstract fun observeEvents(fromIdExclusive: Long): Flow<List<EventEntity>>

abstract fun observeUnprocessedEvents(limit: Long = DEFAULT_UNPROCESSED_EVENTS_LIMIT): Flow<List<EventEntity>>