Enum Request 

pub enum Request {
    Hello {
        runtime: String,
        offering: Option<Label>,
    },
    Provision {
        bytes: Vec<u8>,
    },
    Work {
        plan: Plan,
        input: Value,
        known: Vec<(NodeId, Value)>,
        keys: Vec<(NodeId, Keys)>,
        placement: Placement,
        memory: Memory,
    },
}

What the client says.

The allow is deliberate: Work is far bigger than Hello, and boxing it would buy an allocation on every message to save a few hundred bytes of stack on one that is about to be serialized anyway — and Hello is sent once per session while Work is the whole conversation.

Variants

Hello

Opens the session: who I am and what I would provision you with.

Fields

runtime: String

How the client identifies itself, so the worker can say no. Opaque here; the Provision reads it.

offering: Option<Label>

The name of the artifact I bring, if I bring one. None means “you already have your catalog”, and neither kind can pretend to be the other.

Provision

Here is the artifact, since you asked for it.

Fields

bytes: Vec<u8>

The bytes. Nobody here looks at them.

Work

Execute this.

Fields

plan: Plan

What gets executed.

input: Value

The graph’s input.

known: Vec<(NodeId, Value)>

What was produced on the client that this plan reads and does not produce.

keys: Vec<(NodeId, Keys)>

What each of those is called, so what runs here can name what it produces and the chain of keys does not stop at the wire.

placement: Placement

Where each node of this slice runs.

memory: Memory

What is remembered about the nodes of this slice: what implements each, which are settled, which are worth keeping.

Implementations

impl Request

pub fn to_bytes(&self) -> Result<Vec<u8>, MessageError>

This message in bytes. Fails if some value cannot leave this process.

pub fn from_bytes(bytes: &[u8]) -> Result<Self, MessageError>

And back from them.

Trait Implementations

impl Clone for Request

fn clone(&self) -> Request

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Request

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

Formats the value using the given formatter.

impl PartialEq for Request

fn eq(&self, other: &Request) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for Request