persistence/com.wire.kalium.persistence.dao.event/EventDAOImpl

EventDAOImpl

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

Constructors

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

Functions

deleteAllProcessedEvents

open suspend override fun deleteAllProcessedEvents()

deleteProcessedEventsBefore

open suspend override fun deleteProcessedEventsBefore(id: Long)

deleteUnprocessedLiveEventsByIds

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

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

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

markEventAsProcessed

open suspend override fun markEventAsProcessed(eventId: String)

markEventsAsProcessed

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

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

observeUnprocessedEvents

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

setAllUnprocessedEventsAsPending

open suspend override fun setAllUnprocessedEventsAsPending()

storeFetchedPage

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

App REST page persistence, including its last nontransient cursor, in one transaction.