Enum tarpc::rpc::ClientMessage

[−] Show declaration

[+] Expand attributes
#[non_exhaustive]pub enum ClientMessage<T> {
    Request(Request<T>),
    Cancel {
        trace_context: Context,
        request_id: u64,
    },
}

[−] Expand description

A message from a client to a server.

Variants (Non-exhaustive)

[+] This enum is marked as non-exhaustive

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Request(Request<T>)

[−] Expand description

A request initiated by a user. The server responds to a request by invoking a service-provided request handler. The handler completes with a response, which the server sends back to the client.

Cancel

[−] Expand description

A command to cancel an in-flight request, automatically sent by the client when a response future is dropped.

When received, the server will immediately cancel the main task (top-level future) of the request handler for the associated request. Any tasks spawned by the request handler will not be canceled, because the framework layer does not know about them.

[−] Show fields

Fields of Cancel

trace_context: Context

The trace context associates the message with a specific chain of causally-related actions, possibly orchestrated across many distributed systems.

request_id: u64

The ID of the request to cancel.

Trait Implementations

impl<T: Debug> Debug for ClientMessage<T>[+]

[+] Show hidden undocumented items

fn fmt(&self, f: &mut Formatter<'_>) -> Result[−]

Formats the value using the given formatter.

impl<'de, T> Deserialize<'de> for ClientMessage<T> where
    T: Deserialize<'de>, [+]

[+] Show hidden undocumented items

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, [−]

Deserialize this value from the given Serde deserializer.

impl<T> Serialize for ClientMessage<T> where
    T: Serialize, [+]

[+] Show hidden undocumented items

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, [−]

Serialize this value into the given Serde serializer.