Struct MergeQueue 

pub struct MergeQueue { /* private fields */ }

Merge queue for tracking parallel loop merges.

The queue maintains an append-only JSONL log of merge events. State is derived by replaying events for each loop.

Implementations

impl MergeQueue

pub const QUEUE_FILE: &'static str = ".ralph/merge-queue.jsonl"

The relative path to the merge queue file within the workspace.

pub fn new(workspace_root: impl AsRef<Path>) -> Self

Creates a new merge queue instance for the given workspace.

pub fn enqueue( &self, loop_id: &str, prompt: &str, ) -> Result<(), MergeQueueError>

Enqueues a completed loop for merging.

Arguments

• loop_id - The loop identifier
• prompt - The prompt that was executed

pub fn mark_merging( &self, loop_id: &str, pid: u32, ) -> Result<(), MergeQueueError>

Marks a loop as being merged.

Arguments

• loop_id - The loop identifier
• pid - PID of the merge-ralph process

pub fn mark_merged( &self, loop_id: &str, commit: &str, ) -> Result<(), MergeQueueError>

Marks a loop as successfully merged.

Arguments

• loop_id - The loop identifier
• commit - The merge commit SHA

pub fn mark_needs_review( &self, loop_id: &str, reason: &str, ) -> Result<(), MergeQueueError>

Marks a loop as needing manual review.

Arguments

• loop_id - The loop identifier
• reason - Reason for the failure

pub fn discard( &self, loop_id: &str, reason: Option<&str>, ) -> Result<(), MergeQueueError>

Marks a loop as discarded.

Arguments

• loop_id - The loop identifier
• reason - Optional reason for discarding

pub fn next_pending(&self) -> Result<Option<MergeEntry>, MergeQueueError>

Gets the next pending loop ready for merge (FIFO order).

Returns the oldest loop in Queued state.

pub fn get_entry( &self, loop_id: &str, ) -> Result<Option<MergeEntry>, MergeQueueError>

Gets the entry for a specific loop.

pub fn list(&self) -> Result<Vec<MergeEntry>, MergeQueueError>

Lists all entries in the merge queue.

Returns entries in chronological order (oldest first).

pub fn list_by_state( &self, state: MergeState, ) -> Result<Vec<MergeEntry>, MergeQueueError>

Lists entries filtered by state.