pub struct PersistentSubscriptionToAllOptions { /* private fields */ }
Implementations
Performs the command with the given credentials.
Applies the specified persistent subscription settings.
Filters events or streams based upon a predicate.
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 PersistentSubscriptionToAllOptions
impl Sync for PersistentSubscriptionToAllOptions
impl Unpin for PersistentSubscriptionToAllOptions
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