Enum AdmissionResult 

pub enum AdmissionResult {
    Admitted,
    AlreadyPresent,
    CapacityRejected,
}

Outcome of ReplicationQueues::add_pending_verify.

Distinguishes “the key is already being handled” from “the key was silently dropped due to a queue capacity bound”. Bootstrap drain accounting and source-side retry logic MUST treat CapacityRejected as outstanding work; treating it like a dedup hit was the silent-drop regression introduced when the queues first became bounded.

Variants

Admitted

New entry inserted into pending_verify.

AlreadyPresent

Key was already in some pipeline stage; the existing entry is left in place. No retry required.

CapacityRejected

Global or per-source capacity bound rejected the entry. The caller MUST treat this as work still to do (not as silently completed).

Implementations

impl AdmissionResult

pub fn admitted(self) -> bool

true only for AdmissionResult::Admitted. Preserves call sites that only want to know “did the insert happen”.

Trait Implementations

impl Clone for AdmissionResult

fn clone(&self) -> AdmissionResult

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AdmissionResult

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

Formats the value using the given formatter.

impl PartialEq for AdmissionResult

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

impl Eq for AdmissionResult

impl StructuralPartialEq for AdmissionResult