Struct TreeWorkerResponder 

pub struct TreeWorkerResponder { /* private fields */ }

Gateway-side responder for a tree worker.

Mirrors Gateway.TreeWorkerResponder: it relays routing events from the worker running on the gateway to the admin node through the gateway channel.

Implementations

impl TreeWorkerResponder

pub fn new(srcwkr: u64) -> Self

Create a responder for the given source worker id.

pub fn srcwkr(&self) -> u64

Get the source worker id.

pub fn routing_message(&self, arg: &RoutingEvent) -> Message

Build the routing message to send on the gateway channel.

Corrected construction (upstream 490323d): srcid is always the responder’s own worker id; the event only carries event/gateway/targets.

pub fn ev_routing(&self, chan: &mut Channel, arg: &RoutingEvent)

Relay a routing event onto the gateway channel (mirrors _ev_routing sending the RoutingMessage on gwchan).

Trait Implementations

impl Debug for TreeWorkerResponder

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

Formats the value using the given formatter.