Struct eventstore::SubscribeToAllOptions
source · [−]pub struct SubscribeToAllOptions { /* private fields */ }
Implementations
sourceimpl SubscribeToAllOptions
impl SubscribeToAllOptions
sourcepub fn authenticated(self, credentials: Credentials) -> Self
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
sourceimpl SubscribeToAllOptions
impl SubscribeToAllOptions
sourcepub fn position(self, position: StreamPosition<Position>) -> Self
pub fn position(self, position: StreamPosition<Position>) -> Self
Starting point in the transaction journal log. By default, it will start at
StreamPosition::Start
sourcepub fn filter(self, filter: SubscriptionFilter) -> Self
pub fn filter(self, filter: SubscriptionFilter) -> Self
Filters events or streams based upon a predicate.
sourcepub fn resolve_link_tos(self) -> Self
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.
sourcepub fn retry_options(self, options: RetryOptions) -> Self
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
sourceimpl Clone for SubscribeToAllOptions
impl Clone for SubscribeToAllOptions
sourcefn clone(&self) -> SubscribeToAllOptions
fn clone(&self) -> SubscribeToAllOptions
Returns a copy of the value. Read more
1.0.0 · sourcefn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source
. Read more
Auto Trait Implementations
impl RefUnwindSafe for SubscribeToAllOptions
impl Send for SubscribeToAllOptions
impl Sync for SubscribeToAllOptions
impl Unpin for SubscribeToAllOptions
impl UnwindSafe for SubscribeToAllOptions
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
sourcefn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message T
in a tonic::Request
sourceimpl<T> ToOwned for T where
T: Clone,
impl<T> ToOwned for T where
T: Clone,
type Owned = T
type Owned = T
The resulting type after obtaining ownership.
sourcefn clone_into(&self, target: &mut T)
fn clone_into(&self, target: &mut T)
toowned_clone_into
)Uses borrowed data to replace owned data, usually by cloning. Read more
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
fn vzip(self) -> V
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more