Struct PipelineState 

pub struct PipelineState {
    pub phase: PipelinePhase,
    pub previous_phase: Option<PipelinePhase>,
    pub iteration: u32,
    pub total_iterations: u32,
    pub reviewer_pass: u32,
    pub total_reviewer_passes: u32,
    pub review_issues_found: bool,
    pub context_cleaned: bool,
    pub agent_chain: AgentChainState,
    pub rebase: RebaseState,
    pub commit: CommitState,
    pub execution_history: Vec<ExecutionStep>,
}

Immutable pipeline state (this IS the checkpoint).

Contains all information needed to resume pipeline execution at any point. The reducer updates this state by returning new immutable copies on each event.

Fields

phase: PipelinePhase

previous_phase: Option<PipelinePhase>

iteration: u32

total_iterations: u32

reviewer_pass: u32

total_reviewer_passes: u32

review_issues_found: bool

context_cleaned: bool

agent_chain: AgentChainState

rebase: RebaseState

commit: CommitState

execution_history: Vec<ExecutionStep>

Implementations

impl PipelineState

pub fn initial(developer_iters: u32, reviewer_reviews: u32) -> Self

pub fn is_complete(&self) -> bool

pub fn current_head(&self) -> String

Trait Implementations

impl Clone for PipelineState

fn clone(&self) -> PipelineState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PipelineState

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for PipelineState

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<PipelineCheckpoint> for PipelineState

Convert v3 checkpoint to reducer PipelineState.

Migrates existing checkpoint structure to new state format, ensuring backward compatibility with saved checkpoints.

fn from(checkpoint: PipelineCheckpoint) -> Self

Converts to this type from the input type.

impl Serialize for PipelineState

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

where __S: Serializer,

Serialize this value into the given Serde serializer.