Struct Worker 

pub struct Worker { /* private fields */ }

A process that executes the slices it is sent.

Implementations

impl Worker

pub fn spawn(command: Command) -> Result<Self>

Starts the process and keeps its pipes. The worker there has to bring its own catalog; for an empty one, see Worker::carrying.

stderr is left inherited: its stdout is the wire.

pub fn connect(addr: impl ToSocketAddrs) -> Result<Self>

Connects to a worker that was already running — the form that satisfies the use case. On the other side there is Serving::listen.

pub fn carrying(self, artifact: Artifact, runtime: impl Into<String>) -> Self

The same worker, carrying what to provision it with if it started empty. runtime — cpython-3.13/cloudpickle-3.1 — is what the far side’s Provision can reject at greeting time.

pub fn offering( &self, artifact: Artifact, runtime: impl Into<String>, ) -> Result<(), TransportError>

The same on an already-built worker, for whoever decides at run time which nodes go to this host. Setting the same artifact twice does nothing; changing an open session’s fails.

pub fn packing(self, codec: Arc<dyn Codec>) -> Self

The same worker, with somebody who knows how to write down what an opaque carries.

Without one, a value that only exists in this process is refused at encoding time. With one, it crosses as bytes and the refusal is left for what nobody registered a codec for.

Trait Implementations

impl Drop for Worker

fn drop(&mut self)

Ends the conversation: a child gets its input closed and is waited for; a standing worker just loses the socket and awaits another client.

impl Transport for Worker

fn dispatch( &self, plan: &Plan, cargo: &Cargo<'_>, seen: Option<&dyn Watcher>, ) -> Result<Outcome, TransportError>

Executes plan over there, with what it needs in order to do so, and tells seen whatever the far side says while it is at it.