Struct WorktreePool 

pub struct WorktreePool { /* private fields */ }

Worktree execution pool

Implementations

impl WorktreePool

pub fn new(config: PoolConfig, worktree_base: Option<PathBuf>) -> Result<Self>

Create a new worktree pool with automatic repository discovery

Arguments

• config - Pool configuration
• worktree_base - Optional override for worktree base directory

pub fn new_with_path( repo_path: impl AsRef<Path>, worktree_base: impl AsRef<Path>, config: PoolConfig, ) -> Result<Self>

Create a worktree pool with explicit repository path

pub async fn execute_parallel<F, Fut>( &self, tasks: Vec<WorktreeTask>, executor: F, ) -> PoolExecutionResult

where F: Fn(WorktreeInfo, WorktreeTask) -> Fut + Send + Sync + Clone + 'static, Fut: Future<Output = Result<Value>> + Send + 'static,

Execute multiple tasks in parallel worktrees

Arguments

• tasks - Vector of tasks to execute
• executor - Async function to execute in each worktree

Returns

Pool execution result with individual task results

Fail-Fast Behavior

If fail_fast is enabled in config, execution stops after the first failure and all remaining tasks are cancelled.

pub async fn execute_simple<F, Fut>( &self, issue_numbers: Vec<u64>, executor: F, ) -> PoolExecutionResult

where F: Fn(PathBuf, u64) -> Fut + Send + Sync + Clone + 'static, Fut: Future<Output = Result<()>> + Send + 'static,

Execute tasks with automatic worktree lifecycle management

This is a simplified version that automatically creates, executes, and cleans up worktrees

pub async fn stats(&self) -> PoolStats

Get current pool statistics

pub fn manager(&self) -> &Arc<WorktreeManager>

Get reference to underlying manager