Struct fluvio_dataplane_protocol::api::RequestMessage [−][src]
pub struct RequestMessage<R> {
pub header: RequestHeader,
pub request: R,
}
Expand description
Start of API request
Fields
header: RequestHeader
request: R
Implementations
create with header, this assume header is constructed from higher request no api key check is performed since it is already done
create from request, header is implicilty created from key in the request
pub fn new_response(
&self,
response: <R as Request>::Response
) -> ResponseMessage<<R as Request>::Response>
pub fn response_with_header<H>(
header: H,
response: <R as Request>::Response
) -> ResponseMessage<<R as Request>::Response> where
H: Into<i32>,
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> where
H: AsRef<Path>,
helper function to set client id
Trait Implementations
Auto Trait Implementations
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
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more