Enum fluvio_spu_schema::server::SpuServerRequest [−][src]
pub enum SpuServerRequest { ApiVersionsRequest(RequestMessage<ApiVersionsRequest>), ProduceRequest(RequestMessage<DefaultProduceRequest>), FileFetchRequest(RequestMessage<FileFetchRequest>), FetchOffsetsRequest(RequestMessage<FetchOffsetsRequest>), FileStreamFetchRequest(RequestMessage<FileStreamFetchRequest>), UpdateOffsetsRequest(RequestMessage<UpdateOffsetsRequest>), }
Request to Spu Server
Variants
ApiVersionsRequest(RequestMessage<ApiVersionsRequest>)
list of versions supported
ProduceRequest(RequestMessage<DefaultProduceRequest>)
FileFetchRequest(RequestMessage<FileFetchRequest>)
FetchOffsetsRequest(RequestMessage<FetchOffsetsRequest>)
FileStreamFetchRequest(RequestMessage<FileStreamFetchRequest>)
UpdateOffsetsRequest(RequestMessage<UpdateOffsetsRequest>)
Trait Implementations
impl ApiMessage for SpuServerRequest
[src]
impl ApiMessage for SpuServerRequest
[src]type ApiKey = SpuServerApiKey
fn decode_with_header<T>(
src: &mut T,
header: RequestHeader
) -> Result<Self, IoError> where
Self: Default + Sized,
Self::ApiKey: Sized,
T: Buf,
[src]
src: &mut T,
header: RequestHeader
) -> Result<Self, IoError> where
Self: Default + Sized,
Self::ApiKey: Sized,
T: Buf,
pub fn decode_from<T>(src: &mut T) -> Result<Self, Error> where
T: Buf,
T: Buf,
pub fn decode_from_file<P>(file_name: P) -> Result<Self, Error> where
P: AsRef<Path>,
P: AsRef<Path>,
impl Default for SpuServerRequest
[src]
impl Default for SpuServerRequest
[src]Auto Trait Implementations
impl RefUnwindSafe for SpuServerRequest
impl RefUnwindSafe for SpuServerRequest
impl Send for SpuServerRequest
impl Send for SpuServerRequest
impl Sync for SpuServerRequest
impl Sync for SpuServerRequest
impl Unpin for SpuServerRequest
impl Unpin for SpuServerRequest
impl UnwindSafe for SpuServerRequest
impl UnwindSafe for SpuServerRequest
Blanket Implementations
impl<T> Instrument for T
[src]
impl<T> Instrument for T
[src]