Struct ExecWorker 

pub struct ExecWorker { /* private fields */ }

Worker implementation that runs commands on nodes via local execution.

ExecWorker spawns child processes to execute commands on nodes. It supports fanout control (limiting concurrent processes) and node name substitution in commands (%h or {node}).

Implementations

impl ExecWorker

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

Create a new ExecWorker.

Arguments

• nodes - List of node names to execute the command on.
• command - Command to execute. Use %h or {node} as placeholders for the node name.
• fanout - Maximum number of concurrent processes (default: 64).
• timeout - Optional timeout per node.

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

Create a new ExecWorker with stderr enabled.

Trait Implementations

impl Worker for ExecWorker

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).