Struct ThreadCommitStagedWrites 

pub struct ThreadCommitStagedWrites {
    pub canonical_drafts: Vec<StagedCanonicalEvent>,
    pub server_events: Vec<ServerCanonicalEvent>,
    pub additional_outbox: Vec<OutboxMessageDraft>,
}

Event/outbox writes committed atomically with a checkpoint, supplied by server-side writers: the runtime tee’s canonical drafts (drained from the dispatch EventBuffer), server-authored canonical events, and inline outbox rows.

Fields

canonical_drafts: Vec<StagedCanonicalEvent>

server_events: Vec<ServerCanonicalEvent>

additional_outbox: Vec<OutboxMessageDraft>

Implementations

impl ThreadCommitStagedWrites

pub fn is_empty(&self) -> bool

Whether there are no staged writes — a plain checkpoint.

pub fn with_canonical_drafts( self, drafts: Vec<StagedCanonicalEvent>, ) -> ThreadCommitStagedWrites

Attach staged canonical drafts (runtime tee).

pub fn with_server_events( self, events: Vec<ServerCanonicalEvent>, ) -> ThreadCommitStagedWrites

Attach server-authored canonical events.

pub fn with_additional_outbox( self, rows: Vec<OutboxMessageDraft>, ) -> ThreadCommitStagedWrites

Attach inline-writer outbox rows.

pub fn validate(&self, thread_id: &str, run_id: &str) -> Result<(), CommitError>

Validate every staged write against the checkpoint’s thread/run scope. Mirrors the invariants the runtime-facing plan used to enforce inline.

Trait Implementations

impl Clone for ThreadCommitStagedWrites

fn clone(&self) -> ThreadCommitStagedWrites

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ThreadCommitStagedWrites

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

Formats the value using the given formatter.

impl Default for ThreadCommitStagedWrites

fn default() -> ThreadCommitStagedWrites

Returns the “default value” for a type.

impl PartialEq for ThreadCommitStagedWrites

fn eq(&self, other: &ThreadCommitStagedWrites) -> 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 StructuralPartialEq for ThreadCommitStagedWrites