Struct ReliableMessage 

pub struct ReliableMessage {
    pub message_id: String,
    pub event: StreamEvent,
    pub retry_count: u32,
    pub first_attempt: DateTime<Utc>,
    pub last_attempt: DateTime<Utc>,
    pub errors: Vec<String>,
    pub checksum: Option<String>,
    pub sequence_number: Option<u64>,
    pub partition_key: Option<String>,
    pub replay_count: u32,
    pub last_replay_attempt: Option<DateTime<Utc>>,
    pub replay_status: ReplayStatus,
}

Message wrapper with reliability metadata

Fields

message_id: String

Unique message ID for deduplication

event: StreamEvent

Original event

retry_count: u32

Number of retry attempts

first_attempt: DateTime<Utc>

First attempt timestamp

last_attempt: DateTime<Utc>

Last attempt timestamp

errors: Vec<String>

Error history

checksum: Option<String>

Message checksum for integrity

sequence_number: Option<u64>

Sequence number for ordering

partition_key: Option<String>

Partition key for ordering within partition

replay_count: u32

Number of replay attempts from DLQ

last_replay_attempt: Option<DateTime<Utc>>

Last replay attempt timestamp

replay_status: ReplayStatus

Replay status

Implementations

impl ReliableMessage

pub fn new(event: StreamEvent) -> Self

Create a new reliable message

pub fn add_error(&mut self, error: String)

Add error to message history

pub fn should_retry(&self, max_retries: u32) -> bool

Check if message should be retried

pub fn next_retry_delay(&self, config: &ReliabilityConfig) -> Duration

Calculate next retry delay

Trait Implementations

impl Clone for ReliableMessage

fn clone(&self) -> ReliableMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReliableMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ReliableMessage

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ReliableMessage

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

where __S: Serializer,

Serialize this value into the given Serde serializer.