Interface StreamAPI

interface StreamAPI {
    add(cfg: Partial<StreamConfig>): Promise<StreamInfo>;
    delete(stream: string): Promise<boolean>;
    deleteMessage(stream: string, seq: number, erase?: boolean): Promise<boolean>;
    find(subject: string): Promise<string>;
    get(name: string): Promise<Stream>;
    getMessage(stream: string, query: MsgRequest): Promise<StoredMsg>;
    info(stream: string, opts?: Partial<StreamInfoRequestOptions>): Promise<StreamInfo>;
    list(subject?: string): Lister<StreamInfo>;
    names(subject?: string): Lister<string>;
    purge(stream: string, opts?: PurgeOpts): Promise<PurgeResponse>;
    update(name: string, cfg: Partial<StreamUpdateConfig>): Promise<StreamInfo>;
}

Methods

add delete deleteMessage find get getMessage info list names purge update

Methods

add

  • add(cfg): Promise<StreamInfo>

  • Adds a new stream with the specified stream configuration.

    Parameters

    Returns Promise<StreamInfo>

delete

  • delete(stream): Promise<boolean>

  • Deletes the specified stream

    Parameters

    • stream: string

    Returns Promise<boolean>

deleteMessage

  • deleteMessage(stream, seq, erase?): Promise<boolean>

  • Deletes the specified message sequence from the stream

    Parameters

    • stream: string
    • seq: number
    • Optionalerase: boolean

      erase the message - by default true

    Returns Promise<boolean>

find

  • find(subject): Promise<string>

  • Find the stream that stores the specified subject.

    Parameters

    • subject: string

    Returns Promise<string>

get

  • get(name): Promise<Stream>

  • Returns a Stream object

    Parameters

    • name: string

    Returns Promise<Stream>

getMessage

  • getMessage(stream, query): Promise<StoredMsg>

  • Retrieves the message matching the specified query. Messages can be retrieved by sequence number or by last sequence matching a subject.

    Parameters

    Returns Promise<StoredMsg>

info

  • info(stream, opts?): Promise<StreamInfo>

  • Returns the information about the specified stream

    Parameters

    Returns Promise<StreamInfo>

list

  • list(subject?): Lister<StreamInfo>

  • Lists all streams stored by JetStream

    Parameters

    • Optionalsubject: string

      only return streams that include the specified subject

    Returns Lister<StreamInfo>

names

  • names(subject?): Lister<string>

  • Return a Lister of stream names

    Parameters

    • Optionalsubject: string

      if specified, the results are filtered to streams that contain the subject (can be wildcarded)

    Returns Lister<string>

purge

  • purge(stream, opts?): Promise<PurgeResponse>

  • Purges messages from a stream that match the specified purge options.

    Parameters

    Returns Promise<PurgeResponse>

update

  • update(name, cfg): Promise<StreamInfo>

  • Updates the stream configuration for the specified stream.

    Parameters

    Returns Promise<StreamInfo>

Settings

Member Visibility

On This Page

Methods