Enum ockam_node::NodeMessage

pub enum NodeMessage {
    StartWorker {
        addrs: Vec<Address>,
        senders: SenderPair,
        detached: bool,
        mailbox_count: Arc<AtomicUsize>,
        reply: SmallSender<NodeReplyResult>,
        addresses_metadata: Vec<AddressAndMetadata>,
    },
    ListWorkers(SmallSender<NodeReplyResult>),
    SetCluster(Address, String, SmallSender<NodeReplyResult>),
    StopWorker(Address, bool, SmallSender<NodeReplyResult>),
    StartProcessor {
        addrs: Vec<Address>,
        senders: SenderPair,
        reply: SmallSender<NodeReplyResult>,
        addresses_metadata: Vec<AddressAndMetadata>,
    },
    StopProcessor(Address, SmallSender<NodeReplyResult>),
    StopNode(ShutdownType, SmallSender<NodeReplyResult>),
    AbortNode,
    StopAck(Address),
    SenderReq(Address, SmallSender<NodeReplyResult>),
    Router(TransportType, Address, SmallSender<NodeReplyResult>),
    SetReady(Address),
    CheckReady(Address, SmallSender<NodeReplyResult>),
    FindTerminalAddress(Vec<Address>, SmallSender<NodeReplyResult>),
    GetMetadata(Address, SmallSender<NodeReplyResult>),
}

Messages sent from the Node to the Executor

Variants

StartWorker

Start a new worker and store the send handle

Fields

addrs: Vec<Address>

The set of addresses in use by this worker

senders: SenderPair

Pair of senders to the worker relay (msgs and ctrl)

detached: bool

A detached context/ “worker” runs no relay state

mailbox_count: Arc<AtomicUsize>

A mechanism to read channel fill-state for a worker

reply: SmallSender<NodeReplyResult>

Reply channel for command confirmation

addresses_metadata: Vec<AddressAndMetadata>

List of metadata for each address

ListWorkers(SmallSender<NodeReplyResult>)

Return a list of all worker addresses

SetCluster(Address, String, SmallSender<NodeReplyResult>)

Add an existing address to a cluster

StopWorker(Address, bool, SmallSender<NodeReplyResult>)

Stop an existing worker

StartProcessor

Start a new processor

Fields

addrs: Vec<Address>

The set of addresses in use by this processor

senders: SenderPair

Pair of senders to the worker relay (msgs and ctrl)

reply: SmallSender<NodeReplyResult>

Reply channel for command confirmation

addresses_metadata: Vec<AddressAndMetadata>

List of metadata for each address

StopProcessor(Address, SmallSender<NodeReplyResult>)

Stop an existing processor

StopNode(ShutdownType, SmallSender<NodeReplyResult>)

Stop the node (and all workers)

AbortNode

Immediately stop the node runtime

StopAck(Address)

Let the router know a particular address has stopped

SenderReq(Address, SmallSender<NodeReplyResult>)

Request the sender for a worker address

Router(TransportType, Address, SmallSender<NodeReplyResult>)

Register a new router for a route id type

SetReady(Address)

Message the router to set an address as “ready”

CheckReady(Address, SmallSender<NodeReplyResult>)

Check whether an address has been marked as “ready”

FindTerminalAddress(Vec<Address>, SmallSender<NodeReplyResult>)

Find the terminal address for a given route

GetMetadata(Address, SmallSender<NodeReplyResult>)

Get address metadata

Implementations

impl NodeMessage

pub fn start_worker( addrs: Vec<Address>, senders: SenderPair, detached: bool, mailbox_count: Arc<AtomicUsize>, metadata: Vec<AddressAndMetadata> ) -> (Self, SmallReceiver<NodeReplyResult>)

Create a start worker message

• senders: message and command senders for the relay

• detached: indicate whether this worker address has a full relay behind it that can respond to shutdown commands. Setting this to true will disable stop ACK support in the router

pub fn start_processor( addrs: Vec<Address>, senders: SenderPair, metadata: Vec<AddressAndMetadata> ) -> (Self, SmallReceiver<NodeReplyResult>)

Create a start worker message

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

Create a stop worker message and reply receiver

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

Create a list worker message and reply receiver

pub fn set_cluster( addr: Address, label: String ) -> (Self, SmallReceiver<NodeReplyResult>)

Create a set cluster message and reply receiver

pub fn stop_worker( address: Address, detached: bool ) -> (Self, SmallReceiver<NodeReplyResult>)

Create a stop worker message and reply receiver

pub fn stop_node(tt: ShutdownType) -> (Self, SmallReceiver<NodeReplyResult>)

Create a stop node message

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

Create a sender request message and reply receiver

pub fn set_ready(addr: Address) -> Self

Create a SetReady message and reply receiver

pub fn get_ready(addr: Address) -> (Self, SmallReceiver<NodeReplyResult>)

Create a GetReady message and reply receiver

pub fn find_terminal_address( addrs: Vec<Address> ) -> (Self, SmallReceiver<NodeReplyResult>)

Creates a NodeMessage::FindTerminalAddress message and reply receiver

pub fn read_metadata(address: Address) -> (Self, SmallReceiver<NodeReplyResult>)

Creates a [NodeMessage::ReadMetadata] message and reply receiver

Trait Implementations

impl Debug for NodeMessage

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

Formats the value using the given formatter.

impl Display for NodeMessage

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

Formats the value using the given formatter.