Struct eventstore::PersistentSubscriptionToAllOptions

pub struct PersistentSubscriptionToAllOptions { /* private fields */ }

Implementations

impl PersistentSubscriptionToAllOptions

pub fn authenticated(self, credentials: Credentials) -> Self

Performs the command with the given credentials.

pub fn requires_leader(self, requires_leader: bool) -> Self

pub fn deadline(self, deadline: Duration) -> Self

impl PersistentSubscriptionToAllOptions

pub fn settings(self, setts: PersistentSubscriptionSettings<Position>) -> Self

Applies the specified persistent subscription settings.

pub fn filter(self, filter: SubscriptionFilter) -> Self

Filters events or streams based upon a predicate.

pub fn resolve_link_tos(self, value: bool) -> Self

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

pub fn start_from(self, position: StreamPosition<Position>) -> Self

Where the subscription should start from (event number).

pub fn extra_statistics(self, value: bool) -> Self

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

pub fn message_timeout(self, value: Duration) -> Self

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

pub fn max_retry_count(self, value: i32) -> Self

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

pub fn live_buffer_size(self, value: i32) -> Self

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

pub fn read_batch_size(self, value: i32) -> Self

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

pub fn history_buffer_size(self, value: i32) -> Self

The number of events to cache when paging through history.

pub fn checkpoint_after(self, value: Duration) -> Self

The amount of time to try checkpoint after.

pub fn checkpoint_lower_bound(self, value: i32) -> Self

The minimum number of messages to checkpoint.

pub fn checkpoint_upper_bound(self, value: i32) -> Self

The minimum number of messages to checkpoint.

pub fn max_subscriber_count(self, value: i32) -> Self

The maximum number of subscribers allowed.

pub fn consumer_strategy_name(self, value: SystemConsumerStrategy) -> Self

The strategy to use for distributing events to client consumers.

pub fn settings_mut(&mut self) -> &mut PersistentSubscriptionSettings<Position>

Trait Implementations

impl Clone for PersistentSubscriptionToAllOptions

fn clone(&self) -> PersistentSubscriptionToAllOptions

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for PersistentSubscriptionToAllOptions

fn default() -> PersistentSubscriptionToAllOptions

Returns the “default value” for a type.