Struct Message

Source

pub struct Message {Show 17 fields
    pub id: MessageId,
    pub version: u32,
    pub state: MessageState,
    pub idempotency_key: IdempotencyKey,
    pub correlation_id: Option<CorrelationId>,
    pub reply_to: Option<MessageId>,
    pub sender: Option<String>,
    pub recipient: Option<String>,
    pub channel: Option<String>,
    pub kind: Option<String>,
    pub payload: Option<Value>,
    pub deadline: Option<Timestamp>,
    pub delivery_attempts: u32,
    pub dead_letter_reason: Option<String>,
    pub delivery_refs: Option<BTreeMap<String, String>>,
    pub created_at: Timestamp,
    pub updated_at: Timestamp,
}

Expand description

Governed inter-party message. delivery_refs maps a delivery channel name to an opaque per-channel reference (replaces any single-vendor ref column).

Fields§

§id: MessageId§version: u32§state: MessageState§idempotency_key: IdempotencyKey§correlation_id: Option<CorrelationId>§reply_to: Option<MessageId>§sender: Option<String>§recipient: Option<String>§channel: Option<String>§kind: Option<String>§payload: Option<Value>§deadline: Option<Timestamp>§delivery_attempts: u32§dead_letter_reason: Option<String>§delivery_refs: Option<BTreeMap<String, String>>§created_at: Timestamp§updated_at: Timestamp

Message

Struct Message Copy item path

Fields§

Trait Implementations§

impl Clone for Message

fn clone(&self) -> Message

fn clone_from(&mut self, source: &Self)

impl Debug for Message

fn fmt(&self, f: &mut Formatter<'_>) -> Result

impl<'de> Deserialize<'de> for Message

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where __D: Deserializer<'de>,

impl PartialEq for Message

fn eq(&self, other: &Message) -> bool

fn ne(&self, other: &Rhs) -> bool

impl Serialize for Message

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>where __S: Serializer,

impl StructuralPartialEq for Message

impl Type for Message

fn definition(types: &mut Types) -> DataType

Auto Trait Implementations§

impl Freeze for Message

impl RefUnwindSafe for Message

impl Send for Message

impl Sync for Message

impl Unpin for Message

impl UnsafeUnpin for Message

impl UnwindSafe for Message

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> DeserializeOwned for Twhere T: for<'de> Deserialize<'de>,

impl<T> From<T> for T

fn from(t: T) -> T

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Struct Message

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
where __D: Deserializer<'de>,

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
where S: Serializer,

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T> CloneToUninit for T
where T: Clone,

impl<T> DeserializeOwned for T
where T: for<'de> Deserialize<'de>,

impl<T, U> Into<U> for T
where U: From<T>,

impl<T> ToOwned for T
where T: Clone,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,