import type { IPollingTaskOptions, IPollingQueueInfo, TPollingAction, TPollingBulkAction } from '../../../types/public.js'; import type { TransportRegistry } from '../registry/TransportRegistry.js'; /** * Proxy class that provides a unified interface for managing polling tasks across multiple transports. * It routes commands to the specific PollingManager associated with a Transport ID. * * BUG-5 fix: Methods now throw errors for missing transports instead of silently returning. * IMP-7: Accepts both enum values (EPollingAction.Start) and plain strings ('start'). */ export declare class PollingProxy { private readonly _registry; constructor(_registry: TransportRegistry); addTask(transportId: string, options: IPollingTaskOptions): void; /** * BUG-5 fix: Throws error if transport not found instead of silently returning. */ removeTask(transportId: string, taskId: string): void; /** * BUG-5 fix: Throws error if transport not found. */ updateTask(transportId: string, taskId: string, options: IPollingTaskOptions): Promise; /** * IMP-7: Accepts EPollingAction enum or plain string ('start'|'stop'|'pause'|'resume'). * BUG-5 fix: Throws error if transport not found. */ controlTask(transportId: string, taskId: string, action: TPollingAction): void; /** * IMP-7: Accepts EPollingBulkAction enum or plain string ('startAll'|'stopAll'|'pauseAll'|'resumeAll'). * BUG-5 fix: Throws error if transport not found. */ controlAll(transportId: string, action: TPollingBulkAction): void; getQueueInfo(transportId: string): IPollingQueueInfo; executeImmediate(transportId: string, fn: () => Promise): Promise; pauseAllForTransport(transportId: string): void; resumeAllForTransport(transportId: string): void; clearAllForTransport(transportId: string): void; stopAllForTransport(transportId: string): void; }