pub struct OutboxDispatchOutcome {
pub requested: usize,
pub claimed: usize,
pub published: usize,
pub released: usize,
pub failed: usize,
}Expand description
Counts of what one dispatch pass did. Raced/unclaimable ids are reflected as
claimed < requested, not as an error; publish failures are released
(retryable) or failed (attempt ceiling reached), not errors.
Fields§
§requested: usizeRows asked for (id count for dispatch_ids, batch size for dispatch_batch).
claimed: usizeRows actually claimed this pass.
published: usizeRows published and completed.
released: usizeRows released for retry after a publish failure.
failed: usizeRows permanently failed after exhausting attempts.
Trait Implementations§
Source§impl Clone for OutboxDispatchOutcome
impl Clone for OutboxDispatchOutcome
Source§fn clone(&self) -> OutboxDispatchOutcome
fn clone(&self) -> OutboxDispatchOutcome
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · 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 OutboxDispatchOutcome
impl Debug for OutboxDispatchOutcome
Source§impl Default for OutboxDispatchOutcome
impl Default for OutboxDispatchOutcome
Source§fn default() -> OutboxDispatchOutcome
fn default() -> OutboxDispatchOutcome
Returns the “default value” for a type. Read more
Source§impl PartialEq for OutboxDispatchOutcome
impl PartialEq for OutboxDispatchOutcome
Source§fn eq(&self, other: &OutboxDispatchOutcome) -> bool
fn eq(&self, other: &OutboxDispatchOutcome) -> bool
Tests for
self and other values to be equal, and is used by ==.impl Copy for OutboxDispatchOutcome
impl Eq for OutboxDispatchOutcome
impl StructuralPartialEq for OutboxDispatchOutcome
Auto Trait Implementations§
impl Freeze for OutboxDispatchOutcome
impl RefUnwindSafe for OutboxDispatchOutcome
impl Send for OutboxDispatchOutcome
impl Sync for OutboxDispatchOutcome
impl Unpin for OutboxDispatchOutcome
impl UnsafeUnpin for OutboxDispatchOutcome
impl UnwindSafe for OutboxDispatchOutcome
Blanket Implementations§
Source§impl<T> AsyncAggregateBuilder for T
impl<T> AsyncAggregateBuilder for T
fn async_aggregate<A: Aggregate>(self) -> AsyncAggregateRepository<Self, A>
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<T> Queueable for T
impl<T> Queueable for T
Source§fn queued_async(self) -> QueuedRepository<Self, InMemoryAsyncLockManager>
fn queued_async(self) -> QueuedRepository<Self, InMemoryAsyncLockManager>
Wrap with the default async lock manager. Pair with
.async_aggregate::<T>() for per-aggregate serialization over the async
repository surface.Source§fn queued_async_with<L: AsyncLockManager>(
self,
lock_manager: L,
) -> QueuedRepository<Self, L>
fn queued_async_with<L: AsyncLockManager>( self, lock_manager: L, ) -> QueuedRepository<Self, L>
Wrap with a custom async lock manager.