Enum ockam::NodeMessage

pub enum NodeMessage {
    StartWorker(AddressSet, Sender<RelayMessage>),
    ListWorkers(Sender<NodeReply>),
    StopWorker(Address, Sender<NodeReply>),
    StopNode,
    SenderReq(Address, Sender<NodeReply>),
}

Messages sent from the Node to the Executor

Variants

StartWorker(AddressSet, Sender<RelayMessage>)

Start a new worker and store the send handle

ListWorkers(Sender<NodeReply>)

Return a list of all worker addresses

StopWorker(Address, Sender<NodeReply>)

Stop an existing worker

StopNode

Stop the node (and all workers)

SenderReq(Address, Sender<NodeReply>)

Request the sender for an existing worker

Implementations

impl NodeMessage

pub fn start_worker(
    address: AddressSet,
    sender: Sender<RelayMessage>
) -> NodeMessage

Create a start worker message

pub fn list_workers() -> (NodeMessage, Receiver<NodeReply>)

Create a list worker message and reply receiver

pub fn stop_worker(address: Address) -> (NodeMessage, Receiver<NodeReply>)

Create a stop worker message and reply receiver

pub fn stop_node() -> NodeMessage

Create a stop node message

pub fn sender_request(address: Address) -> (NodeMessage, Receiver<NodeReply>)

Create a sender request message and reply receiver

Trait Implementations

impl Debug for NodeMessage

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

Formats the value using the given formatter.