import type { Task, Worker, WorkerFilter, WorkerAssignment, BroadcastProvider, ShortTermStore, LongTermStore, TaskcastHooks, AssignMode, DisconnectPolicy, WorkerMatchRule } from './types.js';
import type { TaskEngine } from './engine.js';
export interface WorkerManagerOptions {
    engine: TaskEngine;
    shortTermStore: ShortTermStore;
    broadcast: BroadcastProvider;
    longTermStore?: LongTermStore;
    hooks?: TaskcastHooks;
    defaults?: WorkerManagerDefaults;
}
export interface WorkerManagerDefaults {
    assignMode?: AssignMode;
    heartbeatIntervalMs?: number;
    heartbeatTimeoutMs?: number;
    offerTimeoutMs?: number;
    disconnectPolicy?: DisconnectPolicy;
    disconnectGraceMs?: number;
}
export interface WorkerRegistration {
    id?: string;
    matchRule: WorkerMatchRule;
    capacity: number;
    weight?: number;
    connectionMode: Worker['connectionMode'];
    metadata?: Record<string, unknown>;
}
export interface WorkerUpdate {
    weight?: number;
    capacity?: number;
    matchRule?: WorkerMatchRule;
    status?: 'draining' | 'idle';
}
export interface DispatchResult {
    matched: boolean;
    workerId?: string;
}
export interface ClaimResult {
    success: boolean;
    reason?: string;
}
export interface DeclineOptions {
    blacklist?: boolean;
}
export declare class WorkerManager {
    private opts;
    private engine;
    private shortTermStore;
    private longTermStore?;
    private hooks?;
    constructor(opts: WorkerManagerOptions);
    get heartbeatIntervalMs(): number;
    private emitTaskAudit;
    private emitWorkerAudit;
    registerWorker(config: WorkerRegistration): Promise<Worker>;
    unregisterWorker(workerId: string): Promise<void>;
    updateWorker(workerId: string, update: WorkerUpdate): Promise<Worker | null>;
    heartbeat(workerId: string): Promise<void>;
    getWorker(workerId: string): Promise<Worker | null>;
    listWorkers(filter?: WorkerFilter): Promise<Worker[]>;
    dispatchTask(taskId: string): Promise<DispatchResult>;
    claimTask(taskId: string, workerId: string): Promise<ClaimResult>;
    declineTask(taskId: string, workerId: string, opts?: DeclineOptions): Promise<void>;
    getWorkerTasks(workerId: string): Promise<WorkerAssignment[]>;
    releaseTask(taskId: string): Promise<void>;
    waitForTask(workerId: string, signal?: AbortSignal): Promise<Task>;
    notifyNewTask(taskId: string): Promise<void>;
}
//# sourceMappingURL=worker-manager.d.ts.map