import type {
    MaybePromise,
    RxCollection,
    RxDocument
} from '../../types';


export type RxPipelineHandler<RxDocType> = (
    docs: RxDocument<RxDocType>[]
) => MaybePromise<any>;

export type RxPipelineOptions<RxDocType> = {
    /**
     * The identifier of the pipeline. Used when
     * metadata of the pipeline is stored. Changing the identifier.
     */
    identifier: string;
    destination: RxCollection<any>;
    handler: RxPipelineHandler<RxDocType>;
    waitForLeadership?: boolean;
    batchSize?: number;
}


export type CheckpointDocData<CheckpointType = any> = {
    checkpoint: CheckpointType;
    lastDocTime: number;
};