Struct QueuedPayloadMeta 

pub struct QueuedPayloadMeta {
    pub event_name: EventName,
    pub bucket_name: String,
    pub object_name: String,
    pub content_type: String,
    pub queued_at_unix_ms: u64,
    pub payload_len: usize,
    pub dedup_id: String,
    pub failure: Option<FailedEntryMeta>,
}

Fields

event_name: EventName

bucket_name: String

object_name: String

content_type: String

queued_at_unix_ms: u64

payload_len: usize

dedup_id: String

Stable per-entry deduplication identifier sent as the NATS JetStream Nats-Msg-Id header. Empty for every non-JetStream target and for entries queued before JetStream was enabled, so it is skipped on serialization and absent stored entries decode to an empty value. This keeps the stored bytes identical to entries written without the field.

failure: Option<FailedEntryMeta>

Set only on an entry written to the failed-events store. None on every live-queue entry, so it is skipped on serialization and a live entry decodes with no failure metadata, keeping live stored bytes identical to entries written without the field.

Implementations

impl QueuedPayloadMeta

pub fn new( event_name: EventName, bucket_name: String, object_name: String, content_type: impl Into<String>, payload_len: usize, ) -> Self

pub fn best_effort_preview(&self, body: &[u8], limit: usize) -> String

Trait Implementations

impl Clone for QueuedPayloadMeta

fn clone(&self) -> QueuedPayloadMeta

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueuedPayloadMeta

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for QueuedPayloadMeta

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for QueuedPayloadMeta

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

where __S: Serializer,

Serialize this value into the given Serde serializer.