Enum PipelineEvent 

pub enum PipelineEvent {
    PipelineStarted,
    PipelineResumed {
        from_checkpoint: bool,
    },
    PipelineCompleted,
    PipelineAborted {
        reason: String,
    },
    PlanningPhaseStarted,
    PlanningPhaseCompleted,
    DevelopmentPhaseStarted,
    DevelopmentIterationStarted {
        iteration: u32,
    },
    PlanGenerationStarted {
        iteration: u32,
    },
    PlanGenerationCompleted {
        iteration: u32,
        valid: bool,
    },
    DevelopmentIterationCompleted {
        iteration: u32,
        output_valid: bool,
    },
    ContextCleaned,
    DevelopmentPhaseCompleted,
    ReviewPhaseStarted,
    ReviewPassStarted {
        pass: u32,
    },
    ReviewCompleted {
        pass: u32,
        issues_found: bool,
    },
    FixAttemptStarted {
        pass: u32,
    },
    FixAttemptCompleted {
        pass: u32,
        changes_made: bool,
    },
    ReviewPhaseCompleted {
        early_exit: bool,
    },
    AgentInvocationStarted {
        role: AgentRole,
        agent: String,
        model: Option<String>,
    },
    AgentInvocationSucceeded {
        role: AgentRole,
        agent: String,
    },
    AgentInvocationFailed {
        role: AgentRole,
        agent: String,
        exit_code: i32,
        error_kind: AgentErrorKind,
        retriable: bool,
    },
    AgentFallbackTriggered {
        role: AgentRole,
        from_agent: String,
        to_agent: String,
    },
    AgentModelFallbackTriggered {
        role: AgentRole,
        agent: String,
        from_model: String,
        to_model: String,
    },
    AgentRetryCycleStarted {
        role: AgentRole,
        cycle: u32,
    },
    AgentChainExhausted {
        role: AgentRole,
    },
    AgentChainInitialized {
        role: AgentRole,
        agents: Vec<String>,
    },
    RebaseStarted {
        phase: RebasePhase,
        target_branch: String,
    },
    RebaseConflictDetected {
        files: Vec<PathBuf>,
    },
    RebaseConflictResolved {
        files: Vec<PathBuf>,
    },
    RebaseSucceeded {
        phase: RebasePhase,
        new_head: String,
    },
    RebaseFailed {
        phase: RebasePhase,
        reason: String,
    },
    RebaseAborted {
        phase: RebasePhase,
        restored_to: String,
    },
    RebaseSkipped {
        phase: RebasePhase,
        reason: String,
    },
    CommitGenerationStarted,
    CommitMessageGenerated {
        message: String,
        attempt: u32,
    },
    CommitMessageValidationFailed {
        reason: String,
        attempt: u32,
    },
    CommitCreated {
        hash: String,
        message: String,
    },
    CommitGenerationFailed {
        reason: String,
    },
    CommitSkipped {
        reason: String,
    },
    CheckpointSaved {
        trigger: CheckpointTrigger,
    },
    FinalizingStarted,
    PromptPermissionsRestored,
}

Pipeline events representing all state transitions.

Each event captures an observable transition in pipeline execution. The reducer handles these events to compute new state.

Variants

PipelineStarted

PipelineResumed

Fields

from_checkpoint: bool

PipelineCompleted

PipelineAborted

Fields

reason: String

PlanningPhaseStarted

PlanningPhaseCompleted

DevelopmentPhaseStarted

DevelopmentIterationStarted

Fields

iteration: u32

PlanGenerationStarted

Fields

iteration: u32

PlanGenerationCompleted

Fields

iteration: u32

valid: bool

DevelopmentIterationCompleted

Fields

iteration: u32

output_valid: bool

ContextCleaned

DevelopmentPhaseCompleted

ReviewPhaseStarted

ReviewPassStarted

Fields

pass: u32

ReviewCompleted

Fields

pass: u32

issues_found: bool

FixAttemptStarted

Fields

pass: u32

FixAttemptCompleted

Fields

pass: u32

changes_made: bool

ReviewPhaseCompleted

Fields

early_exit: bool

AgentInvocationStarted

Fields

role: AgentRole

agent: String

model: Option<String>

AgentInvocationSucceeded

Fields

role: AgentRole

agent: String

AgentInvocationFailed

Fields

role: AgentRole

agent: String

exit_code: i32

error_kind: AgentErrorKind

retriable: bool

AgentFallbackTriggered

Fields

role: AgentRole

from_agent: String

to_agent: String

AgentModelFallbackTriggered

Fields

role: AgentRole

agent: String

from_model: String

to_model: String

AgentRetryCycleStarted

Fields

role: AgentRole

cycle: u32

AgentChainExhausted

Fields

role: AgentRole

AgentChainInitialized

Fields

role: AgentRole

agents: Vec<String>

RebaseStarted

Fields

phase: RebasePhase

target_branch: String

RebaseConflictDetected

Fields

files: Vec<PathBuf>

RebaseConflictResolved

Fields

files: Vec<PathBuf>

RebaseSucceeded

Fields

phase: RebasePhase

new_head: String

RebaseFailed

Fields

phase: RebasePhase

reason: String

RebaseAborted

Fields

phase: RebasePhase

restored_to: String

RebaseSkipped

Fields

phase: RebasePhase

reason: String

CommitGenerationStarted

CommitMessageGenerated

Fields

message: String

attempt: u32

CommitMessageValidationFailed

Fields

reason: String

attempt: u32

CommitCreated

Fields

hash: String

message: String

CommitGenerationFailed

Fields

reason: String

CommitSkipped

Fields

reason: String

CheckpointSaved

Fields

trigger: CheckpointTrigger

FinalizingStarted

Finalization phase started.

PromptPermissionsRestored

PROMPT.md write permissions have been restored.

This event is emitted after the RestorePromptPermissions effect successfully restores write permissions on PROMPT.md.

Trait Implementations

impl Clone for PipelineEvent

fn clone(&self) -> PipelineEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PipelineEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for PipelineEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for PipelineEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.