import type { ClientId, PacketId, TopicFilter } from "./deps.ts";
import type { ClientRegistrationResult, ClientSubscription, ExtPublishPacket, Handler, Persistence, ShareName } from "./persistence.ts";
import type { StorageProvider } from "./storage.ts";
export declare class MqttPersistence implements Persistence {
    private clientHandlerList;
    private trie;
    private packetIdCounters;
    private storage;
    private sharedGroupCounters;
    constructor(storage: StorageProvider);
    initialize(): Promise<void>;
    registerClient(clientId: ClientId, clientDispatch: Handler): Promise<ClientRegistrationResult>;
    deregisterClient(clientId: ClientId): Promise<void>;
    disconnectClient(clientId: ClientId): Promise<void>;
    subscribe(clientId: ClientId, subscription: ClientSubscription): Promise<void>;
    unsubscribe(clientId: ClientId, topicFilter: TopicFilter, shareName: ShareName): Promise<void>;
    listSubscriptions(clientId: ClientId): AsyncIterableIterator<ClientSubscription>;
    addPendingIncomingPacket(clientId: ClientId, packet: ExtPublishPacket): Promise<void>;
    getPendingIncomingPacket(clientId: ClientId, packetId: PacketId): Promise<ExtPublishPacket | null>;
    listPendingIncomingPackets(clientId: ClientId): AsyncIterableIterator<ExtPublishPacket>;
    deletePendingIncomingPacket(clientId: ClientId, packetId: PacketId): Promise<boolean>;
    addPendingOutgoingPacket(clientId: ClientId, packet: ExtPublishPacket): Promise<void>;
    getPendingOutgoingPacket(clientId: ClientId, packetId: PacketId): Promise<ExtPublishPacket | null>;
    updatePendingOutgoingPacket(clientId: ClientId, packetId: PacketId, dup: boolean): Promise<boolean>;
    listPendingOutgoingPackets(clientId: ClientId): AsyncIterableIterator<ExtPublishPacket>;
    deletePendingOutgoingPacket(clientId: ClientId, packetId: PacketId): Promise<boolean>;
    addPendingAck(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>;
    nextPacketId(clientId: ClientId): Promise<PacketId>;
    publish(publisherClientId: ClientId, packet: ExtPublishPacket): Promise<void>;
    private dispatch;
    handleRetained(clientId: ClientId, subscriptions: ClientSubscription[]): Promise<void>;
}
//# sourceMappingURL=basicPersistence.d.ts.map