pub struct PersistentSubscriptionSettings<A> {Show 13 fields
pub resolve_link_tos: bool,
pub start_from: StreamPosition<A>,
pub extra_statistics: bool,
pub message_timeout: Duration,
pub max_retry_count: i32,
pub live_buffer_size: i32,
pub read_batch_size: i32,
pub history_buffer_size: i32,
pub checkpoint_after: Duration,
pub checkpoint_lower_bound: i32,
pub checkpoint_upper_bound: i32,
pub max_subscriber_count: i32,
pub consumer_strategy_name: SystemConsumerStrategy,
}
Expand description
Gathers every persistent subscription property.
Fields§
§resolve_link_tos: bool
Whether or not the persistent subscription should resolve link events to their linked events.
start_from: StreamPosition<A>
Where the subscription should start from (event number).
extra_statistics: bool
Whether or not in depth latency statistics should be tracked on this subscription.
message_timeout: Duration
The amount of time after which a message should be considered to be timeout and retried.
max_retry_count: i32
The maximum number of retries (due to timeout) before a message get considered to be parked.
live_buffer_size: i32
The size of the buffer listening to live messages as they happen.
read_batch_size: i32
The number of events read at a time when paging in history.
history_buffer_size: i32
The number of events to cache when paging through history.
checkpoint_after: Duration
The amount of time to try checkpoint after.
checkpoint_lower_bound: i32
The minimum number of messages to checkpoint.
checkpoint_upper_bound: i32
The maximum number of messages to checkpoint. If this number is reached , a checkpoint will be forced.
max_subscriber_count: i32
The maximum number of subscribers allowed.
consumer_strategy_name: SystemConsumerStrategy
The strategy to use for distributing events to client consumers.
Trait Implementations§
source§impl<A: Clone> Clone for PersistentSubscriptionSettings<A>
impl<A: Clone> Clone for PersistentSubscriptionSettings<A>
source§fn clone(&self) -> PersistentSubscriptionSettings<A>
fn clone(&self) -> PersistentSubscriptionSettings<A>
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moresource§impl<A: Debug> Debug for PersistentSubscriptionSettings<A>
impl<A: Debug> Debug for PersistentSubscriptionSettings<A>
source§impl<A> Default for PersistentSubscriptionSettings<A>
impl<A> Default for PersistentSubscriptionSettings<A>
source§fn default() -> PersistentSubscriptionSettings<A>
fn default() -> PersistentSubscriptionSettings<A>
Auto Trait Implementations§
impl<A> RefUnwindSafe for PersistentSubscriptionSettings<A>where
A: RefUnwindSafe,
impl<A> Send for PersistentSubscriptionSettings<A>where
A: Send,
impl<A> Sync for PersistentSubscriptionSettings<A>where
A: Sync,
impl<A> Unpin for PersistentSubscriptionSettings<A>where
A: Unpin,
impl<A> UnwindSafe for PersistentSubscriptionSettings<A>where
A: UnwindSafe,
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