Struct C2ControlHandle 

pub struct C2ControlHandle { /* private fields */ }

Implementations

impl C2ControlHandle

pub fn hello(&self) -> &C2Hello

pub fn current_topology(&self) -> Arc<C2Topology>

pub fn subscribe_topology(&self) -> Receiver<Arc<C2Topology>>

pub fn terminal_frame_events_enabled(&self) -> bool

pub async fn request( &self, route: NodeRoute, request: NodeRequest, ) -> Result<RoutedNodeResponse, C2ControlError>

pub async fn request_with_correlation( &self, route: NodeRoute, request: NodeRequest, correlation_id: Option<String>, ) -> Result<RoutedNodeResponse, C2ControlError>

Like Self::request, attaching an opaque HQ correlation id to the operator-wire envelope (logged on core; echoed on the reply).

pub async fn browser_command( &self, cmd: BrowserClientCommand, ) -> Result<(), C2ControlError>

Validates and synchronously enqueues one typed request. The returned non-cloneable waiter cannot enqueue or replay the request again. Start / drive / stop a dig2browser session on a node (A2 restream sidecar).

pub fn start_request( &self, route: NodeRoute, request: NodeRequest, ) -> Result<C2PendingRequest, C2ControlError>

Trait Implementations

impl Clone for C2ControlHandle

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.