import { AsyncEventEmitter } from '@vladfrangu/async_event_emitter';
import { ArangoCollection } from 'arangojs/collection.js';
import { AqStrict, AqQuery, AqBuilder } from 'aql-builder';
import { Entity, JobStatus } from '../../index.js';
/**
 * Options to manage the {@link WorkerQuery}'s rate and concurrency.
 */
export interface WorkerQueryOptions extends Record<string, unknown> {
    /**
     * The number of workers to run simultaneously.
     *
     * @defaultValue 1
     */
    concurrency?: number;
    /**
     * The maximum number of workers to launch within the interval period.
     * Setting the limit to -1 disables rate limiting.
     *
     * @defaultValue Infinity
     */
    intervalCap?: number;
    /**
     * The time (in ms) that the limit applies to.
     *
     * @defaultValue 0
     */
    interval?: number;
}
type WorkerEventMap = Record<PropertyKey, unknown[]> & {
    progress: [status: JobStatus, item?: Entity, message?: string];
    failure: [status: JobStatus, error?: Error, message?: string];
    end: [status: JobStatus];
};
type WorkerEventType = keyof WorkerEventMap;
type WorkerEventParams<T extends WorkerEventType> = WorkerEventMap[T];
type WorkerEventListener<T extends WorkerEventType> = (...args: WorkerEventParams<T>) => unknown;
export type WorkerQueryTask<T extends Entity = Entity> = (item: T, status: JobStatus) => Promise<string | void>;
export declare class WorkerQuery<T extends Entity = Entity> extends AqBuilder {
    protected events: AsyncEventEmitter<WorkerEventMap>;
    status: JobStatus;
    options: Required<WorkerQueryOptions>;
    /**
     * Returns a new {@link AqBuilder} containing a buildable {@link AqStrict}.
     */
    constructor(input: string | ArangoCollection | AqStrict | AqQuery, options?: WorkerQueryOptions);
    on<T extends WorkerEventType>(event: T, listener: WorkerEventListener<T>): this;
    off<T extends WorkerEventType>(event: T, listener: WorkerEventListener<T>): this;
    return(): this;
    run(task?: WorkerQueryTask<T>): Promise<JobStatus>;
    protected performTask(id: string, task: WorkerQueryTask<T>): Promise<void>;
    protected updateStatus(success?: boolean): void;
}
export {};
//# sourceMappingURL=worker-query.d.ts.map