@nats-io/jetstream

Classes

JetStreamApiError
JetStreamError

Type Aliases

AbortOnMissingResource
AccountLimits
AckPolicy
Advisory
AdvisoryKind
ApiError
ApiPaged
ApiPagedRequest
Bind
BoundPushConsumerOptions
Close
Closed
ClusterInfo
ConsumeBytes
ConsumeCallback
ConsumeMessages
ConsumeOptions
Consumer
ConsumerAPI
ConsumerCallbackFn
ConsumerConfig
ConsumerDeleted
ConsumerInfo
ConsumerKind
ConsumerMessages
ConsumerNotFound
ConsumerNotification
Consumers
ConsumerUpdateConfig
Debug
DeleteableConsumer
DeliverPolicy
DeliveryInfo
Destroyable
DirectMsgHeaders
Discard
DiscardPolicy
ExceededLimits
Expires
ExportedConsumer
ExternalStream
FetchBytes
FetchMessages
FetchOptions
FlowControl
Heartbeat
HeartbeatsMissed
IdleHeartbeat
InfoableConsumer
JetStreamAccountStats
JetStreamApiCodes
JetStreamApiStats
JetStreamClient
JetStreamManager
JetStreamManagerOptions
JetStreamOptions
JetStreamPublishOptions
JetStreamUsage
JetStreamUsageAccountLimits
JsHeaders
JsMsg
LastForMsgRequest
Lister
LostStreamData
MaxBytes
MaxMessages
MsgDeleteRequest
MsgRequest
Next
NextOptions
NoResponders
OrderedConsumerOptions
OrderedConsumerRecreated
OrderedPushConsumerOptions
OverflowMinAckPending
OverflowMinPending
OverflowMinPendingAndMinAck
OverflowOptions
PeerInfo
Placement
PriorityGroups
PriorityPolicy
PubAck
PullOptions
PurgeBySeq
PurgeBySubject
PurgeOpts
PurgeResponse
PurgeTrimOpts
PushConsumer
PushConsumerOptions
ReplayPolicy
Republish
RepublishHeaders
Reset
RetentionPolicy
SeqMsgRequest
SequenceInfo
StorageType
StoreCompression
StoredMsg
Stream
StreamAlternate
StreamAPI
StreamConfig
StreamConsumerLimits
StreamInfo
StreamInfoRequestOptions
StreamNames
StreamNotFound
Streams
StreamSource
StreamSourceInfo
StreamState
StreamUpdateConfig
SubjectTransformConfig
Success
ThresholdBytes
ThresholdMessages

Variables

AckPolicy
AdvisoryKind
DeliverPolicy
DirectMsgHeaders
DiscardPolicy
JetStreamApiCodes
JsHeaders
PriorityPolicy
ReplayPolicy
RepublishHeaders
RetentionPolicy
StorageType
StoreCompression

Functions

isPullConsumer
isPushConsumer
jetstream
jetstreamManager

Settings

Member Visibility

On This Page

Classes
Type Aliases
AbortOnMissingResourceAccountLimitsAckPolicyAdvisoryAdvisoryKindApiErrorApiPagedApiPagedRequestBindBoundPushConsumerOptionsCloseClosedClusterInfoConsumeBytesConsumeCallbackConsumeMessagesConsumeOptionsConsumerConsumerAPIConsumerCallbackFnConsumerConfigConsumerDeletedConsumerInfoConsumerKindConsumerMessagesConsumerNotFoundConsumerNotificationConsumersConsumerUpdateConfigDebugDeleteableConsumerDeliverPolicyDeliveryInfoDestroyableDirectMsgHeadersDiscardDiscardPolicyExceededLimitsExpiresExportedConsumerExternalStreamFetchBytesFetchMessagesFetchOptionsFlowControlHeartbeatHeartbeatsMissedIdleHeartbeatInfoableConsumerJetStreamAccountStatsJetStreamApiCodesJetStreamApiStatsJetStreamClientJetStreamManagerJetStreamManagerOptionsJetStreamOptionsJetStreamPublishOptionsJetStreamUsageJetStreamUsageAccountLimitsJsHeadersJsMsgLastForMsgRequestListerLostStreamDataMaxBytesMaxMessagesMsgDeleteRequestMsgRequestNextNextOptionsNoRespondersOrderedConsumerOptionsOrderedConsumerRecreatedOrderedPushConsumerOptionsOverflowMinAckPendingOverflowMinPendingOverflowMinPendingAndMinAckOverflowOptionsPeerInfoPlacementPriorityGroupsPriorityPolicyPubAckPullOptionsPurgeBySeqPurgeBySubjectPurgeOptsPurgeResponsePurgeTrimOptsPushConsumerPushConsumerOptionsReplayPolicyRepublishRepublishHeadersResetRetentionPolicySeqMsgRequestSequenceInfoStorageTypeStoreCompressionStoredMsgStreamStreamAlternateStreamAPIStreamConfigStreamConsumerLimitsStreamInfoStreamInfoRequestOptionsStreamNamesStreamNotFoundStreamsStreamSourceStreamSourceInfoStreamStateStreamUpdateConfigSubjectTransformConfigSuccessThresholdBytesThresholdMessages
Variables
Functions