import { Db, Timestamp } from "mongodb";
import { CSEvent } from "./cs_event";
import { DripPipeline, DripProcessingPipeline } from "../drip_pipeline";
import { CEACursor } from "./cea_cursor";
import { CEAOptions } from "./options";
export declare function dripCEAStart(db: Db, collectionName: string, ccStart: Timestamp, pipeline: Readonly<DripPipeline>, processingPipeline?: Readonly<DripProcessingPipeline>, options?: Readonly<CEAOptions>): AsyncGenerator<CSEvent, void, void>;
export declare function dripCEAResume(db: Db, collectionName: string, cursor: CEACursor, pipeline: Readonly<DripPipeline>, processingPipeline?: Readonly<DripProcessingPipeline>, options?: Readonly<CEAOptions>): AsyncGenerator<CSEvent, void, void>;
export declare class CEACannotResumeError extends Error {
}
export declare class CEACursorNotFoundError extends CEACannotResumeError {
}
export declare class CEACursorTooOldError extends CEACannotResumeError {
}