/** * Task request from the executor to the performer */ export interface TaskRequest { /** Unique identifier for the task */ taskId: string; /** Task payload as bytes */ payload: Uint8Array; } /** * Task response from the performer back to the executor */ export interface TaskResponse { /** Unique identifier for the task (must match request) */ taskId: string; /** Task result as bytes */ result: Uint8Array; } /** * Health check request */ export interface HealthCheckRequest { } /** * Performer status enumeration */ export declare enum PerformerStatus { READY_FOR_TASK = "READY_FOR_TASK", BUSY = "BUSY", ERROR = "ERROR", STARTING = "STARTING", STOPPING = "STOPPING" } /** * Health check response */ export interface HealthCheckResponse { /** Current performer status */ status: PerformerStatus; } /** * Start sync request */ export interface StartSyncRequest { } /** * Start sync response */ export interface StartSyncResponse { } /** * PerformerService interface that must be implemented by performers */ export interface PerformerService { /** * Execute a task * @param request Task request with payload * @returns Task response with result */ ExecuteTask(request: TaskRequest): Promise; /** * Check performer health * @param request Health check request * @returns Health check response with status */ HealthCheck(request: HealthCheckRequest): Promise; /** * Start synchronization * @param request Start sync request * @returns Start sync response */ StartSync(request: StartSyncRequest): Promise; } /** * Configuration for the performer server */ export interface PerformerServerConfig { /** Port to listen on (default: 8080) */ port?: number; /** Timeout for task execution in milliseconds (default: 5000) */ timeout?: number; /** Enable debug logging (default: false) */ debug?: boolean; } /** * Task execution result for internal use */ export interface TaskResult { /** Task ID */ taskId: string; /** Result payload */ result: Uint8Array; } /** * Task validation error */ export declare class TaskValidationError extends Error { readonly taskId: string; constructor(message: string, taskId: string); } /** * Task execution error */ export declare class TaskExecutionError extends Error { readonly taskId: string; constructor(message: string, taskId: string); } //# sourceMappingURL=performer.d.ts.map