EventRepository

Functions

abstract suspend fun acknowledgeMissedEvent(): <Error class: unknown class><<Error class: unknown class>, Unit>

Performs an acknowledgment of the missed event after performing a slow sync.

abstract suspend fun clearLastSavedEventId(): <Error class: unknown class><<Error class: unknown class>, Unit>

Clears the last saved event ID.

abstract suspend fun fetchMostRecentEventId(): <Error class: unknown class><<Error class: unknown class>, String>

abstract suspend fun fetchOldestAvailableEventId(): <Error class: unknown class><<Error class: unknown class>, String>

Fetches the oldest available event ID from remote.

abstract suspend fun lastSavedEventId(): <Error class: unknown class><<Error class: unknown class>, String>

Retrieves the last saved event ID from the storage.

abstract suspend fun liveEvents(): <Error class: unknown class><<Error class: unknown class>, <Error class: unknown class><IncrementalSyncPhase>>

abstract suspend fun observeEvents(): <Error class: unknown class><List<EventEnvelope>>

abstract fun parseExternalEvents(data: String): List<EventEnvelope>

Parse events from an external JSON payload

abstract suspend fun setEventAsProcessed(eventId: String): <Error class: unknown class><<Error class: unknown class>, Unit>

abstract suspend fun updateLastSavedEventId(eventId: String): <Error class: unknown class><<Error class: unknown class>, Unit>

Updates the last saved event ID.