pub struct PersistentSubscriptionToAllOptions { /* private fields */ }Implementations
sourceimpl PersistentSubscriptionToAllOptions
impl PersistentSubscriptionToAllOptions
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 PersistentSubscriptionToAllOptions
impl PersistentSubscriptionToAllOptions
sourcepub fn settings(self, setts: PersistentSubscriptionSettings<Position>) -> Self
pub fn settings(self, setts: PersistentSubscriptionSettings<Position>) -> Self
Applies the specified persistent subscription settings.
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, value: bool) -> Self
pub fn resolve_link_tos(self, value: bool) -> Self
Whether or not the persistent subscription should resolve link events to their linked events.
sourcepub fn start_from(self, position: StreamPosition<Position>) -> Self
pub fn start_from(self, position: StreamPosition<Position>) -> Self
Where the subscription should start from (event number).
sourcepub fn extra_statistics(self, value: bool) -> Self
pub fn extra_statistics(self, value: bool) -> Self
Whether or not in depth latency statistics should be tracked on this subscription.
sourcepub fn message_timeout(self, value: Duration) -> Self
pub fn message_timeout(self, value: Duration) -> Self
The amount of time after which a message should be considered to be timeout and retried.
sourcepub fn max_retry_count(self, value: i32) -> Self
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.
sourcepub fn live_buffer_size(self, value: i32) -> Self
pub fn live_buffer_size(self, value: i32) -> Self
The size of the buffer listening to live messages as they happen.
sourcepub fn read_batch_size(self, value: i32) -> Self
pub fn read_batch_size(self, value: i32) -> Self
The number of events read at a time when paging in history.
sourcepub fn history_buffer_size(self, value: i32) -> Self
pub fn history_buffer_size(self, value: i32) -> Self
The number of events to cache when paging through history.
sourcepub fn checkpoint_after(self, value: Duration) -> Self
pub fn checkpoint_after(self, value: Duration) -> Self
The amount of time to try checkpoint after.
sourcepub fn checkpoint_lower_bound(self, value: i32) -> Self
pub fn checkpoint_lower_bound(self, value: i32) -> Self
The minimum number of messages to checkpoint.
sourcepub fn checkpoint_upper_bound(self, value: i32) -> Self
pub fn checkpoint_upper_bound(self, value: i32) -> Self
The minimum number of messages to checkpoint.
sourcepub fn max_subscriber_count(self, value: i32) -> Self
pub fn max_subscriber_count(self, value: i32) -> Self
The maximum number of subscribers allowed.
sourcepub fn consumer_strategy_name(self, value: SystemConsumerStrategy) -> Self
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
sourceimpl Clone for PersistentSubscriptionToAllOptions
impl Clone for PersistentSubscriptionToAllOptions
sourcefn clone(&self) -> PersistentSubscriptionToAllOptions
fn clone(&self) -> PersistentSubscriptionToAllOptions
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
sourceimpl Default for PersistentSubscriptionToAllOptions
impl Default for PersistentSubscriptionToAllOptions
sourcefn default() -> PersistentSubscriptionToAllOptions
fn default() -> PersistentSubscriptionToAllOptions
Returns the “default value” for a type. Read more
Auto Trait Implementations
impl RefUnwindSafe for PersistentSubscriptionToAllOptions
impl Send for PersistentSubscriptionToAllOptions
impl Sync for PersistentSubscriptionToAllOptions
impl Unpin for PersistentSubscriptionToAllOptions
impl UnwindSafe for PersistentSubscriptionToAllOptions
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