Interface NatsStreamManager

Interface for Stream Manager

interface NatsStreamManager {
    add(config: Partial<NatsStreamConfig>): Promise<void>;
    delete(stream: string): Promise<boolean>;
    deleteMessage(stream: string, seq: number): Promise<boolean>;
    info(stream: string): Promise<NatsStreamInfo>;
    list(): AsyncIterable<NatsStreamInfo>;
    update(stream: string, config: NatsStreamConfig): Promise<void>;
}

Index

Methods

add delete deleteMessage info list update

Methods

add

add(config): Promise<void>
Parameters
- config: Partial<NatsStreamConfig>
Returns Promise<void>
- Defined in types/nats.ts:69

delete

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

deleteMessage

deleteMessage(stream, seq): Promise<boolean>
Parameters
- stream: string
- seq: number
Returns Promise<boolean>
- Defined in types/nats.ts:73

info

info(stream): Promise<NatsStreamInfo>
Parameters
- stream: string
Returns Promise<NatsStreamInfo>
- Defined in types/nats.ts:71

list

list(): AsyncIterable<NatsStreamInfo>
Returns AsyncIterable<NatsStreamInfo>
- Defined in types/nats.ts:72

update

update(stream, config): Promise<void>
Parameters
- stream: string
- config: NatsStreamConfig
Returns Promise<void>
- Defined in types/nats.ts:74