import { ClientPresenceRef, Commit, CommitRepository, ErrorCode, GetRemoteFn, LocalStore, OnStoreEventFn, SyncEvent } from './types';
import { LeaderSettings } from './lib/LeaderManager';
import { EventChannel } from './lib/EventChannel';
export declare type NetworkSettings = Readonly<{
    initialDelayMs: number;
    reconnectBackoffMultiplier: number;
    maxReconnectDelayMs: number;
} & LeaderSettings>;
export declare class CoordinatingLocalStore<CommitMetadata, Delta, Presence> implements LocalStore<CommitMetadata, Delta, Presence> {
    protected readonly userId: string;
    protected readonly clientId: string;
    private readonly onStoreEvent;
    private readonly commitRepo;
    private readonly getRemote?;
    private localChannel?;
    private closed;
    private presence;
    private remote;
    private reconnectTimeout;
    private reconnectDelayMs;
    private remoteSyncState;
    private readonly unacknowledgedRefs;
    private readonly localQueue;
    private readonly remoteQueue;
    private leaderManager?;
    private readonly networkSettings;
    private initialized;
    constructor(userId: string, clientId: string, onStoreEvent: OnStoreEventFn<CommitMetadata, Delta, Presence>, commitRepo: CommitRepository<CommitMetadata, Delta, Presence>, getRemote?: GetRemoteFn<CommitMetadata, Delta, Presence> | undefined, networkSettings?: Partial<NetworkSettings>, localChannel?: EventChannel<CommitMetadata, Delta, Presence> | undefined);
    get isRemoteLeader(): boolean;
    private get clientInfo();
    private setRemoteState;
    protected processEvent: (event: SyncEvent<CommitMetadata, Delta, Presence>, origin: 'local' | 'remote' | 'remote-via-local') => Promise<void>;
    private sendRemoteStatus;
    private onLocalBroadcastEvent;
    shutdown(): Promise<void>;
    private closeRemote;
    private connectRemote;
    private clearReconnectTimeout;
    protected handleAsError(code: ErrorCode): (error: Error) => void;
    protected sendEvent(event: SyncEvent<CommitMetadata, Delta, Presence>, { remote, local, self, }: {
        remote?: boolean;
        local?: boolean;
        self?: boolean;
    }, remoteOrigin?: boolean): Promise<void>;
    private initialize;
    update(commits: Commit<CommitMetadata, Delta>[], presence: ClientPresenceRef<Presence> | undefined): Promise<void>;
    private doUpdate;
}