@nats-io/jetstream
    Preparing search index...

    Type Alias StreamSource

    type StreamSource = {
        consumer?: StreamConsumerSource;
        domain?: string;
        external?: ExternalStream;
        filter_subject?: string;
        name: string;
        opt_start_seq?: number;
        opt_start_time?: string;
        subject_transforms?: SubjectTransformConfig[];
    }
    Index

    Properties

    consumer? domain? external? filter_subject? name opt_start_seq? opt_start_time? subject_transforms?

    Properties

    consumer?: StreamConsumerSource

    Configures durable sourcing using a pre-created consumer. When set, the server uses the named durable consumer instead of an ephemeral ordered consumer. Required for reliable mirroring/sourcing of WorkQueue or Interest streams. Available on server 2.14+ (ADR-60).

    domain?: string

    This field is a convenience for setting up an ExternalStream. If set, the value here is used to calculate the JetStreamAPI prefix. This field is never serialized to the server. This value cannot be set if external is set.

    external?: ExternalStream

    This value cannot be set if domain is set

    filter_subject?: string

    An optional filter subject. If the filter matches the message will be on-boarded.

    name: string

    Name of the stream source

    opt_start_seq?: number

    An optional start sequence from which to start reading messages

    opt_start_time?: string

    An optional start time Date string

    subject_transforms?: SubjectTransformConfig[]

    Apply a subject transforms to sourced messages before doing anything else. This feature only supported on 2.10.x and better.

    Settings

    Member Visibility

    On This Page

    Properties