Enum ockam_node::NodeMessage

pub enum NodeMessage {
    StartWorker(AddressSet, Sender<RelayMessage>, Sender<NodeReplyResult>),
    ListWorkers(Sender<NodeReplyResult>),
    StopWorker(Address, Sender<NodeReplyResult>),
    StartProcessor(Address, Sender<RelayMessage>, Sender<NodeReplyResult>, ShutdownHandle),
    StopProcessor(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

Tuple Fields of StartWorker

0: AddressSet1: Sender<RelayMessage>2: Sender<NodeReplyResult>

ListWorkers(Sender<NodeReplyResult>)

Return a list of all worker addresses

Tuple Fields of ListWorkers

0: Sender<NodeReplyResult>

StopWorker(Address, Sender<NodeReplyResult>)

Stop an existing worker

Tuple Fields of StopWorker

0: Address1: Sender<NodeReplyResult>

StartProcessor(Address, Sender<RelayMessage>, Sender<NodeReplyResult>, ShutdownHandle)

Start a new processor and store the send and shutdown handles

Tuple Fields of StartProcessor

0: Address1: Sender<RelayMessage>2: Sender<NodeReplyResult>3: ShutdownHandle

StopProcessor(Address, Sender<NodeReplyResult>)

Stop an existing processor

Tuple Fields of StopProcessor

0: Address1: Sender<NodeReplyResult>

StopNode

Stop the node (and all workers)

SenderReq(Address, Sender<NodeReplyResult>)

Request the sender for a worker address

Tuple Fields of SenderReq

0: Address1: Sender<NodeReplyResult>

Router(u8, Address, Sender<NodeReplyResult>)

Register a new router for a route id type

Tuple Fields of Router

0: u81: Address2: Sender<NodeReplyResult>

CheckAddress(AddressSet, Sender<NodeReplyResult>)

Check if a given address is already registered

Tuple Fields of CheckAddress

0: AddressSet1: Sender<NodeReplyResult>

Implementations

impl NodeMessage

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

Create a start worker message

pub fn start_processor(
    address: Address,
    sender: Sender<RelayMessage>,
    shutdown_handle: ShutdownHandle
) -> (Self, Receiver<NodeReplyResult>)

Create a start worker message

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

Create a stop worker message and reply receiver

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.