/** * Coordination manager for task scheduling and resource management */ import { Task, CoordinationConfig } from "../utils/types.js"; import { IEventBus } from "../core/event-bus.js"; import { ILogger } from "../core/logger.js"; export interface ICoordinationManager { initialize(): Promise; shutdown(): Promise; assignTask(task: Task, agentId: string): Promise; getAgentTaskCount(agentId: string): Promise; getAgentTasks(agentId: string): Promise; cancelTask(taskId: string, reason?: string): Promise; acquireResource(resourceId: string, agentId: string): Promise; releaseResource(resourceId: string, agentId: string): Promise; sendMessage(from: string, to: string, message: unknown): Promise; getHealthStatus(): Promise<{ healthy: boolean; error?: string; metrics?: Record; }>; performMaintenance(): Promise; getCoordinationMetrics(): Promise>; enableAdvancedScheduling(): void; reportConflict(type: "resource" | "task", id: string, agents: string[]): Promise; } /** * Coordination manager implementation */ export declare class CoordinationManager implements ICoordinationManager { private config; private eventBus; private logger; private scheduler; private resourceManager; private messageRouter; private conflictResolver; private metricsCollector; private initialized; private deadlockCheckInterval?; private advancedSchedulingEnabled; constructor(config: CoordinationConfig, eventBus: IEventBus, logger: ILogger); initialize(): Promise; shutdown(): Promise; assignTask(task: Task, agentId: string): Promise; getAgentTaskCount(agentId: string): Promise; acquireResource(resourceId: string, agentId: string): Promise; releaseResource(resourceId: string, agentId: string): Promise; sendMessage(from: string, to: string, message: unknown): Promise; getHealthStatus(): Promise<{ healthy: boolean; error?: string; metrics?: Record; }>; private setupEventHandlers; private startDeadlockDetection; private detectDeadlock; private resolveDeadlock; getAgentTasks(agentId: string): Promise; cancelTask(taskId: string, reason?: string): Promise; performMaintenance(): Promise; getCoordinationMetrics(): Promise>; enableAdvancedScheduling(): void; reportConflict(type: "resource" | "task", id: string, agents: string[]): Promise; } //# sourceMappingURL=manager.d.ts.map