Trait Worker 

pub trait Worker: Send {
    // Required methods
    fn start(&mut self) -> Result<()>;
    fn abort(&mut self, kill: bool);
    fn state(&self) -> WorkerState;
    fn set_handler(&mut self, handler: Box<dyn EventHandler>);
    fn read_fds(&self) -> Vec<RawFd> ;
    fn write_fds(&self) -> Vec<RawFd> ;
    fn handle_read(&mut self, fd: RawFd) -> Result<()>;
    fn handle_write(&mut self, fd: RawFd) -> Result<()>;
    fn is_done(&self) -> bool;
    fn retcodes(&self) -> &HashMap<String, i32>;
    fn num_nodes(&self) -> usize;
    fn take_handler(&mut self) -> Option<Box<dyn EventHandler>>;
}

Trait for worker implementations.

A worker executes commands across multiple nodes, handling I/O events and managing child processes.

Required Methods

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

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl Worker for ExecWorker

impl Worker for ScpWorker

impl Worker for SshWorker