kkrpc
    Preparing search index...

    Interface RedisStreamsTransportOptions

    Options for connecting a kkrpc transport to Redis Streams.

    interface RedisStreamsTransportOptions {
        blockTimeout?: number;
        consumerGroup?: string;
        consumerName?: string;
        localPeerId: string;
        maxLen?: number;
        remotePeerId?: string;
        stream?: string;
        url?: string;
        useConsumerGroup?: boolean;
    }
    Index

    Properties

    blockTimeout? consumerGroup? consumerName? localPeerId maxLen? remotePeerId? stream? url? useConsumerGroup?

    Properties

    blockTimeout?: number

    Blocking read timeout in milliseconds.

    consumerGroup?: string

    Consumer group used for acknowledged stream consumption.

    consumerName?: string

    Consumer name used within the consumer group.

    localPeerId: string

    Stable id for this endpoint; used to filter self-delivered messages.

    maxLen?: number

    Approximate maximum stream length to keep while publishing.

    remotePeerId?: string

    Optional target endpoint id for point-to-point delivery.

    stream?: string

    Stream name used to exchange kkrpc bus envelopes.

    url?: string

    Redis connection URL. Defaults to redis://localhost:6379.

    useConsumerGroup?: boolean

    Set false to use plain XREAD; plain stream reads have no acknowledgement primitive.

    Settings

    Member Visibility

    On This Page

    Properties