EventDAOImpl

class EventDAOImpl(eventsQueries: EventsQueries, queriesContext: <Error class: unknown class>) : EventDAO

Constructors

constructor(eventsQueries: EventsQueries, queriesContext: <Error class: unknown class>)

open suspend override fun deleteAllProcessedEvents()

open suspend override fun deleteProcessedEventsBefore(id: Long)

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 observeEvents(fromIdExclusive: Long): <Error class: unknown class><List<EventEntity>>

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