pub struct JsonControlClient { /* private fields */ }Expand description
Explicit JSON adapter. Construction is inert; every call opens one stream.
Implementations§
Source§impl JsonControlClient
impl JsonControlClient
Sourcepub fn new(path: impl AsRef<Path>) -> Self
pub fn new(path: impl AsRef<Path>) -> Self
Select legacy JSON explicitly, without probing or opening a connection.
Sourcepub fn from_connector(connector: Arc<dyn Connector>) -> Self
pub fn from_connector(connector: Arc<dyn Connector>) -> Self
Store a repeatable dialer without I/O or hidden negotiation.
Sourcepub fn from_connector_with(
connector: Arc<dyn Connector>,
configure: impl FnOnce(ConnectOptions) -> ConnectOptions,
) -> ControlClientResult<Self>
pub fn from_connector_with( connector: Arc<dyn Connector>, configure: impl FnOnce(ConnectOptions) -> ConnectOptions, ) -> ControlClientResult<Self>
Configure local deadlines without performing I/O.
Sourcepub async fn closed(&self)
pub async fn closed(&self)
Wait for shared closure. Successful per-operation JSON EOF is not a session closure; explicit close or an unexpected exchange failure is.
Sourcepub async fn close(&self)
pub async fn close(&self)
Close every clone and wake each outstanding exchange with its own admission certainty. No implicit reconnect follows an explicit close.
Sourcepub async fn request(
&self,
message: impl IntoControlMessage,
) -> ControlClientResult<JsonReply>
pub async fn request( &self, message: impl IntoControlMessage, ) -> ControlClientResult<JsonReply>
Translate a known native request, returning its actual JSON reply.
Sourcepub async fn request_with(
&self,
message: impl IntoControlMessage,
configure: impl FnOnce(RequestOptions) -> RequestOptions,
) -> ControlClientResult<JsonReply>
pub async fn request_with( &self, message: impl IntoControlMessage, configure: impl FnOnce(RequestOptions) -> RequestOptions, ) -> ControlClientResult<JsonReply>
Configure one total attempt deadline, including dial and any discovery.
Sourcepub async fn request_typed<R: CheckedControlRequest>(
&self,
request: &R,
) -> ControlClientResult<R::Response>
pub async fn request_typed<R: CheckedControlRequest>( &self, request: &R, ) -> ControlClientResult<R::Response>
Normalize a checked operation without manufacturing a CBOR response.
Sourcepub async fn request_typed_with<R: CheckedControlRequest>(
&self,
request: &R,
configure: impl FnOnce(RequestOptions) -> RequestOptions,
) -> ControlClientResult<R::Response>
pub async fn request_typed_with<R: CheckedControlRequest>( &self, request: &R, configure: impl FnOnce(RequestOptions) -> RequestOptions, ) -> ControlClientResult<R::Response>
Configure one checked unary attempt.
Trait Implementations§
Source§impl Clone for JsonControlClient
impl Clone for JsonControlClient
Source§fn clone(&self) -> JsonControlClient
fn clone(&self) -> JsonControlClient
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read more