import type sqlite from "node:sqlite";
import type { ClientId, PacketId, Topic, TopicFilter } from "../deps.ts";
import type { ClientRegistrationResult, ClientSubscription, ExtPublishPacket, ShareName } from "../persistence.ts";
import { PacketDirection } from "../storage.ts";
import type { StorageProvider, StoredSubscription } from "../storage.ts";
export declare class SqliteStorage implements StorageProvider {
    private db;
    private statements;
    constructor(db?: string | sqlite.DatabaseSync);
    initialize(): Promise<void>;
    close(): Promise<void>;
    saveSession(clientId: ClientId, session: ClientRegistrationResult): Promise<void>;
    getSession(clientId: ClientId): Promise<ClientRegistrationResult | null>;
    deleteSession(clientId: ClientId): Promise<void>;
    listAllSessions(): AsyncIterableIterator<{
        clientId: ClientId;
        session: ClientRegistrationResult;
    }>;
    saveSubscription(clientId: ClientId, sub: ClientSubscription): Promise<void>;
    deleteSubscription(clientId: ClientId, topicFilter: TopicFilter, shareName: ShareName): Promise<void>;
    listSubscriptions(clientId: ClientId): AsyncIterableIterator<ClientSubscription>;
    listAllSubscriptions(): AsyncIterableIterator<StoredSubscription>;
    savePendingPacket(clientId: ClientId, direction: PacketDirection, packet: ExtPublishPacket): Promise<void>;
    getPendingPacket(clientId: ClientId, direction: PacketDirection, packetId: PacketId): Promise<ExtPublishPacket | null>;
    updatePendingPacket(clientId: ClientId, direction: PacketDirection, packetId: PacketId, dup: boolean): Promise<boolean>;
    deletePendingPacket(clientId: ClientId, direction: PacketDirection, packetId: PacketId): Promise<boolean>;
    listPendingPackets(clientId: ClientId, direction: PacketDirection): AsyncIterableIterator<ExtPublishPacket>;
    savePendingAck(clientId: ClientId, packetId: PacketId): Promise<void>;
    hasPendingAck(clientId: ClientId, packetId: PacketId): Promise<boolean>;
    deletePendingAck(clientId: ClientId, packetId: PacketId): Promise<boolean>;
    listPendingAcks(clientId: ClientId): AsyncIterableIterator<PacketId>;
    saveRetained(topic: Topic, packet: ExtPublishPacket): Promise<void>;
    deleteRetained(topic: Topic): Promise<void>;
    listRetainedMatches(topicFilter: TopicFilter): AsyncIterableIterator<ExtPublishPacket>;
}
//# sourceMappingURL=sqliteStorage.d.ts.map