Struct ControlConnection 

pub struct ControlConnection { /* private fields */ }

Shared discovery result and operation adapter. Standalone JSON connections rediscover before fresh exchanges unless a verified runtime owner is supplied.

Implementations

impl ControlConnection

pub async fn connect(path: impl AsRef<Path>) -> ControlClientResult<Self>

Discover support at an existing native endpoint. Path identity alone is not sufficient to reuse JSON format evidence across process replacement.

pub async fn connect_with( path: impl AsRef<Path>, configure: impl FnOnce(ConnectOptions) -> ConnectOptions, ) -> ControlClientResult<Self>

Configure one total deadline covering discovery, redial, and handshake.

pub async fn connect_connector( connector: Arc<dyn Connector>, ) -> ControlClientResult<Self>

Discover using a repeatable, owned connector without claimed OS identity.

pub async fn connect_connector_with( connector: Arc<dyn Connector>, configure: impl FnOnce(ConnectOptions) -> ConnectOptions, ) -> ControlClientResult<Self>

Configure discovery over caller-provided independent transports.

pub async fn connect_verified_connector( connector: Arc<dyn VerifiedControlConnector>, ) -> ControlClientResult<Self>

Reuse JSON discovery while an external runtime owner verifies every peer and rechecks its active run and process birth before each operation.

pub async fn connect_verified_connector_with( connector: Arc<dyn VerifiedControlConnector>, configure: impl FnOnce(ConnectOptions) -> ConnectOptions, ) -> ControlClientResult<Self>

Configure setup for an identity-verifying backend connector.

pub fn mode(&self) -> ControlMode

Format selected by this setup. A later detected format change invalidates the JSON handle before sending; callers explicitly establish a new one.

pub fn capabilities(&self) -> &Capabilities

Capability snapshot validated during discovery. Reading it performs no I/O; use GetCapabilities to explicitly request a fresh observation.

pub fn is_closed(&self) -> bool

Inspect shared closure without dialing or rediscovery.

pub async fn closed(&self)

Wait for the selected connection to close without dialing or polling.

pub fn framed(&self) -> ControlClientResult<&ControlClient>

Obtain the complete generic framed surface. JSON fails locally, without opening an endpoint or manufacturing an equivalent frame.

pub async fn close(&self)

Close all shared handles. Subsequent requests cannot silently reconnect.

pub async fn request( &self, message: impl IntoControlMessage, ) -> ControlClientResult<ControlReply>

Send a named request and retain its actual reply representation.

pub async fn request_with( &self, message: impl IntoControlMessage, configure: impl FnOnce(RequestOptions) -> RequestOptions, ) -> ControlClientResult<ControlReply>

Configure one attempt, including any identity recheck or JSON rediscovery.

pub async fn request_typed<R: CheckedControlRequest>( &self, request: &R, ) -> ControlClientResult<R::Response>

Normalize a checked request using the selected format’s real decoder.

pub async fn request_typed_with<R: CheckedControlRequest>( &self, request: &R, configure: impl FnOnce(RequestOptions) -> RequestOptions, ) -> ControlClientResult<R::Response>

Configure one checked operation’s local wait.

Trait Implementations

impl Clone for ControlConnection

fn clone(&self) -> ControlConnection

Returns a duplicate of the value.

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

Performs copy-assignment from source.