Struct ReplicationStatusEntry 

pub struct ReplicationStatusEntry {
    pub status: ReplicationStatus,
    pub generation: u64,
    pub recorded_at: DateTime<Utc>,
}

Per-(source_bucket, source_key) replication status entry, paired with the generation token of the source PUT that produced it.

v0.8.2 #61 — generation token

Each put_object (or complete_multipart_upload) on a source key pulls a fresh, monotonically-increasing generation from the manager. The detached replication task carries that generation and only stamps the status when its generation is >= the stored one (CAS-style). A stale retry whose generation has been overtaken by a newer PUT is silently dropped, so the destination bucket never gets rolled back to older bytes. See ReplicationManager::next_generation

• ReplicationManager::record_status_if_newer.

v0.8.3 #66 — recorded_at for sweep + TTL (H-5 audit fix)

Each stamp records the wall-clock time the entry was last updated. The hourly sweep task (ReplicationManager::sweep_stale) drops terminal entries (Completed / Failed) older than the operator- configured TTL, bounding the otherwise-unbounded growth of the statuses map under workloads with many unique keys. Pending entries are never swept (they are still in-flight and dropping them would lose the eventual Completed / Failed stamp the dispatcher is racing toward). Pre-#66 snapshots without recorded_at deserialise with Utc::now() (= “freshly observed at restart”) which delays the first sweep by one TTL cycle but never drops a still-relevant entry early.

Fields

status: ReplicationStatus

generation: u64

recorded_at: DateTime<Utc>

v0.8.3 #66: when the entry was last updated. The sweep drops terminal entries (Completed / Failed) older than the operator- configured TTL. Pending entries are never swept (still in-flight). Pre-#66 snapshots default to Utc::now() so legacy entries get one full TTL window of grace before becoming sweep-eligible.

Trait Implementations

impl Clone for ReplicationStatusEntry

fn clone(&self) -> ReplicationStatusEntry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReplicationStatusEntry

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ReplicationStatusEntry

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for ReplicationStatusEntry

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for ReplicationStatusEntry

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for ReplicationStatusEntry

impl StructuralPartialEq for ReplicationStatusEntry