Struct ScpWorker 

pub struct ScpWorker { /* private fields */ }

Worker that copies files to/from remote nodes via SCP.

Mirrors ClusterShell’s ScpClient / WorkerSsh copy mode.

Implementations

impl ScpWorker

pub fn new( nodes: Vec<String>, source: String, dest: String, fanout: usize, timeout: Option<Duration>, ssh_options: SshOptions, reverse: bool, preserve: bool, directory: bool, ) -> Self

Create a new ScpWorker for file copy.

Arguments

• nodes - Remote nodes to copy to/from.
• source - Source file/directory path.
• dest - Destination file/directory path.
• fanout - Max concurrent SCP operations.
• timeout - Optional per-node timeout.
• ssh_options - SSH/SCP options.
• reverse - If true, copy from remote to local.
• preserve - If true, preserve file attributes.
• directory - If true, copy recursively.

pub fn source(&self) -> &str

Get the source path.

pub fn dest(&self) -> &str

Get the destination path.

pub fn is_reverse(&self) -> bool

Whether this is a reverse copy.

Trait Implementations

impl Worker for ScpWorker

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