/** * Limits manager: enforces maxPending and maxPayloadBytes constraints. * Fast path for in-flight message tracking. */ /** * Limits configuration. */ export interface LimitsConfig { maxPending?: number; maxPayloadBytes?: number; } /** * In-flight message tracker and enforcer. * Increments counter on message start; decrements on completion. * Throws if maxPending limit is exceeded. */ export declare class LimitsManager { readonly config: LimitsConfig; private inFlight; constructor(config?: LimitsConfig); /** * Begin tracking a new in-flight message. * Throws if maxPending would be exceeded. * Returns a release function to call when message completes. */ begin(): () => void; /** * Get current in-flight message count. */ currentInFlight(): number; /** * Check if payload size exceeds limit. * Returns true if size is acceptable, false otherwise. */ checkPayloadSize(size: number): boolean; } //# sourceMappingURL=limits-manager.d.ts.map