Struct ParallelExecutor 

pub struct ParallelExecutor { /* private fields */ }

Parallel executor for running commands across multiple nodes.

Implementations

impl ParallelExecutor

pub fn new( nodes: Vec<Node>, max_parallel: usize, key_path: Option<String>, ) -> Self

Create a new parallel executor with default strict mode.

pub fn new_with_strict_mode( nodes: Vec<Node>, max_parallel: usize, key_path: Option<String>, strict_mode: StrictHostKeyChecking, ) -> Self

Create a new parallel executor with specified strict mode.

pub fn new_with_strict_mode_and_agent( nodes: Vec<Node>, max_parallel: usize, key_path: Option<String>, strict_mode: StrictHostKeyChecking, use_agent: bool, ) -> Self

Create a new parallel executor with strict mode and agent support.

pub fn new_with_all_options( nodes: Vec<Node>, max_parallel: usize, key_path: Option<String>, strict_mode: StrictHostKeyChecking, use_agent: bool, use_password: bool, ) -> Self

Create a new parallel executor with all authentication options.

pub fn with_timeout(self, timeout: Option<u64>) -> Self

Set command execution timeout.

pub fn with_connect_timeout(self, connect_timeout: Option<u64>) -> Self

Set SSH connection timeout.

pub fn with_jump_hosts(self, jump_hosts: Option<String>) -> Self

Set jump hosts for connections.

pub fn with_ssh_config(self, ssh_config: Option<SshConfig>) -> Self

Set SSH config for ProxyJump directive resolution.

pub fn with_sudo_password( self, sudo_password: Option<Arc<SudoPassword>>, ) -> Self

Set sudo password for automatic sudo authentication.

When set, the executor will automatically detect sudo password prompts and inject the password when commands require sudo privileges.

pub fn with_batch_mode(self, batch: bool) -> Self

Set batch mode for signal handling.

When set to true, a single Ctrl+C will immediately terminate all jobs. When false (default), first Ctrl+C shows status, second terminates.

pub fn with_fail_fast(self, fail_fast: bool) -> Self

Enable fail-fast mode (pdsh -k compatibility).

When enabled, execution stops immediately when any node fails:

• Connection failure to any host
• Non-zero exit code from any command

Pending commands are cancelled and running commands are terminated gracefully.

pub async fn execute(&self, command: &str) -> Result<Vec<ExecutionResult>>

Execute a command on all nodes in parallel.

pub async fn upload_file( &self, local_path: &Path, remote_path: &str, ) -> Result<Vec<UploadResult>>

Upload a file to all nodes in parallel.

pub async fn download_file( &self, remote_path: &str, local_dir: &Path, ) -> Result<Vec<DownloadResult>>

Download a file from all nodes in parallel.

pub async fn download_files( &self, remote_paths: Vec<String>, local_dir: &Path, ) -> Result<Vec<DownloadResult>>

Download multiple files from all nodes.

pub async fn execute_with_streaming( &self, command: &str, output_mode: OutputMode, ) -> Result<Vec<ExecutionResult>>

Execute a command with streaming output support

This method enables real-time output streaming from all nodes with configurable output modes:

• Normal: Traditional batch mode (same as execute())
• Stream: Real-time with [node] prefixes
• File: Save per-node output to files

Arguments

• command - The command to execute
• output_mode - How to handle output (Normal/Stream/File)

Returns

Vector of execution results, one per node