JetStreamObjectStoreOptionsType
Ce contenu n’est pas encore disponible dans votre langue.
Defined in: src/io/broker/JetStreamObjectStoreOptions.ts:21
Common options every broker actor accepts on top of its protocol-
specific options. Subclasses extend this interface with their own
required fields (e.g. brokerUrl, topics).
Extends
Section titled “Extends”Properties
Section titled “Properties”bucket?
Section titled “bucket?”
readonlyoptionalbucket?:string
Defined in: src/io/broker/JetStreamObjectStoreOptions.ts:31
Bucket this actor operates on — required.
circuitBreaker?
Section titled “circuitBreaker?”
readonlyoptionalcircuitBreaker?:object
Defined in: src/io/broker/BrokerOptions.ts:48
Optional circuit-breaker around connectImplementation. After
failureThreshold consecutive failed connect attempts the breaker
opens for resetMs and rejects new attempts immediately.
failureThreshold
Section titled “failureThreshold”
readonlyfailureThreshold:number
resetMs
Section titled “resetMs”
readonlyresetMs:number
Inherited from
Section titled “Inherited from”BrokerCommonOptionsType.circuitBreaker
create?
Section titled “create?”
readonlyoptionalcreate?:boolean
Defined in: src/io/broker/JetStreamObjectStoreOptions.ts:53
Create the bucket at connect time when it does not exist. Default
true. false binds to an existing bucket and fails the connect if
it is missing.
description?
Section titled “description?”
readonlyoptionaldescription?:string
Defined in: src/io/broker/JetStreamObjectStoreOptions.ts:33
Human-readable bucket description. Only applied on create.
maxObjectBytes?
Section titled “maxObjectBytes?”
readonlyoptionalmaxObjectBytes?:number
Defined in: src/io/broker/JetStreamObjectStoreOptions.ts:47
Largest object body this actor will move, in bytes. Default 1 MiB.
It is a real limit, not a hint: a put above it is rejected before
the body reaches the bounded outbound buffer, and a get above it is
refused before the body is materialised. Raise it only as far as
outboundBuffer × maxObjectBytes stays a resident-memory figure you
are willing to hold while disconnected.
readonlyoptionalname?:string
Defined in: src/io/broker/JetStreamObjectStoreOptions.ts:29
Optional client name.
outboundBuffer?
Section titled “outboundBuffer?”
readonlyoptionaloutboundBuffer?:number
Defined in: src/io/broker/BrokerOptions.ts:61
Maximum number of outbound messages buffered while the connection
is connecting or disconnected. When the buffer is full the
oldest message is dropped (FIFO eviction) and a
BrokerBufferOverflow event is published. Default: 1000. Set
to 0 to fail-fast (publish a BrokerNotConnected event and drop
the message).
Inherited from
Section titled “Inherited from”BrokerCommonOptionsType.outboundBuffer
password?
Section titled “password?”
readonlyoptionalpassword?:string
Defined in: src/io/broker/JetStreamObjectStoreOptions.ts:27
reconnect?
Section titled “reconnect?”
readonlyoptionalreconnect?:false| {factor?:number;initialDelayMs?:number;maxAttempts?:number;maxDelayMs?:number; }
Defined in: src/io/broker/BrokerOptions.ts:35
Reconnect strategy applied when the underlying connection drops or
connectImplementation throws. Default: exponential backoff starting at
200ms, doubling, capped at 30s, infinite attempts. Set to
false to disable auto-reconnect (one-shot connections).
Union Members
Section titled “Union Members”false
Type Literal
Section titled “Type Literal”{ factor?: number; initialDelayMs?: number; maxAttempts?: number; maxDelayMs?: number; }
factor?
Section titled “factor?”
readonlyoptionalfactor?:number
initialDelayMs?
Section titled “initialDelayMs?”
readonlyoptionalinitialDelayMs?:number
maxAttempts?
Section titled “maxAttempts?”
readonlyoptionalmaxAttempts?:number
Cap on retry attempts. Default: Infinity (retry forever).
maxDelayMs?
Section titled “maxDelayMs?”
readonlyoptionalmaxDelayMs?:number
Inherited from
Section titled “Inherited from”BrokerCommonOptionsType.reconnect
replicas?
Section titled “replicas?”
readonlyoptionalreplicas?:number
Defined in: src/io/broker/JetStreamObjectStoreOptions.ts:37
Replica count. Only applied when the actor creates the bucket.
servers?
Section titled “servers?”
readonlyoptionalservers?:string| readonlystring[]
Defined in: src/io/broker/JetStreamObjectStoreOptions.ts:23
NATS server URLs.
storage?
Section titled “storage?”
readonlyoptionalstorage?:"memory"|"file"
Defined in: src/io/broker/JetStreamObjectStoreOptions.ts:35
Bucket storage backing. Only applied when the actor creates the bucket.
token?
Section titled “token?”
readonlyoptionaltoken?:string
Defined in: src/io/broker/JetStreamObjectStoreOptions.ts:25
Optional credentials.
readonlyoptionaluser?:string
Defined in: src/io/broker/JetStreamObjectStoreOptions.ts:26
