Struct fluvio::dataplane::api::RequestMessage
source · pub struct RequestMessage<R> {
pub header: RequestHeader,
pub request: R,
}
Expand description
Start of API request
Fields§
§header: RequestHeader
§request: R
Implementations§
source§impl<R> RequestMessage<R>
impl<R> RequestMessage<R>
pub fn get_mut_header(&mut self) -> &mut RequestHeader
source§impl<R> RequestMessage<R>where
R: Request,
impl<R> RequestMessage<R>where
R: Request,
sourcepub fn new(header: RequestHeader, request: R) -> RequestMessage<R>
pub fn new(header: RequestHeader, request: R) -> RequestMessage<R>
create with header, this assume header is constructed from higher request no api key check is performed since it is already done
sourcepub fn new_request(request: R) -> RequestMessage<R>
pub fn new_request(request: R) -> RequestMessage<R>
create from request, header is implicitly created from key in the request
pub fn get_header_request(self) -> (RequestHeader, R)
pub fn request(&self) -> &R
pub fn new_response( &self, response: <R as Request>::Response ) -> ResponseMessage<<R as Request>::Response>
pub fn response_with_header( header: impl Into<i32>, response: <R as Request>::Response ) -> ResponseMessage<<R as Request>::Response>
pub fn decode_response<T>(
&self,
src: &mut T,
version: i16
) -> Result<ResponseMessage<<R as Request>::Response>, Error>where
T: Buf,
pub fn decode_response_from_file<H>( &self, file_name: H, version: i16 ) -> Result<ResponseMessage<<R as Request>::Response>, Error>
sourcepub fn set_client_id<T>(self, client_id: T) -> RequestMessage<R>
pub fn set_client_id<T>(self, client_id: T) -> RequestMessage<R>
helper function to set client id
Trait Implementations§
source§impl<R> Clone for RequestMessage<R>where
R: Clone,
impl<R> Clone for RequestMessage<R>where
R: Clone,
source§fn clone(&self) -> RequestMessage<R>
fn clone(&self) -> RequestMessage<R>
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<R> Debug for RequestMessage<R>where
R: Debug,
impl<R> Debug for RequestMessage<R>where
R: Debug,
source§impl<R> Decoder for RequestMessage<R>where
R: Request,
impl<R> Decoder for RequestMessage<R>where
R: Request,
source§impl<R> Default for RequestMessage<R>
impl<R> Default for RequestMessage<R>
source§fn default() -> RequestMessage<R>
fn default() -> RequestMessage<R>
Returns the “default value” for a type. Read more
source§impl<R> Display for RequestMessage<R>where
R: Display,
impl<R> Display for RequestMessage<R>where
R: Display,
source§impl<R> Encoder for RequestMessage<R>where
R: Request,
impl<R> Encoder for RequestMessage<R>where
R: Request,
source§impl<R> FileWrite for RequestMessage<R>
impl<R> FileWrite for RequestMessage<R>
This is same as encoding in the RequestMessage but first includes the length and can encode async file slice
fn file_encode( &self, dest: &mut BytesMut, data: &mut Vec<StoreValue>, version: i16 ) -> Result<(), Error>
Auto Trait Implementations§
impl<R> Freeze for RequestMessage<R>where
R: Freeze,
impl<R> RefUnwindSafe for RequestMessage<R>where
R: RefUnwindSafe,
impl<R> Send for RequestMessage<R>where
R: Send,
impl<R> Sync for RequestMessage<R>where
R: Sync,
impl<R> Unpin for RequestMessage<R>where
R: Unpin,
impl<R> UnwindSafe for RequestMessage<R>where
R: UnwindSafe,
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