Struct fluvio_spu_schema::server::update_offset::UpdateOffsetsRequest [−][src]
pub struct UpdateOffsetsRequest { pub offsets: Vec<OffsetUpdate>, }
send out current offset to SPU
Fields
offsets: Vec<OffsetUpdate>
Implementations
impl UpdateOffsetsRequest
[src]
impl UpdateOffsetsRequest
[src]pub fn new(offsets: Vec<OffsetUpdate>) -> Self
[src]
Trait Implementations
impl Decoder for UpdateOffsetsRequest
[src]
impl Decoder for UpdateOffsetsRequest
[src]impl Default for UpdateOffsetsRequest
[src]
impl Default for UpdateOffsetsRequest
[src]fn default() -> UpdateOffsetsRequest
[src]
impl Encoder for UpdateOffsetsRequest
[src]
impl Encoder for UpdateOffsetsRequest
[src]impl Request for UpdateOffsetsRequest
[src]
impl Request for UpdateOffsetsRequest
[src]const API_KEY: u16
[src]
const DEFAULT_API_VERSION: i16
[src]
type Response = UpdateOffsetsResponse
pub const MIN_API_VERSION: i16
pub const MAX_API_VERSION: i16
Auto Trait Implementations
impl RefUnwindSafe for UpdateOffsetsRequest
impl RefUnwindSafe for UpdateOffsetsRequest
impl Send for UpdateOffsetsRequest
impl Send for UpdateOffsetsRequest
impl Sync for UpdateOffsetsRequest
impl Sync for UpdateOffsetsRequest
impl Unpin for UpdateOffsetsRequest
impl Unpin for UpdateOffsetsRequest
impl UnwindSafe for UpdateOffsetsRequest
impl UnwindSafe for UpdateOffsetsRequest
Blanket Implementations
impl<T> Instrument for T
[src]
impl<T> Instrument for T
[src]