import { type WorkerProgressMessage } from "./sync-worker-port.js"; import type { SyncWorkerAdapter, WorkOutcome, WorkSlice } from "./sync-work.js"; export type SyncWorkerClass = "realtime" | "chore"; export type ChildProcessSyncWorkerOptions = { readonly workerClass: SyncWorkerClass; /** Defaults to the packaged worker binary adjacent to the compiled sync modules. */ readonly workerScript?: string; readonly env?: NodeJS.ProcessEnv; readonly maxRestarts?: number; readonly restartBackoffMs?: number; readonly readyTimeoutMs?: number; readonly shutdownGraceMs?: number; readonly onProgress?: (progress: WorkerProgressMessage) => void; }; export type ChildWorkerIdentity = { readonly pid: number; readonly moduleStateId: string; }; export declare class ChildProcessSyncWorkerError extends Error { constructor(message: string); } /** * A long-lived worker port. Its child is an execution resource only: the * coordinator remains the owner of path leases and determines retry policy. */ export declare class ChildProcessSyncWorkerAdapter implements SyncWorkerAdapter { private readonly options; private child?; private identity?; private starting?; private rejectStart?; private stopping; private restartCount; private restarting?; private exhausted?; private readonly pending; private readonly maxRestarts; private readonly restartBackoffMs; private readonly readyTimeoutMs; private readonly shutdownGraceMs; constructor(options: ChildProcessSyncWorkerOptions); start(): Promise; execute(slice: WorkSlice): Promise; inspect(): ChildWorkerIdentity | undefined; shutdown(): Promise; private handleChildMessage; private handleExit; private scheduleRestart; private rejectPending; private cancelledBeforeDispatch; private send; } //# sourceMappingURL=child-process-sync-worker.d.ts.map