Struct SubscriptionConfig 

#[non_exhaustive]
pub struct SubscriptionConfig { /* private fields */ }

Subscription configuration.

In-flight sizing precedence

During SubscriptionConfig::apply_defaults the bus reconciles three related inputs:

1. If backpressure is set, its max_in_flight / max_pending_acks seed the matching fields when those are still 0. Setting both backpressure.max_in_flight and max_in_flight to different non-zero values is a configuration error surfaced by validate.
2. max_in_flight falls back to 1 if still unset.
3. max_pending_acks falls back to 2 * max_in_flight.
4. If backpressure was unset, one is synthesized from the resolved max_in_flight / max_pending_acks.

Implementations

impl SubscriptionConfig

pub fn builder( topic: Topic, consumer_group: ConsumerGroup, ) -> SubscriptionConfigBuilder

Begin building a SubscriptionConfig for the given topic + group.

pub fn topic(&self) -> &Topic

pub fn consumer_group(&self) -> &ConsumerGroup

pub fn consumer_name(&self) -> &ConsumerName

pub fn ack_mode(&self) -> AckMode

pub fn ordering_mode(&self) -> Option<OrderingMode>

pub fn balance_mode(&self) -> Option<ConsumerBalanceMode>

pub fn guarantee(&self) -> Option<DeliveryGuarantee>

pub fn max_in_flight(&self) -> usize

pub fn max_pending_acks(&self) -> usize

pub fn max_retry(&self) -> usize

pub fn retry_backoff(&self) -> Duration

pub fn dead_letter_topic(&self) -> Option<&Topic>

pub fn backpressure(&self) -> Option<&BackpressurePolicy>

pub fn wildcard_topic(&self) -> bool

impl SubscriptionConfig

pub fn apply_defaults(&mut self)

Fill in zero-value fields with sensible defaults.

pub fn validate(&self) -> Result<(), EventBusError>

Check config consistency without mutating fields. Call apply_defaults first, or use normalize_and_validate.

pub fn normalize_and_validate(&mut self) -> Result<(), EventBusError>

Apply defaults then validate. Recommended single-call entrypoint.

Trait Implementations

impl Clone for SubscriptionConfig

fn clone(&self) -> SubscriptionConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SubscriptionConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.