Interface NatsConsumerManager

Interface for Consumer Manager

interface NatsConsumerManager {
    add(stream: string, config: NatsConsumerConfig): Promise<void>;
    delete(stream: string, consumer: string): Promise<boolean>;
    info(stream: string, consumer: string): Promise<NatsConsumerInfo>;
    list(stream: string): AsyncIterable<NatsConsumerInfo>;
}

Index

Methods

add delete info list

Methods

add

add(stream, config): Promise<void>
Parameters
- stream: string
- config: NatsConsumerConfig
Returns Promise<void>
- Defined in types/nats.ts:79

delete

delete(stream, consumer): Promise<boolean>
Parameters
- stream: string
- consumer: string
Returns Promise<boolean>
- Defined in types/nats.ts:80

info

info(stream, consumer): Promise<NatsConsumerInfo>
Parameters
- stream: string
- consumer: string
Returns Promise<NatsConsumerInfo>
- Defined in types/nats.ts:81

list

list(stream): AsyncIterable<NatsConsumerInfo>
Parameters
- stream: string
Returns AsyncIterable<NatsConsumerInfo>
- Defined in types/nats.ts:82