Struct eventstore::SubscribeToStreamOptions
source · [−]pub struct SubscribeToStreamOptions { /* private fields */ }
Implementations
sourceimpl SubscribeToStreamOptions
impl SubscribeToStreamOptions
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 SubscribeToStreamOptions
impl SubscribeToStreamOptions
sourcepub fn start_from(self, position: StreamPosition<u64>) -> Self
pub fn start_from(self, position: StreamPosition<u64>) -> Self
For example, if a starting point of 50 is specified when a stream has 100 events in it, the subscriber can expect to see events 51 through 100, and then any events subsequently written events until such time as the subscription is dropped or closed.
By default, it’s StreamPosition::End
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 SubscribeToStreamOptions
impl Clone for SubscribeToStreamOptions
sourcefn clone(&self) -> SubscribeToStreamOptions
fn clone(&self) -> SubscribeToStreamOptions
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 SubscribeToStreamOptions
impl Send for SubscribeToStreamOptions
impl Sync for SubscribeToStreamOptions
impl Unpin for SubscribeToStreamOptions
impl UnwindSafe for SubscribeToStreamOptions
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