Enum tarpc::ClientMessage
source · [−]#[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
Request(Request<T>)
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
Fields
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.
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.
Trait Implementations
sourceimpl<T: Debug> Debug for ClientMessage<T>
impl<T: Debug> Debug for ClientMessage<T>
sourceimpl<'de, T> Deserialize<'de> for ClientMessage<T> where
T: Deserialize<'de>,
impl<'de, T> Deserialize<'de> for ClientMessage<T> where
T: Deserialize<'de>,
sourcefn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Auto Trait Implementations
impl<T> RefUnwindSafe for ClientMessage<T> where
T: RefUnwindSafe,
impl<T> Send for ClientMessage<T> where
T: Send,
impl<T> Sync for ClientMessage<T> where
T: Sync,
impl<T> Unpin for ClientMessage<T> where
T: Unpin,
impl<T> UnwindSafe for ClientMessage<T> where
T: UnwindSafe,
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> FutureExt for T
impl<T> FutureExt for T
sourcefn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
sourcefn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
fn vzip(self) -> V
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more