pub struct PersistentSubscriptionConfig {Show 14 fields
pub resolve_linktos: bool,
pub start_from: i64,
pub message_timeout_milliseconds: i64,
pub extra_statistics: bool,
pub max_retry_count: i64,
pub live_buffer_size: i64,
pub buffer_size: i64,
pub read_batch_size: i64,
pub prefer_round_robin: bool,
pub checkpoint_after_milliseconds: i64,
pub min_checkpoint_count: i64,
pub max_checkpoint_count: i64,
pub max_subscriber_count: i64,
pub named_consumer_strategy: SystemConsumerStrategy,
}
Fields
resolve_linktos: bool
start_from: i64
message_timeout_milliseconds: i64
extra_statistics: bool
max_retry_count: i64
live_buffer_size: i64
buffer_size: i64
read_batch_size: i64
prefer_round_robin: bool
checkpoint_after_milliseconds: i64
min_checkpoint_count: i64
max_checkpoint_count: i64
max_subscriber_count: i64
named_consumer_strategy: SystemConsumerStrategy
Trait Implementations
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Auto Trait Implementations
impl Send for PersistentSubscriptionConfig
impl Sync for PersistentSubscriptionConfig
impl Unpin for PersistentSubscriptionConfig
impl UnwindSafe for PersistentSubscriptionConfig
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