pub struct CommitReceipt {
pub outbox_message_ids: Vec<String>,
}Expand description
Outcome of an outbox-bearing commit.
Carries the ids of the outbox rows the transaction inserted so an
after-commit dispatcher knows exactly which rows to publish. This is the seam
the immediate-dispatch path hangs off (see
specs/durable-enqueue-outbox-dispatch).
Fields§
§outbox_message_ids: Vec<String>Ids of the outbox messages inserted by this commit, in insertion order.
Implementations§
Source§impl CommitReceipt
impl CommitReceipt
Sourcepub fn outbox_message_ids(&self) -> &[String]
pub fn outbox_message_ids(&self) -> &[String]
The outbox message ids inserted by this commit.
Sourcepub fn has_outbox_messages(&self) -> bool
pub fn has_outbox_messages(&self) -> bool
Whether this commit inserted any outbox messages.
Trait Implementations§
Source§impl Clone for CommitReceipt
impl Clone for CommitReceipt
Source§fn clone(&self) -> CommitReceipt
fn clone(&self) -> CommitReceipt
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 CommitReceipt
impl Debug for CommitReceipt
Source§impl Default for CommitReceipt
impl Default for CommitReceipt
Source§fn default() -> CommitReceipt
fn default() -> CommitReceipt
Returns the “default value” for a type. Read more
impl Eq for CommitReceipt
Source§impl PartialEq for CommitReceipt
impl PartialEq for CommitReceipt
impl StructuralPartialEq for CommitReceipt
Auto Trait Implementations§
impl Freeze for CommitReceipt
impl RefUnwindSafe for CommitReceipt
impl Send for CommitReceipt
impl Sync for CommitReceipt
impl Unpin for CommitReceipt
impl UnsafeUnpin for CommitReceipt
impl UnwindSafe for CommitReceipt
Blanket Implementations§
Source§impl<T> AggregateBuilder for T
impl<T> AggregateBuilder for T
fn aggregate<A: Aggregate>(self) -> AggregateRepository<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(self) -> QueuedRepository<Self, InMemoryLockManager>
fn queued(self) -> QueuedRepository<Self, InMemoryLockManager>
Wrap with the default async lock manager. Pair with
.aggregate::<T>() for per-aggregate serialization over the async
repository surface.Source§fn queued_with<L: LockManager>(
self,
lock_manager: L,
) -> QueuedRepository<Self, L>
fn queued_with<L: LockManager>( self, lock_manager: L, ) -> QueuedRepository<Self, L>
Wrap with a custom async lock manager.