Index

A

AccountInfo (class in nats.js.api) AccountLimits (class in nats.js.api) ack() (nats.aio.msg.Msg method) ack_sync() (nats.aio.msg.Msg method) AckPolicy (class in nats.js.api) add_stream() (nats.js.manager.JetStreamManager method) APIError

APIStats (class in nats.js.api) as_dict() (nats.js.api.Base method) (nats.js.api.ConsumerConfig method) (nats.js.api.KeyValueConfig method) (nats.js.api.ObjectStoreConfig method) (nats.js.api.StreamConfig method) AuthorizationError

B

BadBucketError BadObjectMetaError BadRequestError BadSubjectError

BadSubscriptionError BadTimeoutError Base (class in nats.js.api) BucketNotFoundError

C

client_id (nats.aio.client.Client property) close() (in module nats.aio.client.Client) ClusterInfo (class in nats.js.api) connect() (in module nats) (in module nats.aio.client.Client) connected_url (nats.aio.client.Client property) ConnectionClosedError

ConnectionDrainingError ConnectionReconnectingError consumer_info() (nats.js.client.JetStreamContext.PullSubscription method) ConsumerConfig (class in nats.js.api) ConsumerInfo (class in nats.js.api) consumers_info() (nats.js.manager.JetStreamManager method) ConsumerSequenceMismatchError create() (nats.js.kv.KeyValue method)

D

delete() (nats.js.kv.KeyValue method) delete_msg() (nats.js.manager.JetStreamManager method) delete_stream() (nats.js.manager.JetStreamManager method) delivered (nats.aio.subscription.Subscription property) (nats.js.client.JetStreamContext.PullSubscription property) DeliverPolicy (class in nats.js.api)

DigestMismatchError DiscardPolicy (class in nats.js.api) discovered_servers (nats.aio.client.Client property) drain() (in module nats.aio.client.Client) (nats.aio.subscription.Subscription method) DrainTimeoutError

E

ErrAuthorization ErrBadSubject ErrBadSubscription ErrBadTimeout ErrConnectionClosed ErrConnectionDraining ErrConnectionReconnecting ErrDrainTimeout ErrInvalidCallbackType ErrInvalidUserCredentials ErrJsonParse

ErrMaxPayload ErrNoServers Error, [1] ErrSecureConnFailed ErrSecureConnRequired ErrSecureConnWanted ErrSlowConsumer ErrStaleConnection ErrTimeout evolve() (nats.js.api.Base method) ExternalStream (class in nats.js.api)

F

fetch() (nats.js.client.JetStreamContext.PullSubscription method) find_stream_name_by_subject() (nats.js.manager.JetStreamManager method) flush() (in module nats.aio.client.Client) FlushTimeoutError from_response() (nats.js.api.AccountInfo class method) (nats.js.api.Base class method) (nats.js.api.ClusterInfo class method) (nats.js.api.ConsumerConfig class method) (nats.js.api.ConsumerInfo class method) (nats.js.api.ObjectInfo class method) (nats.js.api.ObjectLink class method) (nats.js.api.ObjectMeta class method) (nats.js.api.ObjectMetaOptions class method) (nats.js.api.StreamConfig class method) (nats.js.api.StreamInfo class method) (nats.js.api.StreamSource class method) (nats.js.api.StreamState class method) (nats.js.api.Tier class method)

G

get() (nats.js.kv.KeyValue method)

get_last_msg() (nats.js.manager.JetStreamManager method) get_msg() (nats.js.manager.JetStreamManager method)

H

Header (class in nats.js.api) header (nats.aio.msg.Msg property) (nats.js.api.RawStreamMsg property)

history (nats.js.kv.KeyValue.BucketStatus property) history() (nats.js.kv.KeyValue method)

I

in_progress() (nats.aio.msg.Msg method) InvalidBucketNameError InvalidCallbackTypeError InvalidObjectNameError InvalidUserCredentialsError

is_closed (nats.aio.client.Client property) is_connected (nats.aio.client.Client property) is_connecting (nats.aio.client.Client property) is_draining (nats.aio.client.Client property) is_draining_pubs (nats.aio.client.Client property) is_reconnecting (nats.aio.client.Client property)

J

jetstream() (in module nats.aio.client.Client)

JetStreamManager (class in nats.js.manager) JsonParseError

K

KeyDeletedError KeyHistoryTooLargeError KeyNotFoundError keys() (nats.js.kv.KeyValue method) KeyValue (class in nats.js.kv)

KeyValue.BucketStatus (class in nats.js.kv) KeyValue.Entry (class in nats.js.kv) KeyValueConfig (class in nats.js.api) KeyValueError KeyWrongLastSequenceError

L

last_error (nats.aio.client.Client property)

LinkIsABucketError LostStreamData (class in nats.js.api)

M

max_payload (nats.aio.client.Client property) MaxPayloadError messages (nats.aio.subscription.Subscription property) metadata (nats.aio.msg.Msg property) module nats.aio.errors nats.errors nats.js.api nats.js.errors nats.js.manager nats.nuid

Msg (class in nats.aio.msg) Msg.Metadata (class in nats.aio.msg) Msg.Metadata.SequencePair (class in nats.aio.msg) MsgAlreadyAckdError

N

nak() (nats.aio.msg.Msg method) nats.aio.errors module nats.errors module nats.js.api module nats.js.errors module nats.js.manager module nats.nuid module

NatsError new_inbox() (in module nats.aio.client.Client) next() (nats.nuid.NUID method) next_msg() (nats.aio.subscription.Subscription method) NoKeysError NoRespondersError NoServersError NoStreamResponseError NotFoundError NotJSMessageError NUID (class in nats.nuid)

O

ObjectAlreadyExists ObjectDeletedError ObjectInfo (class in nats.js.api) ObjectLink (class in nats.js.api)

ObjectMeta (class in nats.js.api) ObjectMetaOptions (class in nats.js.api) ObjectNotFoundError ObjectStoreConfig (class in nats.js.api) OutboundBufferLimitError

P

PeerInfo (class in nats.js.api) pending_bytes (nats.aio.subscription.Subscription property) (nats.js.client.JetStreamContext.PullSubscription property) pending_data_size (nats.aio.client.Client property) pending_msgs (nats.aio.subscription.Subscription property) (nats.js.client.JetStreamContext.PullSubscription property) Placement (class in nats.js.api) ProtocolError

PubAck (class in nats.js.api) publish() (in module nats.aio.client.Client) (in module nats.js.client.JetStreamContext) pull_subscribe() (in module nats.js.client.JetStreamContext) PullSubscription (class in nats.js.client.JetStreamContext) purge() (nats.js.kv.KeyValue method) purge_deletes() (nats.js.kv.KeyValue method) purge_stream() (nats.js.manager.JetStreamManager method) put() (nats.js.kv.KeyValue method)

Q

queue (nats.aio.subscription.Subscription property)

R

RawStreamMsg (class in nats.js.api) ReplayPolicy (class in nats.js.api)

RePublish (class in nats.js.api) respond() (nats.aio.msg.Msg method) RetentionPolicy (class in nats.js.api)

S

SecureConnFailedError SecureConnRequiredError SecureConnWantedError SequenceInfo (class in nats.js.api) ServerError servers (nats.aio.client.Client property) ServiceUnavailableError sid (nats.aio.msg.Msg property) SlowConsumerError StaleConnectionError status() (nats.js.kv.KeyValue method) StatusCode (class in nats.js.api)

StorageType (class in nats.js.api) stream_info() (nats.js.manager.JetStreamManager method) StreamConfig (class in nats.js.api) StreamInfo (class in nats.js.api) StreamPurgeRequest (class in nats.js.api) streams_info() (nats.js.manager.JetStreamManager method) StreamSource (class in nats.js.api) StreamSourceInfo (class in nats.js.api) StreamState (class in nats.js.api) subject (nats.aio.subscription.Subscription property) subscribe() (in module nats.aio.client.Client) (in module nats.js.client.JetStreamContext) Subscription (class in nats.aio.subscription)

T

term() (nats.aio.msg.Msg method) Tier (class in nats.js.api)

TimeoutError ttl (nats.js.kv.KeyValue.BucketStatus property)

U

UnexpectedEOF unsubscribe() (nats.aio.subscription.Subscription method) (nats.js.client.JetStreamContext.PullSubscription method)

update() (nats.js.kv.KeyValue method) update_stream() (nats.js.manager.JetStreamManager method)

V

values (nats.js.kv.KeyValue.BucketStatus property)

W

watch() (nats.js.kv.KeyValue method)

watchall() (nats.js.kv.KeyValue method)