Enum ockam::NodeMessage

pub enum NodeMessage {
    StartWorker(AddressSet, Sender<RelayMessage>, Sender<Result<NodeReply, NodeError>>),
    ListWorkers(Sender<Result<NodeReply, NodeError>>),
    StopWorker(Address, Sender<Result<NodeReply, NodeError>>),
    StartProcessor(Address, Sender<RelayMessage>, Sender<Result<NodeReply, NodeError>>, ShutdownHandle),
    StopProcessor(Address, Sender<Result<NodeReply, NodeError>>),
    StopNode,
    SenderReq(Address, Sender<Result<NodeReply, NodeError>>),
    Router(u8, Address, Sender<Result<NodeReply, NodeError>>),
    CheckAddress(AddressSet, Sender<Result<NodeReply, NodeError>>),
}

Messages sent from the Node to the Executor

Variants

StartWorker(AddressSet, Sender<RelayMessage>, Sender<Result<NodeReply, NodeError>>)

Start a new worker and store the send handle

Tuple Fields of StartWorker

0: AddressSet1: Sender<RelayMessage>2: Sender<Result<NodeReply, NodeError>>

ListWorkers(Sender<Result<NodeReply, NodeError>>)

Return a list of all worker addresses

Tuple Fields of ListWorkers

0: Sender<Result<NodeReply, NodeError>>

StopWorker(Address, Sender<Result<NodeReply, NodeError>>)

Stop an existing worker

Tuple Fields of StopWorker

0: Address1: Sender<Result<NodeReply, NodeError>>

StartProcessor(Address, Sender<RelayMessage>, Sender<Result<NodeReply, NodeError>>, ShutdownHandle)

Start a new processor and store the send and shutdown handles

Tuple Fields of StartProcessor

0: Address1: Sender<RelayMessage>2: Sender<Result<NodeReply, NodeError>>3: ShutdownHandle

StopProcessor(Address, Sender<Result<NodeReply, NodeError>>)

Stop an existing processor

Tuple Fields of StopProcessor

0: Address1: Sender<Result<NodeReply, NodeError>>

StopNode

Stop the node (and all workers)

SenderReq(Address, Sender<Result<NodeReply, NodeError>>)

Request the sender for a worker address

Tuple Fields of SenderReq

0: Address1: Sender<Result<NodeReply, NodeError>>

Router(u8, Address, Sender<Result<NodeReply, NodeError>>)

Register a new router for a route id type

Tuple Fields of Router

0: u81: Address2: Sender<Result<NodeReply, NodeError>>

CheckAddress(AddressSet, Sender<Result<NodeReply, NodeError>>)

Check if a given address is already registered

Tuple Fields of CheckAddress

0: AddressSet1: Sender<Result<NodeReply, NodeError>>

Implementations

impl NodeMessage

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

Create a start worker message

pub fn start_processor(
    address: Address,
    sender: Sender<RelayMessage>,
    shutdown_handle: ShutdownHandle
) -> (NodeMessage, Receiver<Result<NodeReply, NodeError>>)

Create a start worker message

pub fn stop_processor(
    address: Address
) -> (NodeMessage, Receiver<Result<NodeReply, NodeError>>)

Create a stop worker message and reply receiver

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

Create a list worker message and reply receiver

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

Create a stop worker message and reply receiver

pub fn stop_node() -> NodeMessage

Create a stop node message

pub fn sender_request(
    route: Address
) -> (NodeMessage, Receiver<Result<NodeReply, NodeError>>)

Create a sender request message and reply receiver

pub fn check_address(
    addrs: AddressSet
) -> (NodeMessage, Receiver<Result<NodeReply, NodeError>>)

Create a message to check the availability of an address set

Trait Implementations

impl Debug for NodeMessage

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

Formats the value using the given formatter.