export interface WorkerTurnState { worker: Worker; workflowId: string; turnId: number; kind: 'run' | 'resume'; timeoutMs: number | undefined; /** * The workflow's captured revision (WFT-20), when known — carried forward * on every turn for this workflow (including `resume`, which never * re-supplies it), for `WorkerProtocolGuard` to validate the outbound * echo against. */ revision?: string; } export type WorkerTurnTimeoutResolverForTesting = (turn: Pick) => number; export declare class WorkerTurnWatchdog { #private; constructor(timeoutMs: number | undefined, onTimeout: (turn: WorkerTurnState) => void); begin(worker: Worker, workflowId: string, turnId: number, kind: WorkerTurnState['kind'], timeoutMs?: number | undefined, revision?: string): void; setTimeoutResolverForTesting(resolver: WorkerTurnTimeoutResolverForTesting): void; clear(worker: Worker): void; clearAll(): void; get(worker: Worker): WorkerTurnState | undefined; }