feat(05-03): create DispatchManager port interface
- QueuedTask type with priority and dependencies - DispatchResult type for dispatch operation outcomes - DispatchManager interface with queue/dispatch/complete/block methods - Follows hexagonal architecture pattern (same as EventBus, AgentManager)
This commit is contained in:
9
src/dispatch/index.ts
Normal file
9
src/dispatch/index.ts
Normal file
@@ -0,0 +1,9 @@
|
|||||||
|
/**
|
||||||
|
* Dispatch Module - Public API
|
||||||
|
*
|
||||||
|
* Exports the DispatchManager port interface and related types.
|
||||||
|
* All modules should import from this index file.
|
||||||
|
*/
|
||||||
|
|
||||||
|
// Port interface (what consumers depend on)
|
||||||
|
export type { DispatchManager, QueuedTask, DispatchResult } from './types.js';
|
||||||
118
src/dispatch/types.ts
Normal file
118
src/dispatch/types.ts
Normal file
@@ -0,0 +1,118 @@
|
|||||||
|
/**
|
||||||
|
* Dispatch Module Types
|
||||||
|
*
|
||||||
|
* Port interface for task dispatch management.
|
||||||
|
* DispatchManager is the PORT. Implementations are ADAPTERS.
|
||||||
|
*
|
||||||
|
* This follows the same hexagonal architecture pattern as EventBus and AgentManager:
|
||||||
|
* - Interface defines the contract (port)
|
||||||
|
* - Implementations can be swapped without changing consumers
|
||||||
|
* - Enables testing with in-memory/mock implementations
|
||||||
|
*/
|
||||||
|
|
||||||
|
// =============================================================================
|
||||||
|
// Dispatch Domain Types
|
||||||
|
// =============================================================================
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Represents a task queued for dispatch.
|
||||||
|
* Tasks are dispatched when all dependencies complete.
|
||||||
|
*/
|
||||||
|
export interface QueuedTask {
|
||||||
|
/** Unique identifier for the task */
|
||||||
|
taskId: string;
|
||||||
|
/** Task priority level */
|
||||||
|
priority: 'low' | 'medium' | 'high';
|
||||||
|
/** When the task was queued */
|
||||||
|
queuedAt: Date;
|
||||||
|
/** Task IDs that must complete before this task can be dispatched */
|
||||||
|
dependsOn: string[];
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Result of a dispatch operation.
|
||||||
|
* Success means task was assigned to an agent; failure means dispatch couldn't happen.
|
||||||
|
*/
|
||||||
|
export interface DispatchResult {
|
||||||
|
/** Whether the task was successfully dispatched */
|
||||||
|
success: boolean;
|
||||||
|
/** ID of the task that was dispatched */
|
||||||
|
taskId: string;
|
||||||
|
/** ID of the agent assigned to the task (only present on success) */
|
||||||
|
agentId?: string;
|
||||||
|
/** Reason why dispatch failed (only present on failure) */
|
||||||
|
reason?: string;
|
||||||
|
}
|
||||||
|
|
||||||
|
// =============================================================================
|
||||||
|
// DispatchManager Port Interface
|
||||||
|
// =============================================================================
|
||||||
|
|
||||||
|
/**
|
||||||
|
* DispatchManager Port Interface
|
||||||
|
*
|
||||||
|
* Manages task dispatch queue with dependency ordering.
|
||||||
|
*
|
||||||
|
* Covers requirements:
|
||||||
|
* - TASK-04: Dependency-ordered dispatch
|
||||||
|
* - TASK-05: Work queue for available agents
|
||||||
|
*/
|
||||||
|
export interface DispatchManager {
|
||||||
|
/**
|
||||||
|
* Queue a task for dispatch.
|
||||||
|
* Task will be dispatched when all dependencies complete.
|
||||||
|
*
|
||||||
|
* @param taskId - ID of the task to queue
|
||||||
|
*/
|
||||||
|
queue(taskId: string): Promise<void>;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Get next dispatchable task.
|
||||||
|
* Returns task with all dependencies complete, highest priority first.
|
||||||
|
* Returns null if no tasks ready.
|
||||||
|
*
|
||||||
|
* @returns Next dispatchable task or null
|
||||||
|
*/
|
||||||
|
getNextDispatchable(): Promise<QueuedTask | null>;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Dispatch next available task to an agent.
|
||||||
|
* Finds available agent, assigns task, spawns agent.
|
||||||
|
* Returns dispatch result.
|
||||||
|
*
|
||||||
|
* @returns Result of the dispatch operation
|
||||||
|
*/
|
||||||
|
dispatchNext(): Promise<DispatchResult>;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Mark a task as complete.
|
||||||
|
* Triggers re-evaluation of dependent tasks.
|
||||||
|
*
|
||||||
|
* @param taskId - ID of the completed task
|
||||||
|
*/
|
||||||
|
completeTask(taskId: string): Promise<void>;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Mark a task as blocked.
|
||||||
|
* Task will not be dispatched until unblocked.
|
||||||
|
*
|
||||||
|
* @param taskId - ID of the task to block
|
||||||
|
* @param reason - Reason for blocking
|
||||||
|
*/
|
||||||
|
blockTask(taskId: string, reason: string): Promise<void>;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Get current queue state.
|
||||||
|
* Returns all queued tasks with their dispatch readiness.
|
||||||
|
*
|
||||||
|
* @returns Queue state with queued, ready, and blocked tasks
|
||||||
|
*/
|
||||||
|
getQueueState(): Promise<{
|
||||||
|
/** All queued tasks */
|
||||||
|
queued: QueuedTask[];
|
||||||
|
/** Tasks ready for dispatch (all dependencies complete) */
|
||||||
|
ready: QueuedTask[];
|
||||||
|
/** Tasks that are blocked */
|
||||||
|
blocked: Array<{ taskId: string; reason: string }>;
|
||||||
|
}>;
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user