Struct OperatorLink 

pub struct OperatorLink { /* private fields */ }

Operator control routed through core (A2): core sends g4a requests down a node’s control stream and correlates replies. C2 relays the bytes without parsing them.

Wire (inner plaintext): {"op_id": u64, "g4a": <frame>} both ways. Messages without op_id are node-initiated events and go to the events channel.

Implementations

impl OperatorLink

pub fn new( events: Option<UnboundedSender<G4aMessage>>, ) -> (Self, Receiver<Vec<u8>>)

Returns the link and the outbound queue to hand to DrainConsumer::with_outbound.

pub async fn request<T: Serialize>( &self, frame: &T, timeout: Duration, ) -> Result<G4aMessage, OperatorError>

Send one g4a request (e.g. a RoutedNodeRequest) and wait for its reply.

pub fn handler(self) -> CoreHandler

Drain handler for the node’s g4a control channel: parses g4a on core only.

Trait Implementations

impl Clone for OperatorLink

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.