import type { WorkflowCheckpoint } from '../agent/workflow.js';
import type { ActiveRun, BufferedEvent, EventSubscriber, RunSnapshot } from './run-registry.js';
/** Agent 运行会话注册表接口 */
export interface RunRegistryInterface {
    /** 设置空闲超时回调 */
    setIdleTimeoutHandler(handler: (threadId: number | string, sessionId: string) => void): void;
    /** 启用/禁用空闲超时检测 */
    setIdleTimeoutEnabled(enabled: boolean): void;
    /** 注册一个新的运行 */
    startRun(threadId: number | string, sessionId: string, traceId?: string): ActiveRun;
    /** 获取运行记录 */
    getRun(threadId: number | string): ActiveRun | null;
    /** 是否有活跃运行 */
    hasActiveRun(threadId: number | string): boolean;
    /** 标记运行为暂停（agent loop 将在 turn 边界挂起）。返回是否存在该运行。 */
    pauseAgent(threadId: number | string): boolean;
    /** 恢复暂停的运行。返回是否存在该运行。 */
    resumeAgent(threadId: number | string): boolean;
    /** 查询运行是否处于暂停状态 */
    isPaused(threadId: number | string): boolean;
    /** 添加事件到缓冲区并通知所有订阅者 */
    addEvent(threadId: number | string, event: string, data: any): void | Promise<void>;
    /** 结束运行 */
    finishRun(threadId: number | string, status: 'done' | 'error', error?: string): void | Promise<void>;
    /** 设置步数 */
    setStepCount(threadId: number | string, count: number): void;
    /** 设置消息 ID */
    setMessageId(threadId: number | string, messageId: number | string): void;
    /** 订阅运行事件 */
    subscribe(threadId: number | string, callback: EventSubscriber): () => void;
    /** 获取缓冲事件 */
    getBufferedEvents(threadId: number | string): BufferedEvent[];
    /** 获取运行快照 */
    getRunSnapshot(threadId: number | string): RunSnapshot | null;
    /** 列出所有运行快照 */
    listRunSnapshots(): RunSnapshot[] | Promise<RunSnapshot[]>;
    /** 获取失败的检查点 */
    getFailedCheckpoint(threadId: number | string): WorkflowCheckpoint | null;
    /** 设置最后失败的阶段 */
    setLastFailedStage(threadId: number | string, stageId: string): void;
    /** 移除运行 */
    removeRun(threadId: number | string): void | Promise<void>;
    /** 获取活跃线程 ID 列表 */
    getActiveThreadIds(): (number | string)[];
    /** 销毁，清理资源 */
    destroy(): void | Promise<void>;
}
//# sourceMappingURL=run-registry-interface.d.ts.map