import type { EmbeddingDrainResult, EmbeddingRuntime } from './types.js';
export declare const DEFAULT_EMBEDDING_WORKER_INTERVAL_MS = 5000;
export declare const DEFAULT_EMBEDDING_WORKER_MAX_JOBS = 64;
export declare const DEFAULT_EMBEDDING_WORKER_DEADLINE_MS = 120000;
export interface EmbeddingWorkerOptions {
    readonly runtime: EmbeddingRuntime;
    readonly intervalMs?: number;
    readonly maxJobs?: number;
    readonly deadlineMs?: number;
    readonly setTimeout?: typeof setTimeout;
    readonly clearTimeout?: typeof clearTimeout;
    readonly onDrain?: (result: EmbeddingDrainResult) => void | PromiseLike<void>;
    readonly onError?: (error: unknown) => void | PromiseLike<void>;
}
export interface EmbeddingWorker {
    readonly running: boolean;
    start(): void;
    stop(): void;
    close(): Promise<void>;
}
/** Run bounded embedding drains without overlapping provider calls or timers. */
export declare function createEmbeddingWorker(options: EmbeddingWorkerOptions): EmbeddingWorker;
//# sourceMappingURL=worker.d.ts.map