Enum ockam_node::NodeMessage

pub enum NodeMessage {
    StartWorker(AddressSet, Sender<RelayMessage>, Sender<NodeReplyResult>),
    ListWorkers(Sender<NodeReplyResult>),
    StopWorker(Address, Sender<NodeReplyResult>),
    StopNode,
    SenderReq(Address, Sender<NodeReplyResult>),
    Router(u8, Address, Sender<NodeReplyResult>),
    CheckAddress(AddressSet, Sender<NodeReplyResult>),
}

Messages sent from the Node to the Executor

Variants

StartWorker(AddressSet, Sender<RelayMessage>, Sender<NodeReplyResult>)

Start a new worker and store the send handle

ListWorkers(Sender<NodeReplyResult>)

Return a list of all worker addresses

StopWorker(Address, Sender<NodeReplyResult>)

Stop an existing worker

StopNode

Stop the node (and all workers)

SenderReq(Address, Sender<NodeReplyResult>)

Request the sender for a worker address

Router(u8, Address, Sender<NodeReplyResult>)

Register a new router for a route id type

CheckAddress(AddressSet, Sender<NodeReplyResult>)

Check if a given address is already registered

Implementations

impl NodeMessage

pub fn start_worker(
    address: AddressSet,
    sender: Sender<RelayMessage>
) -> (Self, Receiver<NodeReplyResult>)

Create a start worker message

pub fn list_workers() -> (Self, Receiver<NodeReplyResult>)

Create a list worker message and reply receiver

pub fn stop_worker(address: Address) -> (Self, Receiver<NodeReplyResult>)

Create a stop worker message and reply receiver

pub fn stop_node() -> Self

Create a stop node message

pub fn sender_request(route: Address) -> (Self, Receiver<NodeReplyResult>)

Create a sender request message and reply receiver

pub fn check_address(addrs: AddressSet) -> (Self, Receiver<NodeReplyResult>)

Create a message to check the availability of an address set

Trait Implementations

impl Debug for NodeMessage

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

Formats the value using the given formatter.