Enum ockam::NodeReply

pub enum NodeReply {
    Ok,
    Workers(Vec<Address, Global>),
    Sender {
        addr: Address,
        sender: Sender<RelayMessage>,
        wrap: bool,
    },
}

Successful return values from a router command

Variants

Ok

Success with no payload

Workers(Vec<Address, Global>)

A list of worker addresses

Tuple Fields of Workers

0: Vec<Address, Global>

Sender

Message sender to a specific worker

Fields of Sender

addr: Address

The address a message is being sent to

sender: Sender<RelayMessage>

The relay sender

wrap: bool

Indicate whether the relay message needs to be constructed with router wrapping.

Implementations

impl NodeReply

pub fn ok() -> Result<NodeReply, NodeError>

Return NodeReply::Ok

pub fn no_such_worker(a: Address) -> Result<NodeReply, NodeError>

Return NodeError::NoSuchWorker

pub fn no_such_processor(a: Address) -> Result<NodeReply, NodeError>

Return NodeError::NoSuchProcessor

pub fn worker_exists(a: Address) -> Result<NodeReply, NodeError>

Return NodeError::WorkerExists for the given address

pub fn router_exists() -> Result<NodeReply, NodeError>

Return NodeError::RouterExists

pub fn rejected(reason: Reason) -> Result<NodeReply, NodeError>

Return [NodeReply::Rejected(reason)]

pub fn workers(v: Vec<Address, Global>) -> Result<NodeReply, NodeError>

Return NodeReply::Workers for the given addresses

pub fn sender(
    addr: Address,
    sender: Sender<RelayMessage>,
    wrap: bool
) -> Result<NodeReply, NodeError>

Return NodeReply::Sender for the given information

pub fn take_sender(self) -> Result<(Address, Sender<RelayMessage>, bool), Error>

Consume the wrapper and return NodeReply::Sender

pub fn take_workers(self) -> Result<Vec<Address, Global>, Error>

Consume the wrapper and return NodeReply::Workers

pub fn is_ok(self) -> Result<(), Error>

Returns Ok if self is NodeReply::Ok

Trait Implementations

impl Debug for NodeReply

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

Formats the value using the given formatter.