export declare const OPLOG_COLLECTION = "oplog.rs";
export declare function idForOp(op: any): any;
export declare class OplogHandle {
    private _oplogUrl;
    private _dbName;
    private _oplogLastEntryConnection;
    private _oplogTailConnection;
    private _stopped;
    private _tailHandle;
    private _crossbar;
    private _baseOplogSelector;
    private _catchingUpFutures;
    private _onSkippedEntriesHook;
    private _entryQueue;
    private _workerActive;
    private _lastProcessedTS;
    private _readyFuture;
    constructor(oplogUrl: string, dbName: string);
    stop(): void;
    onOplogEntry(trigger: Record<string, any>, callback: (notification: Record<string, any>) => void): Promise<{
        stop: () => void;
    }>;
    onSkippedEntries(callback: any): {
        callback: any;
        stop: () => void;
    };
    waitUntilCaughtUp(): Promise<void>;
    _startTailing(): Promise<void>;
    _maybeStartWorker(): void;
    _setLastProcessedTS(ts: any): void;
    _defineTooFarBehind(value: any): void;
    _resetTooFarBehind(): void;
}
export declare function _sleepForMs(ms: number): Promise<unknown>;
export declare function _escapeRegExp(s: string): string;