import { type LivingMemoryLogger } from '../../logging/logger';
import type { LivingMemoryAgenticRecallExecutor } from './agentic_recall';
import type { JobRepository, LivingMemoryConfig, SnapshotRepository } from '../../../contracts/workflows';
import type { MessageLogRegistry } from '../../transcript/message_log/message_log_registry';
import type { LivingMemoryTranscriptMessage, MemoryScope } from '../../../contracts/memory';
type LivingMemoryRecallCoordinatorConfig = Pick<LivingMemoryConfig, 'recallIntervalMessages' | 'subModel'>;
/** 召回间隔锚点所需的消息日志读取面。 */
type RecallMessageLog = Pick<MessageLogRegistry, 'tailSeq'>;
type RecallAgenticExecutor = Pick<LivingMemoryAgenticRecallExecutor, 'run'>;
export type RecallWorkflowRepository = Pick<JobRepository, 'createFailedJob'> & Pick<SnapshotRepository, 'upsertSnapshot' | 'getLatestSnapshotByScope'>;
export declare class LivingMemoryRecallCoordinator {
    private readonly config;
    private readonly messageLog;
    private readonly repository;
    private readonly agenticRecall;
    private readonly logger;
    private readonly recallLockByConversation;
    /**
     * 召回窗口锚点：上次实际执行召回时点的日志末序号。间隔按此后累计
     * 进入日志的消息条数（含闲聊）计；锚点只在召回实际执行时前移，
     * 召回失败时清除，使下次触发立即重试。
     */
    private readonly anchorSeqByScope;
    constructor(config: LivingMemoryRecallCoordinatorConfig, messageLog: RecallMessageLog, repository: RecallWorkflowRepository, agenticRecall: RecallAgenticExecutor, logger: LivingMemoryLogger);
    queue(scope: MemoryScope, currentMessage: LivingMemoryTranscriptMessage, loadHistoryMessages: () => Promise<LivingMemoryTranscriptMessage[]>): Promise<void>;
    clearAll(): void;
    clearByConversation(conversationId: string): void;
    private run;
}
export {};