JetStreamManagerLike
JetStreamManagerLike =
object
Defined in: src/io/broker/JetStreamActor.ts:648
Properties
Section titled “Properties”consumers
Section titled “consumers”
readonlyconsumers:object
Defined in: src/io/broker/JetStreamActor.ts:659
add(
stream,config):Promise<unknown>
Parameters
Section titled “Parameters”stream
Section titled “stream”string
config
Section titled “config”ConsumerAddConfig
Returns
Section titled “Returns”Promise<unknown>
update()
Section titled “update()”update(
stream,durable,config):Promise<unknown>
Parameters
Section titled “Parameters”stream
Section titled “stream”string
durable
Section titled “durable”string
config
Section titled “config”ConsumerAddConfig
Returns
Section titled “Returns”Promise<unknown>
streams
Section titled “streams”
readonlystreams:object
Defined in: src/io/broker/JetStreamActor.ts:649
add(
config):Promise<unknown>
Parameters
Section titled “Parameters”config
Section titled “config”max_age?
Section titled “max_age?”number
max_bytes?
Section titled “max_bytes?”number
max_msgs?
Section titled “max_msgs?”number
string
retention?
Section titled “retention?”string
storage?
Section titled “storage?”string
subjects
Section titled “subjects”string[]
Returns
Section titled “Returns”Promise<unknown>
update()
Section titled “update()”update(
name,config):Promise<unknown>
Parameters
Section titled “Parameters”string
config
Section titled “config”max_age?
Section titled “max_age?”number
max_bytes?
Section titled “max_bytes?”number
max_msgs?
Section titled “max_msgs?”number
retention?
Section titled “retention?”string
storage?
Section titled “storage?”string
subjects
Section titled “subjects”string[]
Returns
Section titled “Returns”Promise<unknown>