Struct mz_storage_client::client::ProtoStorageCommand
source · Fields§
§kind: Option<Kind>
Trait Implementations§
source§impl Clone for ProtoStorageCommand
impl Clone for ProtoStorageCommand
source§fn clone(&self) -> ProtoStorageCommand
fn clone(&self) -> ProtoStorageCommand
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 ProtoStorageCommand
impl Debug for ProtoStorageCommand
source§impl Default for ProtoStorageCommand
impl Default for ProtoStorageCommand
source§impl Message for ProtoStorageCommand
impl Message for ProtoStorageCommand
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<ProtoStorageCommand> for ProtoStorageCommand
impl PartialEq<ProtoStorageCommand> for ProtoStorageCommand
source§fn eq(&self, other: &ProtoStorageCommand) -> bool
fn eq(&self, other: &ProtoStorageCommand) -> bool
This method tests for
self
and other
values to be equal, and is used
by ==
.source§impl RustType<ProtoStorageCommand> for StorageCommand<Timestamp>
impl RustType<ProtoStorageCommand> for StorageCommand<Timestamp>
source§fn into_proto(&self) -> ProtoStorageCommand
fn into_proto(&self) -> ProtoStorageCommand
Convert a
Self
into a Proto
value.source§fn from_proto(proto: ProtoStorageCommand) -> Result<Self, TryFromProtoError>
fn from_proto(proto: ProtoStorageCommand) -> Result<Self, TryFromProtoError>
source§impl StatsCollector<ProtoStorageCommand, ProtoStorageResponse> for RehydratingStorageClientMetrics
impl StatsCollector<ProtoStorageCommand, ProtoStorageResponse> for RehydratingStorageClientMetrics
Make ReplicaConnectionMetric pluggable into the gRPC connection.
fn send_event(&self, _item: &ProtoStorageCommand, size: usize)
fn receive_event(&self, _item: &ProtoStorageResponse, size: usize)
source§impl<T: ProtoStorage> StreamingService<ProtoStorageCommand> for CommandResponseStreamSvc<T>
impl<T: ProtoStorage> StreamingService<ProtoStorageCommand> for CommandResponseStreamSvc<T>
§type Response = ProtoStorageResponse
type Response = ProtoStorageResponse
Protobuf response message type
§type ResponseStream = <T as ProtoStorage>::CommandResponseStreamStream
type ResponseStream = <T as ProtoStorage>::CommandResponseStreamStream
Stream of outbound response messages
§type Future = Pin<Box<dyn Future<Output = Result<Response<<CommandResponseStreamSvc<T> as StreamingService<ProtoStorageCommand>>::ResponseStream>, Status>> + Send + 'static, Global>>
type Future = Pin<Box<dyn Future<Output = Result<Response<<CommandResponseStreamSvc<T> as StreamingService<ProtoStorageCommand>>::ResponseStream>, Status>> + Send + 'static, Global>>
Response future
impl StructuralPartialEq for ProtoStorageCommand
Auto Trait Implementations§
impl RefUnwindSafe for ProtoStorageCommand
impl Send for ProtoStorageCommand
impl Sync for ProtoStorageCommand
impl Unpin for ProtoStorageCommand
impl UnwindSafe for ProtoStorageCommand
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
.