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(eventRepository: EventRepository, incrementalSyncRepository: IncrementalSyncRepository, serverTimeHandler: ServerTimeHandler = ServerTimeHandlerImpl(), 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, 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 class IncrementalSyncManager(slowSyncRepository: SlowSyncRepository, incrementalSyncWorker: IncrementalSyncWorker, incrementalSyncRepository: IncrementalSyncRepository, incrementalSyncRecoveryHandler: IncrementalSyncRecoveryHandler, networkStateObserver: <Error class: unknown class>, logger: <Error class: unknown class> = kaliumLogger, kaliumDispatcher: <Error class: unknown class> = KaliumDispatcherImpl, exponentialDurationHelper: ExponentialDurationHelper = ExponentialDurationHelperImpl( MIN_RETRY_DELAY, MAX_RETRY_DELAY ))

Starts and Stops Incremental Sync once SlowSync is performed.

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

OnIncrementalSyncRetryCallback

internal fun interface OnIncrementalSyncRetryCallback