Enum PressureResponse 

pub enum PressureResponse {
    Accept,
    Defer {
        delay: Duration,
    },
    Reject {
        reason: String,
    },
}

Application-visible backpressure result for a publish operation.

Pressure responses are part of the successful publish path so applications can react to delivery, buffering, and shedding decisions without those signals being hidden inside transport-specific errors.

Variants

Accept

The message was accepted and delivered to the consumer.

Defer

The message was accepted into a buffer and will be delivered later.

Fields

delay: Duration

Estimated delay before the buffered message can be delivered.

Reject

The consumer was overwhelmed and the message was shed.

Fields

reason: String

Human-readable reason describing why the message was shed.

Trait Implementations

impl Clone for PressureResponse

fn clone(&self) -> PressureResponse

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PressureResponse

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

Formats the value using the given formatter.

impl Eq for PressureResponse

impl PartialEq for PressureResponse

fn eq(&self, other: &PressureResponse) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for PressureResponse