pub struct PersistentSubscriptionOptions { /* private fields */ }
Implementations
Performs the command with the given credentials.
Applies the specified persistent subscription settings.
Whether or not the persistent subscription should resolve link events to their linked events.
Where the subscription should start from (event number).
Whether or not in depth latency statistics should be tracked on this subscription.
The amount of time after which a message should be considered to be timeout and retried.
The maximum number of retries (due to timeout) before a message get considered to be parked.
The size of the buffer listening to live messages as they happen.
The number of events read at a time when paging in history.
The number of events to cache when paging through history.
The amount of time to try checkpoint after.
The minimum number of messages to checkpoint.
The minimum number of messages to checkpoint.
The maximum number of subscribers allowed.
The strategy to use for distributing events to client consumers.
Trait Implementations
Returns the “default value” for a type. Read more
Auto Trait Implementations
impl Send for PersistentSubscriptionOptions
impl Sync for PersistentSubscriptionOptions
impl Unpin for PersistentSubscriptionOptions
impl UnwindSafe for PersistentSubscriptionOptions
Blanket Implementations
Mutably borrows from an owned value. Read more
Wrap the input message T
in a tonic::Request
pub fn vzip(self) -> V
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more