pub enum ServerMessage {
InitResponse(InitResponse),
ReadResponse(ReadResponse),
CommitOffsetResponse(CommitOffsetResponse),
PartitionSessionStatusResponse(PartitionSessionStatusResponse),
UpdateTokenResponse(UpdateTokenResponse),
StartPartitionSessionRequest(StartPartitionSessionRequest),
StopPartitionSessionRequest(StopPartitionSessionRequest),
UpdatePartitionSession(UpdatePartitionSession),
}
Variants§
InitResponse(InitResponse)
Responses to respective client requests.
ReadResponse(ReadResponse)
CommitOffsetResponse(CommitOffsetResponse)
PartitionSessionStatusResponse(PartitionSessionStatusResponse)
UpdateTokenResponse(UpdateTokenResponse)
StartPartitionSessionRequest(StartPartitionSessionRequest)
Server commands.
StopPartitionSessionRequest(StopPartitionSessionRequest)
UpdatePartitionSession(UpdatePartitionSession)
Implementations§
Source§impl ServerMessage
impl ServerMessage
Sourcepub fn merge<B>(
field: &mut Option<ServerMessage>,
tag: u32,
wire_type: WireType,
buf: &mut B,
ctx: DecodeContext,
) -> Result<(), DecodeError>where
B: Buf,
pub fn merge<B>(
field: &mut Option<ServerMessage>,
tag: u32,
wire_type: WireType,
buf: &mut B,
ctx: DecodeContext,
) -> Result<(), DecodeError>where
B: Buf,
Decodes an instance of the message from a buffer, and merges it into self.
Sourcepub fn encoded_len(&self) -> usize
pub fn encoded_len(&self) -> usize
Returns the encoded length of the message without a length delimiter.
Trait Implementations§
Source§impl Clone for ServerMessage
impl Clone for ServerMessage
Source§fn clone(&self) -> ServerMessage
fn clone(&self) -> ServerMessage
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 ServerMessage
impl Debug for ServerMessage
Source§impl<'de> Deserialize<'de> for ServerMessage
impl<'de> Deserialize<'de> for ServerMessage
Source§fn 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
Source§impl PartialEq for ServerMessage
impl PartialEq for ServerMessage
Source§impl Serialize for ServerMessage
impl Serialize for ServerMessage
impl StructuralPartialEq for ServerMessage
Auto Trait Implementations§
impl Freeze for ServerMessage
impl RefUnwindSafe for ServerMessage
impl Send for ServerMessage
impl Sync for ServerMessage
impl Unpin for ServerMessage
impl UnwindSafe for ServerMessage
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
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