Struct ConsumerClientConfig 

pub struct ConsumerClientConfig {
    pub consumer_name: String,
    pub subject: String,
    pub num_parts: usize,
    pub inactive_threshold: Duration,
    pub repartition_attempts: usize,
    pub repartition_delay: Duration,
    pub fetch_timeout: Duration,
}

Configuration for a ConsumerClient.

Fields

consumer_name: String

Name of the consumer. Must be unique over the stream.

Defaults to a random number between 0 and 10000.

subject: String

Subject to subscribe to.

Defaults to "consumer_subject".

num_parts: usize

The number of parts the stream is partitioned into. This number should be consistent with how the stream was partitioned, e.g with its subject_transform option.

Defaults to 100.

inactive_threshold: Duration

How long the consumer should stay alive before JetStream kills it when inactive.

Defaults to 30 seconds.

repartition_attempts: usize

How many times the client should try updating the consumer’s filter_subjects before giving up. See module’s documentation.

Defaults to 5.

repartition_delay: Duration

Time to wait between attempts to update the filter_subjects. See module’s documentation.

Defaults to 1 second.

fetch_timeout: Duration

Timeout after which message fetching fails. If this timeout expires we return None.

Defaults to 30 seconds.

Implementations

impl ConsumerClientConfig

pub fn for_rooms(name: String) -> Self

Creates a consumer config that subscribes to the room subject

Trait Implementations

impl Clone for ConsumerClientConfig

fn clone(&self) -> ConsumerClientConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ConsumerClientConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ConsumerClientConfig

fn default() -> Self

Returns the “default value” for a type.