Struct MatrixState 

pub struct MatrixState { /* private fields */ }

State derives only from canonical snapshots; callers persist each mutation before effects.

Implementations

impl MatrixState

pub fn create(spec: MatrixSpec, root: &Path) -> MatrixResult<Self>

Create an idle matrix after structural and path validation.

pub fn from_snapshot(snapshot: MatrixSnapshot) -> MatrixResult<Self>

Validate and restore a retained canonical checkpoint.

pub fn snapshot(&self) -> &MatrixSnapshot

Inspect the complete canonical state.

pub fn event(&self) -> ThreadEvent

Build the canonical event for an acknowledged persistence barrier.

pub fn active_assignments(&self) -> Vec<MatrixAssignment>

Assignments whose owned work has not been confirmed stopped.

pub fn start(&mut self) -> MatrixResult<()>

Freeze creation and permit scheduler dispatch.

pub fn pause(&mut self) -> MatrixResult<()>

Stop new dispatch while admitted workers finish.

pub fn resume(&mut self) -> MatrixResult<()>

Resume dispatch from a paused phase.

pub fn cancel(&mut self) -> MatrixResult<()>

Permanently stop new dispatch; owned workers still require cleanup.

pub fn reserve_ready( &mut self, configured_cap: usize, ) -> MatrixResult<Vec<MatrixAssignment>>

Reserve slot, shared workspace lease, and all named resources as one state mutation.

pub fn mark_launch_requested(&mut self, attempt_id: &str) -> MatrixResult<()>

Persist this marker before invoking a process or worker launch.

pub fn rollback_launch(&mut self, attempt_id: &str) -> MatrixResult<()>

Release a launch reservation after launch failure and confirmed cleanup.

pub fn report( &mut self, attempt_id: &str, worker_id: &str, outcome: MatrixOutcome, evidence: Vec<MatrixCommandEvidence>, cleanup_confirmed: bool, ) -> MatrixResult<()>

Runtime must resolve evidence IDs to owned completed canonical commands before calling.

pub fn begin_verification(&mut self, generation: String) -> MatrixResult<()>

Start complete final verification after every execution task finishes.

pub fn finalize_verification(&mut self, generation: &str) -> MatrixResult<()>

The runtime fingerprints again after cleanup before committing success.

pub fn recover(&mut self) -> MatrixResult<()>

Explicit resume reconciles prepared assignments and blocks ambiguous survivors.

pub fn invalidate_verification( &mut self, generation: String, ) -> MatrixResult<()>

Invalidate every verification result after a source generation change.

pub fn retry(&mut self, task_id: &str) -> MatrixResult<()>

Retry a failed task after an explicit coordinator decision and cleanup.

pub fn confirm_cleanup( &mut self, attempt_id: &str, worker_id: &str, ) -> MatrixResult<()>

Cleanup must be established by an ownership token, never a PID alone.

Trait Implementations

impl Clone for MatrixState

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MatrixState

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

Formats the value using the given formatter.