import type { MsgHdrs, NatsConnection, Payload, QueuedIterator } from "@nats-io/nats-core/internal";
import { StorageType } from "@nats-io/jetstream/internal";
import type { ConsumerConfig, JetStreamClient, JetStreamClientImpl, JetStreamManager, JsMsg, Lister, Placement, PurgeOpts, PurgeResponse, Republish, StoredMsg, StreamInfo } from "@nats-io/jetstream/internal";
import type { KV, KvCodecs, KvDeleteOptions, KvEntry, KvKeyCodec, KvOptions, KvPutOptions, KvStatus, KvWatchEntry, KvWatchOptions } from "./types";
import { KvWatchInclude } from "./types";
export declare function Base64KeyCodec(): KvKeyCodec;
export declare function NoopKvCodecs(): KvCodecs;
export declare function defaultBucketOpts(): Partial<KvOptions>;
export declare const kvOperationHdr = "KV-Operation";
export declare function validateKey(k: string): void;
export declare function validateSearchKey(k: string): void;
export declare function hasWildcards(k: string): boolean;
export declare function validateBucket(name: string): void;
/**
 * The entry point to creating new KV instances.
 */
export declare class Kvm {
    #private;
    js: JetStreamClientImpl;
    /**
     * Creates an instance of the Kv that allows you to create and access KV stores.
     * Note that if the argument is a NatsConnection, default JetStream Options are
     * used. If you want to set some options, please provide a JetStreamClient instead.
     * @param nc
     */
    constructor(nc: JetStreamClient | NatsConnection);
    /**
     * Creates and opens the specified KV. If the KV already exists, it opens the existing KV.
     * @param name
     * @param opts
     */
    create(name: string, opts?: Partial<KvOptions>): Promise<KV>;
    /**
     * Open to the specified KV. If the KV doesn't exist, this API will fail on accessing
     * the KV.
     * @param name
     * @param opts
     */
    open(name: string, opts?: Partial<KvOptions>): Promise<KV>;
    /**
     * Lists all available KVs
     */
    list(): Lister<KvStatus>;
}
export declare class Bucket implements KV {
    js: JetStreamClient;
    jsm: JetStreamManager;
    stream: string;
    bucket: string;
    direct: boolean;
    codec: KvCodecs;
    prefix: string;
    editPrefix: string;
    useJsPrefix: boolean;
    _prefixLen: number;
    constructor(bucket: string, js: JetStreamClient, jsm: JetStreamManager);
    static create(js: JetStreamClient, name: string, opts?: Partial<KvOptions>): Promise<KV>;
    static bind(js: JetStreamClient, name: string, opts?: Partial<KvOptions>): Promise<KV>;
    init(opts?: Partial<KvOptions>): Promise<void>;
    initializePrefixes(info: StreamInfo): void;
    bucketName(): string;
    subjectForBucket(): string;
    subjectForKey(k: string, edit?: boolean): string;
    fullKeyName(k: string): string;
    get prefixLen(): number;
    encodeKey(key: string): string;
    decodeKey(ekey: string): string;
    validateKey: typeof validateKey;
    validateSearchKey: typeof validateSearchKey;
    hasWildcards: typeof hasWildcards;
    close(): Promise<void>;
    dataLen(data: Uint8Array, h?: MsgHdrs): number;
    smToEntry(sm: StoredMsg): KvEntry;
    jmToWatchEntry(jm: JsMsg, isUpdate: boolean): KvWatchEntry;
    create(k: string, data: Payload, markerTTL?: string): Promise<number>;
    update(k: string, data: Payload, version: number, timeout?: number): Promise<number>;
    _put(k: string, data: Payload, opts?: Partial<KvPutOptions>, markerTTL?: string): Promise<number>;
    put(k: string, data: Payload, opts?: Partial<KvPutOptions>): Promise<number>;
    get(k: string, opts?: {
        revision: number;
    }): Promise<KvEntry | null>;
    purge(k: string, opts?: Partial<KvDeleteOptions>): Promise<void>;
    delete(k: string, opts?: Partial<KvDeleteOptions>): Promise<void>;
    purgeDeletes(olderMillis?: number): Promise<PurgeResponse>;
    _deleteOrPurge(k: string, op: "DEL" | "PURGE", opts?: Partial<KvDeleteOptions>): Promise<void>;
    _doDeleteOrPurge(k: string, op: "DEL" | "PURGE", opts?: Partial<KvDeleteOptions>): Promise<void>;
    _buildCC(k: string | string[], content: KvWatchInclude, opts?: Partial<ConsumerConfig>): Partial<ConsumerConfig>;
    remove(k: string): Promise<void>;
    history(opts?: {
        key?: string | string[];
        headers_only?: boolean;
    }): Promise<QueuedIterator<KvWatchEntry>>;
    canSetWatcherName(): boolean;
    watch(opts?: KvWatchOptions): Promise<QueuedIterator<KvWatchEntry>>;
    keys(k?: string | string[]): Promise<QueuedIterator<string>>;
    purgeBucket(opts?: PurgeOpts): Promise<PurgeResponse>;
    destroy(): Promise<boolean>;
    status(): Promise<KvStatus>;
}
export declare class KvStatusImpl implements KvStatus {
    si: StreamInfo;
    cluster: string;
    constructor(si: StreamInfo, cluster?: string);
    get bucket(): string;
    get values(): number;
    get history(): number;
    get ttl(): number;
    get markerTTL(): number;
    get bucket_location(): string;
    get backingStore(): StorageType;
    get storage(): StorageType;
    get replicas(): number;
    get description(): string;
    get maxBucketSize(): number;
    get maxValueSize(): number;
    get max_bytes(): number;
    get placement(): Placement;
    get placementCluster(): string;
    get republish(): Republish;
    get streamInfo(): StreamInfo;
    get size(): number;
    get metadata(): Record<string, string>;
    get compression(): boolean;
}