pub struct PersistentSubscriptionOptions { /* private fields */ }
Implementations§
source§impl PersistentSubscriptionOptions
impl PersistentSubscriptionOptions
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
source§impl PersistentSubscriptionOptions
impl PersistentSubscriptionOptions
sourcepub fn settings(self, setts: PersistentSubscriptionSettings<u64>) -> Self
pub fn settings(self, setts: PersistentSubscriptionSettings<u64>) -> Self
Applies the specified persistent subscription settings.
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<u64>) -> Self
pub fn start_from(self, position: StreamPosition<u64>) -> 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<u64>
Trait Implementations§
source§impl Clone for PersistentSubscriptionOptions
impl Clone for PersistentSubscriptionOptions
source§fn clone(&self) -> PersistentSubscriptionOptions
fn clone(&self) -> PersistentSubscriptionOptions
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moresource§impl Default for PersistentSubscriptionOptions
impl Default for PersistentSubscriptionOptions
source§fn default() -> PersistentSubscriptionOptions
fn default() -> PersistentSubscriptionOptions
Auto Trait Implementations§
impl RefUnwindSafe for PersistentSubscriptionOptions
impl Send for PersistentSubscriptionOptions
impl Sync for PersistentSubscriptionOptions
impl Unpin for PersistentSubscriptionOptions
impl UnwindSafe for PersistentSubscriptionOptions
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T
in a tonic::Request