Interface ConsumerAPI

interface ConsumerAPI {
    add(stream: string, cfg: Partial<ConsumerConfig>): Promise<ConsumerInfo>;
    delete(stream: string, consumer: string): Promise<boolean>;
    info(stream: string, consumer: string): Promise<ConsumerInfo>;
    list(stream: string): Lister<ConsumerInfo>;
    pause(stream: string, name: string, until?: Date): Promise<{
        pause_until?: string;
        paused: boolean;
    }>;
    resume(stream: string, name: string): Promise<{
        pause_until?: string;
        paused: boolean;
    }>;
    update(stream: string, durable: string, cfg: Partial<ConsumerUpdateConfig>): Promise<ConsumerInfo>;
}

Methods

add delete info list pause resume update

Methods

add

  • add(stream, cfg): Promise<ConsumerInfo>

  • Adds a new consumer to the specified stream with the specified consumer options.

    Parameters

    Returns Promise<ConsumerInfo>

delete

  • delete(stream, consumer): Promise<boolean>

  • Deletes the specified consumer name/durable from the specified stream.

    Parameters

    • stream: string
    • consumer: string

    Returns Promise<boolean>

info

  • info(stream, consumer): Promise<ConsumerInfo>

  • Returns the ConsumerInfo for the specified consumer in the specified stream.

    Parameters

    • stream: string
    • consumer: string

    Returns Promise<ConsumerInfo>

list

pause

  • pause(stream, name, until?): Promise<{
        pause_until?: string;
        paused: boolean;
    }>

  • Parameters

    • stream: string
    • name: string
    • Optionaluntil: Date

    Returns Promise<{
        pause_until?: string;
        paused: boolean;
    }>

resume

  • resume(stream, name): Promise<{
        pause_until?: string;
        paused: boolean;
    }>

  • Parameters

    • stream: string
    • name: string

    Returns Promise<{
        pause_until?: string;
        paused: boolean;
    }>

update

  • update(stream, durable, cfg): Promise<ConsumerInfo>

  • Updates the consumer configuration for the specified consumer on the specified stream that has the specified durable name.

    Parameters

    Returns Promise<ConsumerInfo>

Settings

Member Visibility

On This Page

Methods