export interface RetryOptions {
    retries?: number;
    baseMs?: number;
    factor?: number;
    jitter?: boolean;
}
export interface FallbackOptions {
    onFallback?: (error: unknown, index: number) => void;
}
export declare function withRetry<TReq, TRes>(fn: (req: TReq, signal?: AbortSignal) => Promise<TRes>, opts?: RetryOptions): (req: TReq, signal?: AbortSignal) => Promise<TRes>;
export declare function withFallback<TReq, TRes>(fns: Array<(req: TReq, signal?: AbortSignal) => Promise<TRes>>, opts?: FallbackOptions): (req: TReq, signal?: AbortSignal) => Promise<TRes>;
export declare function withStreamRetry<TReq, TChunk>(fn: (req: TReq, signal?: AbortSignal) => AsyncIterable<TChunk>, opts?: RetryOptions): (req: TReq, signal?: AbortSignal) => AsyncIterable<TChunk>;
export declare function withStreamFallback<TReq, TChunk>(fns: Array<(req: TReq, signal?: AbortSignal) => AsyncIterable<TChunk>>, opts?: FallbackOptions): (req: TReq, signal?: AbortSignal) => AsyncIterable<TChunk>;
export interface RateLimiterOptions {
    /** Maximum requests per minute (sliding window). Default: Infinity */
    rpm?: number;
    /** Maximum concurrent in-flight requests. Default: Infinity */
    concurrent?: number;
    /** Maximum time (ms) a request will wait in queue. Default: 60000 */
    maxQueueMs?: number;
}
export interface RateLimiter {
    /** Current number of in-flight requests */
    readonly active: number;
    /** Current number of queued requests waiting for a slot */
    readonly queued: number;
    /** Reject all queued requests and clean up timers */
    dispose(): void;
}
export interface RateLimitOptions {
    /** Override maxQueueMs for this particular wrapped function */
    maxQueueMs?: number;
}
export declare function createRateLimiter(opts?: RateLimiterOptions): RateLimiter;
export declare function withRateLimit<TReq, TRes>(fn: (req: TReq, signal?: AbortSignal) => Promise<TRes>, limiter: RateLimiter, opts?: RateLimitOptions): (req: TReq, signal?: AbortSignal) => Promise<TRes>;
//# sourceMappingURL=middleware.d.ts.map