Struct ParallelStateFile 

pub struct ParallelStateFile {
    pub schema_version: u32,
    pub started_at: String,
    pub target_branch: String,
    pub workers: Vec<WorkerRecord>,
}

Parallel state file for direct-push mode.

Fields

schema_version: u32

Schema version for migration compatibility.

started_at: String

Timestamp when the parallel run started (RFC3339).

target_branch: String

Target branch for direct pushes.

workers: Vec<WorkerRecord>

Active workers (one per task ID).

Implementations

impl ParallelStateFile

pub fn new( started_at: impl Into<String>, target_branch: impl Into<String>, ) -> Self

pub fn upsert_worker(&mut self, record: WorkerRecord)

Upsert a worker record. Replaces existing if task_id matches.

pub fn remove_worker(&mut self, task_id: &str)

Remove a worker by task_id.

pub fn get_worker(&self, task_id: &str) -> Option<&WorkerRecord>

Get a worker by task_id.

pub fn get_worker_mut(&mut self, task_id: &str) -> Option<&mut WorkerRecord>

Get a mutable worker by task_id.

pub fn has_worker(&self, task_id: &str) -> bool

Returns true if there’s a worker for this task_id.

pub fn workers_by_lifecycle( &self, lifecycle: WorkerLifecycle, ) -> impl Iterator<Item = &WorkerRecord>

Get all workers in a specific lifecycle state.

pub fn active_worker_count(&self) -> usize

Count workers that are not in a terminal state.

pub fn blocked_worker_count(&self) -> usize

Count workers in the blocked_push state.

Trait Implementations

impl Clone for ParallelStateFile

fn clone(&self) -> ParallelStateFile

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ParallelStateFile

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ParallelStateFile

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ParallelStateFile

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

where __S: Serializer,

Serialize this value into the given Serde serializer.