Struct eventstore::SubscribeToAllOptions

pub struct SubscribeToAllOptions { /* private fields */ }

Implementations

impl SubscribeToAllOptions

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 SubscribeToAllOptions

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

Starting point in the transaction journal log. By default, it will start at StreamPosition::Start

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

Filters events or streams based upon a predicate.

pub fn resolve_link_tos(self) -> Self

When using projections, you can have links placed into another stream. If you set true, the server will resolve those links and will return the event that the link points to. Default: NoResolution.

pub fn retry_options(self, options: RetryOptions) -> Self

When a disconnection happens, automatically resubscribe to stream changes. When enabled, The client will keep track of the current subscription offset.

Trait Implementations

impl Clone for SubscribeToAllOptions

fn clone(&self) -> SubscribeToAllOptions

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for SubscribeToAllOptions

fn default() -> Self

Returns the “default value” for a type.