/** * V3 Task Manager * Decomposed from orchestrator.ts - Task lifecycle management * ~200 lines (target achieved) */ import type { ITask, ITaskCreate, ITaskResult, ITaskManager, ITaskQueue, TaskManagerMetrics } from '../interfaces/task.interface.js'; import type { IEventBus } from '../interfaces/event.interface.js'; /** * Priority queue implementation for tasks */ export declare class TaskQueue implements ITaskQueue { private tasks; enqueue(task: ITask): Promise; dequeue(): Promise; peek(): Promise; size(): number; isEmpty(): boolean; clear(): Promise; getAll(): Promise; remove(taskId: string): Promise; updatePriority(taskId: string, priority: number): Promise; } /** * Task manager implementation */ export declare class TaskManager implements ITaskManager { private eventBus; private tasks; private queue; private metrics; constructor(eventBus: IEventBus, queue?: ITaskQueue); createTask(params: ITaskCreate): Promise; getTask(taskId: string): ITask | undefined; getTasks(filter?: Partial>): ITask[]; assignTask(taskId: string, agentId: string): Promise; startTask(taskId: string): Promise; completeTask(taskId: string, result: ITaskResult): Promise; failTask(taskId: string, error: Error): Promise; cancelTask(taskId: string, reason?: string): Promise; retryTask(taskId: string): Promise; getMetrics(): TaskManagerMetrics; cleanup(olderThan: Date): Promise; private isRetryable; /** * Get the task queue */ getQueue(): ITaskQueue; } //# sourceMappingURL=task-manager.d.ts.map