/**
 * WorkstreamManager - ワークストリーム管理
 *
 * @description
 * 並列タスク実行のためのワークストリームを管理する。
 * DURING_PHASE層でParallelExecutorと連携し、タスクの分散実行を制御。
 *
 * @see DES-ORCH-001 - ワークストリーム管理システム
 * @see TSK-FR-043 - WorkstreamManagerインターフェース定義
 * @see TSK-FR-044 - create/get/addTask実装
 * @see TSK-FR-045 - start/assignTask/completeTask実装
 * @see TSK-FR-046 - ParallelExecutor統合
 * @trace REQ-FR-005 - 並列タスク実行
 */
import type { Workstream, WorkstreamTask, WorkstreamInput, WorkstreamTaskInput, WorkstreamStats, WorkstreamConfig } from '../value-objects/Workstream.js';
/**
 * WorkstreamManagerインターフェース
 *
 * @trace DES-ORCH-001
 */
export interface IWorkstreamManager {
    /**
     * ワークストリームを作成
     */
    create(input: WorkstreamInput): Promise<Workstream>;
    /**
     * IDでワークストリームを取得
     */
    get(id: string): Promise<Workstream | null>;
    /**
     * タスクを追加
     */
    addTask(workstreamId: string, task: WorkstreamTaskInput): Promise<Workstream | null>;
    /**
     * ワークストリームを開始
     */
    start(id: string): Promise<Workstream | null>;
    /**
     * タスクをエージェントに割り当て
     */
    assignTask(workstreamId: string, taskId: string, agentId: string): Promise<WorkstreamTask | null>;
    /**
     * タスクを完了
     */
    completeTask(workstreamId: string, taskId: string, result: unknown): Promise<WorkstreamTask | null>;
    /**
     * タスクを失敗
     */
    failTask(workstreamId: string, taskId: string, error: string): Promise<WorkstreamTask | null>;
    /**
     * 次に実行可能なタスクを取得
     */
    getNextTasks(workstreamId: string): Promise<readonly WorkstreamTask[]>;
    /**
     * 統計を取得
     */
    getStats(workstreamId: string): Promise<WorkstreamStats | null>;
    /**
     * 全ワークストリームを取得
     */
    list(): Promise<readonly Workstream[]>;
    /**
     * ワークストリームをキャンセル
     */
    cancel(id: string): Promise<Workstream | null>;
}
/**
 * WorkstreamManager実装
 *
 * @trace DES-ORCH-001
 */
export declare class WorkstreamManager implements IWorkstreamManager {
    private readonly workstreams;
    private readonly config;
    constructor(config?: WorkstreamConfig);
    /**
     * @trace TSK-FR-044
     */
    create(input: WorkstreamInput): Promise<Workstream>;
    get(id: string): Promise<Workstream | null>;
    /**
     * @trace TSK-FR-044
     */
    addTask(workstreamId: string, taskInput: WorkstreamTaskInput): Promise<Workstream | null>;
    /**
     * @trace TSK-FR-045
     */
    start(id: string): Promise<Workstream | null>;
    /**
     * @trace TSK-FR-045
     */
    assignTask(workstreamId: string, taskId: string, agentId: string): Promise<WorkstreamTask | null>;
    /**
     * @trace TSK-FR-045
     */
    completeTask(workstreamId: string, taskId: string, result: unknown): Promise<WorkstreamTask | null>;
    failTask(workstreamId: string, taskId: string, error: string): Promise<WorkstreamTask | null>;
    /**
     * @trace TSK-FR-046
     */
    getNextTasks(workstreamId: string): Promise<readonly WorkstreamTask[]>;
    getStats(workstreamId: string): Promise<WorkstreamStats | null>;
    list(): Promise<readonly Workstream[]>;
    cancel(id: string): Promise<Workstream | null>;
}
/**
 * ファクトリ関数
 *
 * @trace TSK-FR-043
 */
export declare function createWorkstreamManager(config?: WorkstreamConfig): IWorkstreamManager;
//# sourceMappingURL=WorkstreamManager.d.ts.map