EventDAOImpl

class EventDAOImpl(eventsQueries: EventsQueries, readDispatcher: ReadDispatcher, writeDispatcher: WriteDispatcher) : EventDAO

Constructors

constructor(eventsQueries: EventsQueries, readDispatcher: ReadDispatcher, writeDispatcher: WriteDispatcher)

open suspend override fun deleteAllProcessedEvents()

open suspend override fun deleteProcessedEventsBefore(id: Long)

open suspend override fun deleteUnprocessedLiveEventsByIds(ids: List<String>)

open suspend override fun getEventById(id: String): EventEntity?

open suspend override fun insertEvents(events: List<NewEventEntity>)

open suspend override fun markEventAsProcessed(eventId: String)

open suspend override fun markEventsAsProcessed(eventIds: List<String>)

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

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