Skip to content

JetStreamManagerLike

Defined in: src/io/broker/JetStreamActor.ts:650

readonly consumers: object

Defined in: src/io/broker/JetStreamActor.ts:661

add(stream, cfg): Promise<unknown>

string

ConsumerAddConfig

Promise<unknown>

update(stream, durable, cfg): Promise<unknown>

string

string

ConsumerAddConfig

Promise<unknown>


readonly streams: object

Defined in: src/io/broker/JetStreamActor.ts:651

add(cfg): Promise<unknown>

number

number

number

string

string

string

string[]

Promise<unknown>

update(name, cfg): Promise<unknown>

string

number

number

number

string

string

string[]

Promise<unknown>