/** Contract for a component that can process a batch of queued items. */ export interface BatchProcessor { processBatch(): Promise; } /** Configuration for the daemon polling worker. */ export interface DaemonWorkerOptions { queueProcessor: BatchProcessor; pollIntervalMs: number; } /** Polling worker that periodically processes queued observations. */ export declare class DaemonWorker { private queueProcessor; private pollIntervalMs; private timer; private lastActiveAt; private processing; constructor(options: DaemonWorkerOptions); start(): void; stop(): void; get isRunning(): boolean; get idleMs(): number; get shouldAutoExit(): boolean; handleMessage(message: unknown): void; } //# sourceMappingURL=worker.d.ts.map