NatsTransportOptions
Options for creating a NATS JetStream-backed pubsub transport.
Properties
Section titled “Properties”connectionOptions?
Section titled “connectionOptions?”
optionalconnectionOptions?:Omit<ConnectionOptions,"servers">
Additional NATS connection options.
defaultSource?
Section titled “defaultSource?”
optionaldefaultSource?:string
Default CloudEvent source for publishers using this transport.
interceptors?
Section titled “interceptors?”
optionalinterceptors?:PubSubInterceptor[]
Optional interceptors for transport operations.
publishTimeoutMs?
Section titled “publishTimeoutMs?”
optionalpublishTimeoutMs?:number
Optional timeout for JetStream publish acknowledgements in milliseconds.
scheduler?
Section titled “scheduler?”
optionalscheduler?:PubSubScheduler
Optional scheduler used for durable notBefore publish and delayed retry.
Immediate publish/subscribe does not require a scheduler. If a publish call
provides notBefore, or a handler returns ctx.retry({ delay }), the
transport throws unless a scheduler was supplied.
servers?
Section titled “servers?”
optionalservers?:string|string[]
NATS server URLs passed to the client.
signal?
Section titled “signal?”
optionalsignal?:AbortSignal
Optional signal that closes this transport when aborted.
stream
Section titled “stream”stream:
NatsEventStreamOptions
Event stream configuration for normal publishes and subscribes.