Struct RemoteCluster 

pub struct RemoteCluster {
    pub slots: Vec<RemoteSlot>,
    pub job_timeout_ms: u64,
    pub max_attempts: u32,
    pub connect_timeout_ms: u64,
}

SSH worker pool for pmap_on. The dispatcher spawns one persistent ssh process per slot, performs HELLO + SESSION_INIT once, then streams JOB frames over the same stdin/stdout.

Tunables:

• job_timeout_ms — per-job wall-clock budget. A slot that exceeds this is killed and the job is re-enqueued (counted against the retry budget).
• max_attempts — total attempts (initial + retries) per job before it is failed.
• connect_timeout_ms — ssh -o ConnectTimeout=N-equivalent for the initial handshake.

Fields

slots: Vec<RemoteSlot>

job_timeout_ms: u64

max_attempts: u32

connect_timeout_ms: u64

Implementations

impl RemoteCluster

pub const DEFAULT_JOB_TIMEOUT_MS: u64 = 60_000

pub const DEFAULT_MAX_ATTEMPTS: u32 = 3

pub const DEFAULT_CONNECT_TIMEOUT_MS: u64 = 10_000

pub fn from_list_args(items: &[PerlValue]) -> Result<Self, String>

Parse a list of cluster spec values into a RemoteCluster. Accepted forms (any may appear in the same call):

• "host" — 1 slot, default stryke path
• "host:N" — N slots
• "host:N:/path/to/stryke" — N slots, custom remote stryke
• "user@host:N" — ssh user override (kept verbatim in host)
• hashref { host => "h", slots => N, stryke => "/usr/local/bin/stryke" }
• trailing hashref { timeout => 30, retries => 2, connect_timeout => 5 } — global tunables that apply to the whole cluster (must be the last argument; consumed only when its keys are all known tunable names so it cannot be confused with a slot)

Backwards compatible with the basic v1 "host:N" syntax.

Trait Implementations

impl Clone for RemoteCluster

fn clone(&self) -> RemoteCluster

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RemoteCluster

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.