pub enum OutboxMessageStatus {
Pending,
InFlight,
Published,
Failed,
}Expand description
Status of an outbox message.
Variants§
Implementations§
Trait Implementations§
Source§impl Clone for OutboxMessageStatus
impl Clone for OutboxMessageStatus
Source§fn clone(&self) -> OutboxMessageStatus
fn clone(&self) -> OutboxMessageStatus
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 OutboxMessageStatus
impl Debug for OutboxMessageStatus
Source§impl Default for OutboxMessageStatus
impl Default for OutboxMessageStatus
Source§fn default() -> OutboxMessageStatus
fn default() -> OutboxMessageStatus
Returns the “default value” for a type. Read more
Source§impl<'de> Deserialize<'de> for OutboxMessageStatus
impl<'de> Deserialize<'de> for OutboxMessageStatus
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
impl Eq for OutboxMessageStatus
Source§impl FromStr for OutboxMessageStatus
impl FromStr for OutboxMessageStatus
Source§impl PartialEq for OutboxMessageStatus
impl PartialEq for OutboxMessageStatus
Source§fn eq(&self, other: &OutboxMessageStatus) -> bool
fn eq(&self, other: &OutboxMessageStatus) -> bool
Tests for
self and other values to be equal, and is used by ==.Source§impl Serialize for OutboxMessageStatus
impl Serialize for OutboxMessageStatus
impl StructuralPartialEq for OutboxMessageStatus
Auto Trait Implementations§
impl Freeze for OutboxMessageStatus
impl RefUnwindSafe for OutboxMessageStatus
impl Send for OutboxMessageStatus
impl Sync for OutboxMessageStatus
impl Unpin for OutboxMessageStatus
impl UnsafeUnpin for OutboxMessageStatus
impl UnwindSafe for OutboxMessageStatus
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,
impl<T> DeserializeOwned for Twhere
T: for<'de> Deserialize<'de>,
Source§impl<T> Queueable for T
impl<T> Queueable for T
Source§fn queued(self) -> QueuedRepository<Self, InMemoryAsyncLockManager>
fn queued(self) -> QueuedRepository<Self, InMemoryAsyncLockManager>
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: AsyncLockManager>(
self,
lock_manager: L,
) -> QueuedRepository<Self, L>
fn queued_with<L: AsyncLockManager>( self, lock_manager: L, ) -> QueuedRepository<Self, L>
Wrap with a custom async lock manager.