Struct PendingOutboundEntry 

pub struct PendingOutboundEntry {
    pub envelope_bytes: Vec<u8>,
    pub redelivered: bool,
}

One outbound envelope that hadn’t been shipped yet when the snapshot was taken. The redelivered flag tells the transport adapter “I’ve seen this before, decide whether to ship again.”

Fields

envelope_bytes: Vec<u8>

Prost-serialized WireEnvelope bytes.

redelivered: bool

true once a previous snapshot/restore cycle already surfaced this envelope.

Trait Implementations

impl Clone for PendingOutboundEntry

fn clone(&self) -> PendingOutboundEntry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PendingOutboundEntry

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for PendingOutboundEntry

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for PendingOutboundEntry

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

where __S: Serializer,

Serialize this value into the given Serde serializer.