import * as nats from "https://deno.land/x/nats@v1.23.0/jetstream/mod.ts";
Enums
The different kinds of Advisories | |
These events represent informational notifications emitted by ConsumerMessages that can be safely ignored by clients. | |
ConsumerEvents are informational notifications emitted by ConsumerMessages that may be of interest to a client. | |
Functions
Returns true if the message is a flow control message | |
Returns true if the message is a heart beat message |
Interfaces
An advisory is an interesting event in the JetStream server | |
An interface that reports via a promise when an object such as a connection or subscription closes. | |
A JetStream interface that allows you to request the ConsumerInfo on the backing object. | |
A builder API that creates a ConsumerOpt | |
Interface for interacting with JetStream data | |
The API for interacting with JetStream resources | |
Options to a JetStream options applied to all JetStream or JetStreamManager requests. | |
Options for messages published to JetStream | |
Represents a message stored in JetStream | |
I KV | |
An interface for encoding and decoding values before they are stored or returned to the client. | |
An interface for listing. Returns a promise with typed list. | |
Records messages that were damaged and unrecoverable | |
The response returned by the JetStream server when a message is added to a stream. | |
Options for a JetStream pull subscription which define how long the pull request will remain open and limits the amount of data that the server could return. | |
I RoKV | |
An interface representing a message that retrieved directly from JetStream. | |
An alternate location to read mirrored data | |
Sets default consumer limits for inactive_threshold and max_ack_pending to consumers of this stream that don't specify specific values. This functionality requires a server 2.10.x or better. | |
Stream configuration info | |
Information about an upstream stream source in a mirror | |
Stream options that can be updated | |
The interface for creating instances of different JetStream materialized views. |
Type Aliases
T Bind | |
Options for fetching bytes | |
Options for fetching messages | |
The JetStream pull subscription object. | |
The JetStream Subscription object | |
The signature a message handler for a JetStream subscription. | |
An object that allows reading the object stored under a specified name. | |
These options are a subset of ConsumerConfig and ConsumerUpdateConfig | |
Options for StreamAPI info requests | |