pub struct ReconcileReport {
pub scanned: u64,
pub reconciled: u64,
pub noop: u64,
pub filtered: u64,
pub errors: u64,
}Expand description
Per-tick work report. Returned so the driving scanner task can emit metrics + logs at cycle boundary without re-querying.
Fields§
§scanned: u64Rows matched by the scan query before filter application.
reconciled: u64Events that produced DispatchOutcome::Advanced(_).
noop: u64Events that produced DispatchOutcome::NoOp (concurrent
dispatcher won the claim race between our SELECT and our
re-dispatch — legal, logged at trace).
filtered: u64Events skipped by the ScannerFilter.
errors: u64Re-dispatch invocations that returned EngineError. The
event row stays dispatched_at_ms IS NULL and the next tick
will retry.
Trait Implementations§
Source§impl Clone for ReconcileReport
impl Clone for ReconcileReport
Source§fn clone(&self) -> ReconcileReport
fn clone(&self) -> ReconcileReport
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for ReconcileReport
impl Debug for ReconcileReport
Source§impl Default for ReconcileReport
impl Default for ReconcileReport
Source§fn default() -> ReconcileReport
fn default() -> ReconcileReport
Returns the “default value” for a type. Read more
Source§impl PartialEq for ReconcileReport
impl PartialEq for ReconcileReport
impl Copy for ReconcileReport
impl Eq for ReconcileReport
impl StructuralPartialEq for ReconcileReport
Auto Trait Implementations§
impl Freeze for ReconcileReport
impl RefUnwindSafe for ReconcileReport
impl Send for ReconcileReport
impl Sync for ReconcileReport
impl Unpin for ReconcileReport
impl UnsafeUnpin for ReconcileReport
impl UnwindSafe for ReconcileReport
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
Mutably borrows from an owned value. Read more
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§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key and return true if they are equal.Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
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>
Converts
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>
Converts
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