Struct eventstore::PersistentSubscriptionSettings

pub struct PersistentSubscriptionSettings {
    pub resolve_links: bool,
    pub revision: u64,
    pub extra_stats: 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 min_checkpoint_count: i32,
    pub max_checkpoint_count: i32,
    pub max_subscriber_count: i32,
    pub named_consumer_strategy: SystemConsumerStrategy,
}

Gathers every persistent subscription property.

Fields

resolve_links: bool

Whether or not the persistent subscription shoud resolve 'linkTo' events to their linked events.

revision: u64

Where the subscription should start from (event number).

extra_stats: 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 listenning 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.

min_checkpoint_count: i32

The minimum number of messages to checkpoint.

max_checkpoint_count: 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.

named_consumer_strategy: SystemConsumerStrategy

The strategy to use for distributing events to client consumers.

Implementations

impl PersistentSubscriptionSettings

pub fn default() -> PersistentSubscriptionSettings

Trait Implementations

impl Clone for PersistentSubscriptionSettings

pub fn clone(&self) -> PersistentSubscriptionSettings

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Copy for PersistentSubscriptionSettings

impl Debug for PersistentSubscriptionSettings

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

Formats the value using the given formatter.

impl Default for PersistentSubscriptionSettings

pub fn default() -> PersistentSubscriptionSettings

Returns the "default value" for a type.