import type { Batch } from "./batch";
/**
 * 基于 nextRetryMs 的小顶堆重试队列。
 *
 * - 按 nextRetryMs 升序出队；
 * - 支持一次性弹出所有元素（优雅退出时使用）。
 */
export declare class RetryQueue {
    private heap;
    add(batch: Batch): void;
    /**
     * 获取需要重试的批次列表。
     *
     * @param drainAll 为 true 时，忽略 nextRetryMs，弹出所有批次；
     *                 为 false 时，仅弹出 nextRetryMs 小于等于当前时间的批次。
     */
    getRetryBatches(drainAll: boolean): Batch[];
    clear(): void;
    private heapPush;
    private heapPop;
    private siftUp;
    private siftDown;
    private swap;
}