Struct eventstore::prelude::PersistentSubscriptionSettings

pub struct PersistentSubscriptionSettings<A> {

    pub resolve_link_tos: bool,
    pub start_from: StreamPosition<A>,
    pub extra_statistics: bool,
    pub message_timeout: Duration,
    pub max_retry_count: i32,
    pub live_buffer_size: i32,
    pub read_batch_size: i32,
    pub history_buffer_size: i32,
    pub checkpoint_after: Duration,
    pub checkpoint_lower_bound: i32,
    pub checkpoint_upper_bound: i32,
    pub max_subscriber_count: i32,
    pub consumer_strategy_name: SystemConsumerStrategy,
}

Gathers every persistent subscription property.

Fields

resolve_link_tos: bool

Whether or not the persistent subscription should resolve link events to their linked events.

start_from: StreamPosition<A>

Where the subscription should start from (event number).

extra_statistics: bool

Whether or not in depth latency statistics should be tracked on this subscription.

message_timeout: Duration

The amount of time after which a message should be considered to be timeout and retried.

max_retry_count: i32

The maximum number of retries (due to timeout) before a message get considered to be parked.

live_buffer_size: i32

The size of the buffer listening to live messages as they happen.

read_batch_size: i32

The number of events read at a time when paging in history.

history_buffer_size: i32

The number of events to cache when paging through history.

checkpoint_after: Duration

The amount of time to try checkpoint after.

checkpoint_lower_bound: i32

The minimum number of messages to checkpoint.

checkpoint_upper_bound: i32

The maximum number of messages to checkpoint. If this number is reached , a checkpoint will be forced.

max_subscriber_count: i32

The maximum number of subscribers allowed.

consumer_strategy_name: SystemConsumerStrategy

The strategy to use for distributing events to client consumers.

Trait Implementations

impl<A: Clone> Clone for PersistentSubscriptionSettings<A>

fn clone(&self) -> PersistentSubscriptionSettings<A>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<A: Debug> Debug for PersistentSubscriptionSettings<A>

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

Formats the value using the given formatter.

impl<A> Default for PersistentSubscriptionSettings<A>

fn default() -> PersistentSubscriptionSettings<A>

Returns the “default value” for a type.