import { Bucket } from "https://deno.land/x/natsws@v1.28.0/src/nats-base-client.ts";
Methods
_buildCC(): Partial<ConsumerConfig>
k: string | string[],
content: KvWatchInclude,
opts?: Partial<ConsumerConfig>,
_deleteOrPurge(): Promise<void>
k: string,
op: "DEL" | "PURGE",
opts?: Partial<KvDeleteOptions>,
_doDeleteOrPurge(): Promise<void>
k: string,
op: "DEL" | "PURGE",
opts?: Partial<KvDeleteOptions>,
bucketName(): string
canSetWatcherName(): boolean
close(): Promise<void>
decodeKey(ekey: string): string
delete(k: string, opts?: Partial<KvDeleteOptions>): Promise<void>
destroy(): Promise<boolean>
encodeKey(key: string): string
fullKeyName(k: string): string
get(k: string, opts?: { revision: number; }): Promise<KvEntry | null>
history(opts?: { key?: string | string[]; headers_only?: boolean; }): Promise<QueuedIterator<KvEntry>>
init(opts?: Partial<KvOptions>): Promise<void>
initializePrefixes(info: StreamInfo)
jmToEntry(jm: JsMsg): KvEntry
keys(k?: string | string[]): Promise<QueuedIterator<string>>
purge(k: string, opts?: Partial<KvDeleteOptions>): Promise<void>
purgeBucket(opts?: PurgeOpts): Promise<PurgeResponse>
purgeDeletes(olderMillis?: number): Promise<PurgeResponse>
remove(k: string): Promise<void>
smToEntry(sm: StoredMsg): KvEntry
status(): Promise<KvStatus>
subjectForBucket(): string
subjectForKey(k: string, edit?): string
watch(opts?: KvWatchOptions): Promise<QueuedIterator<KvEntry>>