Struct Reaching 

pub struct Reaching { /* private fields */ }

One host, reached through a broker.

Implementations

impl Reaching

pub fn new(session: Arc<Session>, host: Host) -> Self

A host that will be connected to through this session when somebody needs it.

pub fn host(&self) -> &Host

The name this reaches.

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

Tells it what to provision the far side with, before the first job.

Staged if the wire is not open yet, handed straight over if it is — and either way the far side only receives it if it asks, because the wire announces an artifact’s name and sends the bytes on request.

Trait Implementations

impl Drop for Reaching

fn drop(&mut self)

Lets the rendezvous go, so that no client has to remember to.

Only one that was taken: a handle nobody sent work to never held anything. Nothing fails if this does not arrive, which is why the failure is swallowed — a run that finished is not a run to report an error from.

impl Transport for Reaching

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

The connection on the first call, and after that this is the wire’s dispatch with one Arc clone in front of it.