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 getUnprocessedEvents(): List<EventEntity>

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

open suspend override fun markEventAsProcessed(eventId: String)

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

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