Enum CreditPolicy 

pub enum CreditPolicy {
    Drop,
    Detach,
    Park,
}

Credit policy (router-enforced credits).

Credits are an overload-control mechanism, not a reliability mechanism.

Contract

• Credit enforcement is implemented in the router loop; it does not change the underlying ABI layout.
• Credits are based on an estimated per-consumer queue depth and are best-effort.
• Credit policies are primarily intended for [RouterMode::WorkQueue].

Variants

Drop

Drop when a message cannot be delivered due to credit exhaustion.

Detach

Temporarily detach consumers that remain over the credit limit for long enough.

Detached consumers are not considered for delivery until they catch up.

Requires the std feature to measure elapsed time for the detach threshold. Without std, this behaves like CreditPolicy::Park (no detaches will occur).

Park

When no consumers are eligible (work-queue only), wait instead of dropping.

Trait Implementations

impl Clone for CreditPolicy

fn clone(&self) -> CreditPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CreditPolicy

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

Formats the value using the given formatter.

impl PartialEq for CreditPolicy

fn eq(&self, other: &CreditPolicy) -> 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 Copy for CreditPolicy

impl Eq for CreditPolicy

impl StructuralPartialEq for CreditPolicy