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

Package-level declarations

Types

EventBatchProcessor

internal interface EventBatchProcessor

Applies one gathered app event batch and completes its queue acknowledgement.

EventBatchRecovery

internal interface EventBatchRecovery

Durable evidence and queue completion behind the batch module's internal recovery seam.

internal interface EventGatherer

Orchestrates the reception of events from remote sources, coordinating between historical (pending) and real-time (live) event delivery modes.

EventGathererImpl

internal class EventGathererImpl(isClientAsyncNotificationsCapableProvider: IsClientAsyncNotificationsCapableProvider, eventRepository: EventRepository, logger: KaliumLogger = 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.

internal interface EventProcessor

Handles processing of incoming Events received via sync or WebSocket.

EventProcessorImpl

internal class EventProcessorImpl(conversationEventReceiver: ConversationEventReceiver, userEventReceiver: UserEventReceiver, teamEventReceiver: TeamEventReceiver, featureConfigEventReceiver: FeatureConfigEventReceiver, userPropertiesEventReceiver: UserPropertiesEventReceiver, federationEventReceiver: FederationEventReceiver, meetingEventReceiver: MeetingEventReceiver, processingScope: CoroutineScope, logger: KaliumLogger = kaliumLogger) : EventProcessor

internal enum EventSource : Enum<EventSource>

Informs where an event came from.

EventStreamData

internal sealed interface EventStreamData

IncrementalSyncManager

internal interface IncrementalSyncManager

Starts and Stops Incremental Sync.

IncrementalSyncPhase

internal sealed class IncrementalSyncPhase

Incremental sync can be divided into two phases

IncrementalSyncRecoveryHandler

internal interface IncrementalSyncRecoveryHandler

Represents a handler for recovering from incremental sync.

IncrementalSyncRecoveryHandlerImpl

internal class IncrementalSyncRecoveryHandlerImpl(restartSlowSyncProcessForRecoveryUseCase: RestartSlowSyncProcessForRecoveryUseCase, eventRepository: EventRepository, logger: KaliumLogger = kaliumLogger) : IncrementalSyncRecoveryHandler

Implementation of the IncrementalSyncRecoveryHandler interface.

IncrementalSyncWorker

internal interface IncrementalSyncWorker

Gathers app event batches and publishes incremental sync progress.

IncrementalSyncWorkerImpl

internal class IncrementalSyncWorkerImpl(eventGatherer: EventGatherer, batchProcessor: EventBatchProcessor, logger: KaliumLogger = kaliumLogger, consumePendingAccountInvalidation: suspend () -> Boolean = { false }, consumePendingLegalHoldTransitions: suspend () -> Unit = {}, consumePendingConversationCleanup: suspend () -> Unit = {}) : IncrementalSyncWorker

OnIncrementalSyncRetryCallback

internal fun interface OnIncrementalSyncRetryCallback

Functions

IncrementalSyncManager

internal fun IncrementalSyncManager(incrementalSyncWorker: IncrementalSyncWorker, incrementalSyncRepository: IncrementalSyncRepository, incrementalSyncRecoveryHandler: IncrementalSyncRecoveryHandler, networkStateObserver: NetworkStateObserver, userScopedLogger: KaliumLogger, userSessionWorkScheduler: UserSessionWorkScheduler, retryController: SyncRetryController = SyncRetryController(), exponentialDurationHelper: ExponentialDurationHelper = ExponentialDurationHelper( IncrementalSyncManager.MIN_RETRY_DELAY, IncrementalSyncManager.MAX_RETRY_DELAY )): IncrementalSyncManager