Struct mz_compute_client::command::ProtoComputeCommand
source · Fields§
§kind: Option<Kind>
Trait Implementations§
source§impl Clone for ProtoComputeCommand
impl Clone for ProtoComputeCommand
source§fn clone(&self) -> ProtoComputeCommand
fn clone(&self) -> ProtoComputeCommand
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresource§impl Debug for ProtoComputeCommand
impl Debug for ProtoComputeCommand
source§impl Default for ProtoComputeCommand
impl Default for ProtoComputeCommand
source§impl Message for ProtoComputeCommand
impl Message for ProtoComputeCommand
source§fn encoded_len(&self) -> usize
fn encoded_len(&self) -> usize
Returns the encoded length of the message without a length delimiter.
source§fn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError>where
B: BufMut,
Self: Sized,
fn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError>where
B: BufMut,
Self: Sized,
Encodes the message to a buffer. Read more
source§fn encode_to_vec(&self) -> Vec<u8, Global> ⓘwhere
Self: Sized,
fn encode_to_vec(&self) -> Vec<u8, Global> ⓘwhere
Self: Sized,
Encodes the message to a newly allocated buffer.
source§fn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError>where
B: BufMut,
Self: Sized,
fn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError>where
B: BufMut,
Self: Sized,
Encodes the message with a length-delimiter to a buffer. Read more
source§fn encode_length_delimited_to_vec(&self) -> Vec<u8, Global> ⓘwhere
Self: Sized,
fn encode_length_delimited_to_vec(&self) -> Vec<u8, Global> ⓘwhere
Self: Sized,
Encodes the message with a length-delimiter to a newly allocated buffer.
source§fn decode<B>(buf: B) -> Result<Self, DecodeError>where
B: Buf,
Self: Default,
fn decode<B>(buf: B) -> Result<Self, DecodeError>where
B: Buf,
Self: Default,
Decodes an instance of the message from a buffer. Read more
source§fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError>where
B: Buf,
Self: Default,
fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError>where
B: Buf,
Self: Default,
Decodes a length-delimited instance of the message from the buffer.
source§fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError>where
B: Buf,
Self: Sized,
fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError>where
B: Buf,
Self: Sized,
Decodes an instance of the message from a buffer, and merges it into
self
. Read moresource§fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError>where
B: Buf,
Self: Sized,
fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError>where
B: Buf,
Self: Sized,
Decodes a length-delimited instance of the message from buffer, and
merges it into
self
.source§impl PartialEq<ProtoComputeCommand> for ProtoComputeCommand
impl PartialEq<ProtoComputeCommand> for ProtoComputeCommand
source§fn eq(&self, other: &ProtoComputeCommand) -> bool
fn eq(&self, other: &ProtoComputeCommand) -> bool
This method tests for
self
and other
values to be equal, and is used
by ==
.source§impl RustType<ProtoComputeCommand> for ComputeCommand<Timestamp>
impl RustType<ProtoComputeCommand> for ComputeCommand<Timestamp>
source§fn into_proto(&self) -> ProtoComputeCommand
fn into_proto(&self) -> ProtoComputeCommand
Convert a
Self
into a Proto
value.source§fn from_proto(proto: ProtoComputeCommand) -> Result<Self, TryFromProtoError>
fn from_proto(proto: ProtoComputeCommand) -> Result<Self, TryFromProtoError>
source§impl<T: ProtoCompute> StreamingService<ProtoComputeCommand> for CommandResponseStreamSvc<T>
impl<T: ProtoCompute> StreamingService<ProtoComputeCommand> for CommandResponseStreamSvc<T>
§type Response = ProtoComputeResponse
type Response = ProtoComputeResponse
Protobuf response message type
§type ResponseStream = <T as ProtoCompute>::CommandResponseStreamStream
type ResponseStream = <T as ProtoCompute>::CommandResponseStreamStream
Stream of outbound response messages
§type Future = Pin<Box<dyn Future<Output = Result<Response<<CommandResponseStreamSvc<T> as StreamingService<ProtoComputeCommand>>::ResponseStream>, Status>> + Send + 'static, Global>>
type Future = Pin<Box<dyn Future<Output = Result<Response<<CommandResponseStreamSvc<T> as StreamingService<ProtoComputeCommand>>::ResponseStream>, Status>> + Send + 'static, Global>>
Response future
impl StructuralPartialEq for ProtoComputeCommand
Auto Trait Implementations§
impl RefUnwindSafe for ProtoComputeCommand
impl Send for ProtoComputeCommand
impl Sync for ProtoComputeCommand
impl Unpin for ProtoComputeCommand
impl UnwindSafe for ProtoComputeCommand
Blanket Implementations§
source§impl<T> FutureExt for T
impl<T> FutureExt for T
source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request
source§impl<T> Pointable for T
impl<T> Pointable for T
source§impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
source§fn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
See
RustType::from_proto
.source§fn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
See
RustType::into_proto
.