Struct fluvio::dataplane::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>, Global>, }
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>, Global>
The response topics.
Implementations
impl<R> FetchResponse<R> where
R: Encoder + Decoder + Default + Debug,
[src]
impl<R> FetchResponse<R> where
R: Encoder + Decoder + Default + Debug,
[src]pub fn find_partition(
self,
topic: &str,
partition: i32
) -> Option<FetchablePartitionResponse<R>>
[src]
self,
topic: &str,
partition: i32
) -> Option<FetchablePartitionResponse<R>>
impl<R> FetchResponse<R> where
R: Encoder + Decoder + Debug,
[src]
impl<R> FetchResponse<R> where
R: Encoder + Decoder + Debug,
[src]pub fn find_topic(&self, topic: &str) -> Option<&FetchableTopicResponse<R>> where
R: Debug,
[src]
R: Debug,
Trait Implementations
impl<R> Default for FetchResponse<R> where
R: Encoder + Decoder + Default + Debug,
[src]
impl<R> Default for FetchResponse<R> where
R: Encoder + Decoder + Default + Debug,
[src]pub fn default() -> FetchResponse<R>
[src]
impl FileWrite for FetchResponse<FileRecordSet>
[src]
impl FileWrite for FetchResponse<FileRecordSet>
[src]pub fn file_encode(
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue, Global>,
version: i16
) -> Result<(), Error>
[src]
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue, Global>,
version: i16
) -> Result<(), Error>
Auto Trait Implementations
impl<R> RefUnwindSafe for FetchResponse<R> where
R: RefUnwindSafe,
impl<R> RefUnwindSafe for FetchResponse<R> where
R: RefUnwindSafe,
impl<R> Send for FetchResponse<R> where
R: Send,
impl<R> Send for FetchResponse<R> where
R: Send,
impl<R> Sync for FetchResponse<R> where
R: Sync,
impl<R> Sync for FetchResponse<R> where
R: Sync,
impl<R> Unpin for FetchResponse<R> where
R: Unpin,
impl<R> Unpin for FetchResponse<R> where
R: Unpin,
impl<R> UnwindSafe for FetchResponse<R> where
R: UnwindSafe,
impl<R> UnwindSafe for FetchResponse<R> where
R: UnwindSafe,
Blanket Implementations
impl<T> Instrument for T
[src]
impl<T> Instrument for T
[src]