@horizon-republic/nestjs-jetstream

Enumerations

• ConsumeKind
• JetstreamDlqHeader
• JetstreamHeader
• JetstreamTrace
• MessageKind
• NatsErrorCode
• PatternPrefix
• PublishKind
• StreamKind
• TransportEvent

Classes

• JetstreamClient
• JetstreamHealthIndicator
• JetstreamModule
• JetstreamRecord
• JetstreamRecordBuilder
• JetstreamStrategy
• JsonCodec
• MsgpackCodec
• RpcContext

Interfaces

• CaptureBodyOptions
• Codec
• ConsumeSourceMsg
• DeadLetterInfo
• HandlerMetadata
• JetstreamConsumeContext
• JetstreamFeatureOptions
• JetstreamHealthStatus
• JetstreamModuleOptions
• JetstreamPublishContext
• JetstreamResponseContext
• MetadataRegistryOptions
• OrderedEventOverrides
• OtelOptions
• ScheduleRecordOptions
• ServerEndpoint
• StreamConsumerOverrides
• TransportHooks

Type Aliases

• ErrorClassification
• JetstreamModuleAsyncOptions
• RpcConfig
• StreamConfigOverrides

Variables

• DEFAULT_BROADCAST_CONSUMER_CONFIG
• DEFAULT_BROADCAST_STREAM_CONFIG
• DEFAULT_COMMAND_CONSUMER_CONFIG
• DEFAULT_COMMAND_STREAM_CONFIG
• DEFAULT_DLQ_STREAM_CONFIG
• DEFAULT_EVENT_CONSUMER_CONFIG
• DEFAULT_EVENT_STREAM_CONFIG
• DEFAULT_JETSTREAM_RPC_TIMEOUT
• DEFAULT_METADATA_BUCKET
• DEFAULT_METADATA_HISTORY
• DEFAULT_METADATA_REPLICAS
• DEFAULT_METADATA_TTL
• DEFAULT_ORDERED_STREAM_CONFIG
• DEFAULT_RPC_TIMEOUT
• DEFAULT_SHUTDOWN_TIMEOUT
• DEFAULT_TRACES
• JETSTREAM_CODEC
• JETSTREAM_CONNECTION
• JETSTREAM_OPTIONS
• MIN_METADATA_TTL
• RESERVED_HEADERS
• TRACER_NAME

Functions

• buildBroadcastSubject
• buildSubject
• consumerName
• dlqStreamName
• getClientToken
• internalName
• isCoreRpcMode
• isJetStreamRpcMode
• metadataKey
• streamName
• toNanos