EventRepository

interface EventRepository

Inheritors

Functions

Link copied to clipboard
abstract suspend fun clearLastProcessedEventId(): Either<StorageFailure, Unit>

Clears the last processed event ID.

Link copied to clipboard
abstract suspend fun fetchMostRecentEventId(): Either<CoreFailure, String>
Link copied to clipboard
abstract suspend fun fetchOldestAvailableEventId(): Either<CoreFailure, String>

Fetches the oldest available event ID from remote.

Link copied to clipboard
abstract suspend fun fetchServerTime(): String?
Link copied to clipboard
abstract suspend fun lastProcessedEventId(): Either<StorageFailure, String>

Retrieves the last processed event ID from the storage.

Link copied to clipboard
abstract suspend fun liveEvents(): Either<CoreFailure, <Error class: unknown class><<Error class: unknown class><EventEnvelope>>>
Link copied to clipboard
abstract fun parseExternalEvents(data: String): List<EventEnvelope>

Parse events from an external JSON payload

Link copied to clipboard
abstract suspend fun pendingEvents(): <Error class: unknown class><Either<CoreFailure, EventEnvelope>>
Link copied to clipboard
abstract suspend fun updateLastProcessedEventId(eventId: String): Either<StorageFailure, Unit>