import type { PendingMessage } from "../types";
import type { Database } from "./database";
/** Repository for pending message queue operations. */
export declare class PendingMessageRepository {
    private db;
    constructor(db: Database);
    create(data: Omit<PendingMessage, "id" | "createdAt" | "status" | "retryCount" | "error">): PendingMessage;
    getPending(limit?: number): PendingMessage[];
    getByStatus(status: PendingMessage["status"]): PendingMessage[];
    markProcessing(id: string): void;
    markCompleted(id: string): void;
    markFailed(id: string, error: string): void;
    /**
     * Reset stale "processing" messages back to "pending".
     * Handles the case where the plugin crashes mid-processing.
     * Returns the number of messages reset.
     */
    resetStale(olderThanMinutes?: number): number;
    deleteCompletedOlderThan(days: number): number;
    private mapRow;
}
//# sourceMappingURL=pending.d.ts.map