import type { LivingMemoryDreamJobRunner } from './job_runner';
import type { LivingMemoryLogger } from '../../logging/logger';
import type { DreamTriggerResult, JobRepository } from '../../../contracts/workflows';
export type DreamCoordinatorRepository = Pick<JobRepository, 'createJob' | 'markStaleRunningJobsAsFailed'> & {
    countActiveEntries(presetId: string): Promise<number>;
};
export declare class LivingMemoryDreamCoordinator {
    private readonly jobRunner;
    private readonly repository;
    private readonly logger;
    private readonly queue;
    private readonly pendingByPreset;
    private readonly runningJobs;
    private readonly controller;
    private readonly tasks;
    constructor(jobRunner: Pick<LivingMemoryDreamJobRunner, 'run'>, repository: DreamCoordinatorRepository, logger: LivingMemoryLogger);
    start(presetId: string): Promise<DreamTriggerResult>;
    queueAfterExtraction(presetId: string, memoryIds: string[]): void;
    private enqueue;
    private runJob;
    stop(): Promise<void>;
}