import type { ClientId, PacketId, Topic, TopicFilter } from "./deps.ts";
import type { ClientRegistrationResult, ClientSubscription, ExtPublishPacket, ShareName } from "./persistence.ts";
export type StoredSubscription = ClientSubscription & {
    clientId: ClientId;
};
export declare const PacketDirection: {
    readonly Incoming: 0;
    readonly Outgoing: 1;
};
export type PacketDirection = typeof PacketDirection[keyof typeof PacketDirection];
export interface StorageProvider {
    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=storage.d.ts.map