Enum ockam_node::NodeMessage [−][src]
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>),
}
Expand description
Messages sent from the Node to the Executor
Variants
Start a new worker and store the send handle
Tuple Fields of StartWorker
Return a list of all worker addresses
Tuple Fields of ListWorkers
Stop an existing worker
Tuple Fields of StopWorker
0: Address
1: Sender<NodeReplyResult>
Start a new processor and store the send and shutdown handles
Tuple Fields of StartProcessor
Stop an existing processor
Tuple Fields of StopProcessor
0: Address
1: Sender<NodeReplyResult>
Stop the node (and all workers)
Request the sender for a worker address
Tuple Fields of SenderReq
0: Address
1: Sender<NodeReplyResult>
Register a new router for a route id type
Tuple Fields of Router
Check if a given address is already registered
Tuple Fields of CheckAddress
0: AddressSet
1: Sender<NodeReplyResult>
Implementations
pub fn start_worker(
address: AddressSet,
sender: Sender<RelayMessage>
) -> (Self, Receiver<NodeReplyResult>)
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>)
pub fn start_processor(
address: Address,
sender: Sender<RelayMessage>,
shutdown_handle: ShutdownHandle
) -> (Self, Receiver<NodeReplyResult>)
Create a start worker message
Create a stop worker message and reply receiver
Create a list worker message and reply receiver
Create a stop worker message and reply receiver
Create a sender request message and reply receiver
Create a message to check the availability of an address set