logic/com.wire.kalium.logic.sync.incremental

Package-level declarations

Types

Responsible for fetching events from a remote source, orchestrating between events missed since the last time we gathered events and new events being received in real time.

EventGathererImpl

internal class EventGathererImpl(isClientAsyncNotificationsCapableProvider: IsClientAsyncNotificationsCapableProvider, eventRepository: EventRepository, serverTimeHandler: ServerTimeHandler = ServerTimeHandlerImpl(), processingScope: <Error class: unknown class>, liveSourceChangeHandler: LiveSourceChangeHandler = LiveSourceChangeHandlerImpl(processingScope), logger: <Error class: unknown class> = kaliumLogger) : EventGatherer

EventProcessingHistory

internal class EventProcessingHistory

In-memory event storage, used to check if an event was already dealt with and avoid duplication. i.e. present in both pending and live sources.

EventProcessor

internal interface EventProcessor

Handles incoming events from remote.

EventProcessorImpl

internal class EventProcessorImpl(eventRepository: EventRepository, conversationEventReceiver: ConversationEventReceiver, userEventReceiver: UserEventReceiver, teamEventReceiver: TeamEventReceiver, featureConfigEventReceiver: FeatureConfigEventReceiver, userPropertiesEventReceiver: UserPropertiesEventReceiver, federationEventReceiver: FederationEventReceiver, missedNotificationsEventReceiver: MissedNotificationsEventReceiver, processingScope: <Error class: unknown class>, logger: <Error class: unknown class> = kaliumLogger) : EventProcessor

EventSource

enum EventSource : Enum<EventSource>

Informs where an event came from.

IncrementalSyncManager

internal interface IncrementalSyncManager

Starts and Stops Incremental Sync.

IncrementalSyncRecoveryHandler

internal interface IncrementalSyncRecoveryHandler

Represents a handler for recovering from incremental sync.

IncrementalSyncRecoveryHandlerImpl

internal class IncrementalSyncRecoveryHandlerImpl(restartSlowSyncProcessForRecoveryUseCase: RestartSlowSyncProcessForRecoveryUseCase, eventRepository: EventRepository, logger: <Error class: unknown class> = kaliumLogger) : IncrementalSyncRecoveryHandler

Implementation of the IncrementalSyncRecoveryHandler interface.

IncrementalSyncWorker

interface IncrementalSyncWorker

Gathers and processes IncrementalSync events.

IncrementalSyncWorkerImpl

internal class IncrementalSyncWorkerImpl(eventGatherer: EventGatherer, eventProcessor: EventProcessor, logger: <Error class: unknown class> = kaliumLogger) : IncrementalSyncWorker

LiveSourceChangeHandler

interface LiveSourceChangeHandler

Handles the change of the event source from pending to live after opening a Websocket connection. It is used to manage the catching up job that processes events when the websocket is opened to mimic the behavior of the old quick sync that was used to fetch pending events from the notification stream.

LiveSourceChangeHandlerImpl

internal class LiveSourceChangeHandlerImpl(processingScope: <Error class: unknown class>) : LiveSourceChangeHandler

OnIncrementalSyncRetryCallback

internal fun interface OnIncrementalSyncRetryCallback

Functions

IncrementalSyncManager

internal fun IncrementalSyncManager(incrementalSyncWorker: IncrementalSyncWorker, incrementalSyncRepository: IncrementalSyncRepository, incrementalSyncRecoveryHandler: IncrementalSyncRecoveryHandler, networkStateObserver: <Error class: unknown class>, userScopedLogger: <Error class: unknown class>, exponentialDurationHelper: ExponentialDurationHelper = ExponentialDurationHelperImpl( IncrementalSyncManager.MIN_RETRY_DELAY, IncrementalSyncManager.MAX_RETRY_DELAY )): IncrementalSyncManager