Struct IntentJournal 

pub struct IntentJournal {
    pub flush_uuid: String,
    pub keys: Vec<String>,
    pub recent_uuids: Vec<String>,
    pub installed_etag: Option<String>,
}

The intent journal written BEFORE uploads: which keys this barrier will touch and under which flush_uuid, so a restarted container can recognize its own crashed/torn PUT at the 412 (AdoptOwn) instead of mistaking it for a foreign write. recent_uuids keeps the last few barriers’ uuids for the same reason.

Fields

flush_uuid: String

keys: Vec<String>

recent_uuids: Vec<String>

installed_etag: Option<String>

The ETag of the manifest document THIS workspace last installed, written immediately after the CAS.

The merge base (Baseline::inst_base) and the baseline are both rewritten at step 7, after the CAS and after the GC deletes. A container restart in that window leaves the bucket holding a document we wrote and our persisted merge base one generation behind it — so at the next merge our own entries read as foreign changes, delete/modify resolves conservatively against the agent’s own delete, and the path is queued into the inbox as a conflict nobody else ever touched. Recording the installed ETag costs one small local write and restores exactly what step 7 was going to say: if the bucket is still at this document, the merge base IS this document.

Trait Implementations

impl Clone for IntentJournal

fn clone(&self) -> IntentJournal

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for IntentJournal

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

Formats the value using the given formatter.

impl Default for IntentJournal

fn default() -> IntentJournal

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for IntentJournal

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for IntentJournal

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

where __S: Serializer,

Serialize this value into the given Serde serializer.