Struct ControlProtocol 

pub struct ControlProtocol;

Generation-one hello/welcome and operation metadata.

Trait Implementations

impl Protocol for ControlProtocol

type Ready = ControlReady

Shared immutable metadata negotiated during setup.

fn establish( stream: BoxTransport, options: ConnectOptions, ) -> BoxFuture<'static, ClientResult<Established<Self::Ready>>>

Consume an owned stream and preserve any prefetched bytes in the result.

fn prepare(ready: &Self::Ready, wire_name: &str) -> ClientResult<SendMetadata>

Validate availability and select metadata for a named outbound message.

const REUSE_IDS: bool = true

Whether terminal completion permits reusing a correlation ID.

impl Request<ControlProtocol> for GetCapabilities

type Response = Capabilities

Checked operation result, independent of SDK domain behavior.

type Error = ControlClientError

Application error that can also retain a local transport failure.

fn message(&self) -> ControlClientResult<EncodedMessage>

Encode the prepared request without performing I/O.

fn decode(&self, response: Message) -> ControlClientResult<Self::Response>

Check the expected terminal response name, generation, and payload.

impl Request<ControlProtocol> for GetMemoryState

type Response = MemoryState

Checked operation result, independent of SDK domain behavior.

type Error = ControlClientError

Application error that can also retain a local transport failure.

fn message(&self) -> ControlClientResult<EncodedMessage>

Encode the prepared request without performing I/O.

fn decode(&self, response: Message) -> ControlClientResult<Self::Response>

Check the expected terminal response name, generation, and payload.

impl Request<ControlProtocol> for SetMemoryTarget

type Response = MemoryState

Checked operation result, independent of SDK domain behavior.

type Error = ControlClientError

Application error that can also retain a local transport failure.

fn message(&self) -> ControlClientResult<EncodedMessage>

Encode the prepared request without performing I/O.

fn decode(&self, response: Message) -> ControlClientResult<Self::Response>

Check the expected terminal response name, generation, and payload.

impl Request<ControlProtocol> for GetCpuState

type Response = CpuState

Checked operation result, independent of SDK domain behavior.

type Error = ControlClientError

Application error that can also retain a local transport failure.

fn message(&self) -> ControlClientResult<EncodedMessage>

Encode the prepared request without performing I/O.

fn decode(&self, response: Message) -> ControlClientResult<Self::Response>

Check the expected terminal response name, generation, and payload.

impl Request<ControlProtocol> for SetCpuTarget

type Response = CpuState

Checked operation result, independent of SDK domain behavior.

type Error = ControlClientError

Application error that can also retain a local transport failure.

fn message(&self) -> ControlClientResult<EncodedMessage>

Encode the prepared request without performing I/O.

fn decode(&self, response: Message) -> ControlClientResult<Self::Response>

Check the expected terminal response name, generation, and payload.

impl Request<ControlProtocol> for UpdateSecrets

type Response = SecretsResult

Checked operation result, independent of SDK domain behavior.

type Error = ControlClientError

Application error that can also retain a local transport failure.

fn message(&self) -> ControlClientResult<EncodedMessage>

Encode the prepared request without performing I/O.

fn decode(&self, response: Message) -> ControlClientResult<Self::Response>

Check the expected terminal response name, generation, and payload.