pub struct SweepReport {
pub acked: usize,
pub still_pending: usize,
pub not_due: usize,
pub exhausted: usize,
pub in_flight: usize,
pub deferred: usize,
pub orphaned: usize,
pub undecodable: usize,
pub bookkeeping_failures: usize,
pub scan_error: Option<String>,
}Expand description
Counts from one WebhookIngress::retry_pending_once pass.
Every pending entry lands in exactly one bucket, so the counts account for the whole spool — a delivery that vanishes from all of them is a bug the tests can see.
Fields§
§acked: usizeEntries a target acknowledged and that were removed.
still_pending: usizeEntries relayed this pass that stayed pending.
not_due: usizeEntries not yet eligible under the backoff schedule.
exhausted: usizeEntries past max_attempts — never retried again, never deleted, and
holding the health signal red until an operator intervenes.
in_flight: usizeEntries another relay was already handling.
deferred: usizeEntries left for the next tick by [SWEEP_BUDGET].
orphaned: usizeEntries whose source no longer maps to a configured target.
undecodable: usizeEntries on disk that could not be decoded.
bookkeeping_failures: usizeEntries whose post-relay spool write failed.
scan_error: Option<String>Set when the spool itself could not be listed.
Trait Implementations§
Source§impl Clone for SweepReport
impl Clone for SweepReport
Source§fn clone(&self) -> SweepReport
fn clone(&self) -> SweepReport
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for SweepReport
impl Debug for SweepReport
Source§impl Default for SweepReport
impl Default for SweepReport
Source§fn default() -> SweepReport
fn default() -> SweepReport
impl Eq for SweepReport
Source§impl PartialEq for SweepReport
impl PartialEq for SweepReport
impl StructuralPartialEq for SweepReport
Auto Trait Implementations§
impl Freeze for SweepReport
impl RefUnwindSafe for SweepReport
impl Send for SweepReport
impl Sync for SweepReport
impl Unpin for SweepReport
impl UnsafeUnpin for SweepReport
impl UnwindSafe for SweepReport
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
key and return true if they are equal.impl<A, B, T> HttpServerConnExec<A, B> for Twhere
B: Body,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more