Struct fluvio_dataplane_protocol::fetch::FetchResponse [−][src]
pub struct FetchResponse<R> where
R: Encoder + Decoder + Default + Debug, {
pub throttle_time_ms: i32,
pub error_code: ErrorCode,
pub session_id: i32,
pub topics: Vec<FetchableTopicResponse<R>>,
}
Fields
throttle_time_ms: i32
The duration in milliseconds for which the request was throttled due to a quota violation, or zero if the request did not violate any quota.
error_code: ErrorCode
session_id: i32
topics: Vec<FetchableTopicResponse<R>>
The response topics.
Implementations
pub fn find_partition(
self,
topic: &str,
partition: i32
) -> Option<FetchablePartitionResponse<R>>
Trait Implementations
Auto Trait Implementations
impl<R> RefUnwindSafe for FetchResponse<R> where
R: RefUnwindSafe,
impl<R> Send for FetchResponse<R> where
R: Send,
impl<R> Sync for FetchResponse<R> where
R: Sync,
impl<R> Unpin for FetchResponse<R> where
R: Unpin,
impl<R> UnwindSafe for FetchResponse<R> where
R: UnwindSafe,
Blanket Implementations
Mutably borrows from an owned value. Read more
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. 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