Struct SshWorker 

pub struct SshWorker { /* private fields */ }

Worker that executes commands on remote nodes via SSH.

SshWorker is a thin wrapper around ExecWorker that builds SSH commands using configurable SshOptions. It mirrors ClusterShell’s WorkerSsh class.

Implementations

impl SshWorker

pub fn new( nodes: Vec<String>, command: String, fanout: usize, timeout: Option<Duration>, ssh_options: SshOptions, ) -> Self

Create a new SshWorker.

Arguments

• nodes - List of remote node names to execute on.
• command - Command to run on each remote node.
• fanout - Max concurrent SSH connections.
• timeout - Optional per-node timeout.
• ssh_options - SSH connection options.

pub fn with_defaults( nodes: Vec<String>, command: String, fanout: usize, timeout: Option<Duration>, ) -> Self

Create a new SshWorker with default SSH options.

pub fn with_stderr(self, stderr: bool) -> Self

Enable stderr capture.

pub fn ssh_options(&self) -> &SshOptions

Get the SSH options.

pub fn original_command(&self) -> &str

Get the original (unwrapped) command.

Trait Implementations

impl Worker for SshWorker

fn start(&mut self) -> Result<()>

Start the worker.

fn abort(&mut self, kill: bool)

Abort the worker, optionally killing child processes.

fn state(&self) -> WorkerState

Get the worker’s current state.

fn set_handler(&mut self, handler: Box<dyn EventHandler>)

Set the event handler for this worker.

fn read_fds(&self) -> Vec<RawFd>

Get file descriptors for read interest.

fn write_fds(&self) -> Vec<RawFd>

Get file descriptors for write interest.

fn handle_read(&mut self, fd: RawFd) -> Result<()>

Handle a read event on the given file descriptor.

fn handle_write(&mut self, fd: RawFd) -> Result<()>

Handle a write event on the given file descriptor.

fn is_done(&self) -> bool

Check if the worker has completed.

fn retcodes(&self) -> &HashMap<String, i32>

Get the return codes map: node -> return_code.

fn num_nodes(&self) -> usize

Get the number of nodes.

fn take_handler(&mut self) -> Option<Box<dyn EventHandler>>

Take the event handler out of the worker (used by Task to extract gathered data).