import { type StreamAPI } from "https://deno.land/x/natsws@v1.29.0/src/mod.ts";
Methods
info(stream: string, opts?: Partial<StreamInfoRequestOptions>): Promise<StreamInfo>
Returns the information about the specified stream
add(cfg: Partial<StreamConfig>): Promise<StreamInfo>
Adds a new stream with the specified stream configuration.
update(name: string, cfg: Partial<StreamUpdateConfig>): Promise<StreamInfo>
Updates the stream configuration for the specified stream.
purge(stream: string, opts?: PurgeOpts): Promise<PurgeResponse>
Purges messages from a stream that match the specified purge options.
getMessage(stream: string, query: MsgRequest): Promise<StoredMsg>
Retrieves the message matching the specified query. Messages can be retrieved by sequence number or by last sequence matching a subject.
Returns a list of KvStatus for all streams that are identified as
being a KV (that is having names that have the prefix KV_
)
listObjectStores(): Lister<ObjectStoreStatus>
Returns a list of ObjectStoreInfo for all streams that are identified as
being a ObjectStore (that is having names that have the prefix OBJ_
)