Enum fluvio_spu_schema::client::SpuClientRequest [−][src]
pub enum SpuClientRequest { ReplicaOffsetUpdateRequest(RequestMessage<ReplicaOffsetUpdateRequest>), }
Request from Spu Server to Client
Variants
ReplicaOffsetUpdateRequest(RequestMessage<ReplicaOffsetUpdateRequest>)
Trait Implementations
impl ApiMessage for SpuClientRequest
[src]
impl ApiMessage for SpuClientRequest
[src]type ApiKey = SpuClientApiKey
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 SpuClientRequest
[src]
impl Default for SpuClientRequest
[src]Auto Trait Implementations
impl RefUnwindSafe for SpuClientRequest
impl RefUnwindSafe for SpuClientRequest
impl Send for SpuClientRequest
impl Send for SpuClientRequest
impl Sync for SpuClientRequest
impl Sync for SpuClientRequest
impl Unpin for SpuClientRequest
impl Unpin for SpuClientRequest
impl UnwindSafe for SpuClientRequest
impl UnwindSafe for SpuClientRequest
Blanket Implementations
impl<T> Instrument for T
[src]
impl<T> Instrument for T
[src]