Enum fluvio_spu_schema::client::SpuClientRequest [−][src]
pub enum SpuClientRequest {
ReplicaOffsetUpdateRequest(RequestMessage<ReplicaOffsetUpdateRequest>),
}
Expand description
Request from Spu Server to Client
Variants
ReplicaOffsetUpdateRequest(RequestMessage<ReplicaOffsetUpdateRequest>)
Tuple Fields of ReplicaOffsetUpdateRequest
Trait Implementations
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,
Auto Trait Implementations
impl RefUnwindSafe for SpuClientRequest
impl Send for SpuClientRequest
impl Sync for SpuClientRequest
impl Unpin for SpuClientRequest
impl UnwindSafe for SpuClientRequest
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