[−][src]Struct fluvio::dataplane::fetch::FetchRequest
Fields
max_wait: i32
The maximum time in milliseconds to wait for the response.
min_bytes: i32
The minimum bytes to accumulate in the response.
max_bytes: i32
The maximum bytes to fetch. See KIP-74 for cases where this limit may not be honored.
isolation_level: Isolation
This setting controls the visibility of transactional records. Using READ_UNCOMMITTED (isolation_level = 0) makes all records visible. With READ_COMMITTED (isolation_level = 1), non-transactional and COMMITTED transactional records are visible. To be more concrete, READ_COMMITTED returns all data from offsets smaller than the current LSO (last stable offset), and enables the inclusion of the list of aborted transactions in the result, which allows consumers to discard ABORTED transactional records
topics: Vec<FetchableTopic, Global>
The topics to fetch.
forgotten: Vec<ForgottenTopic, Global>
In an incremental fetch request, the partitions to remove.
data: PhantomData<R>
Trait Implementations
impl<R> Debug for FetchRequest<R> where
R: Debug + Encoder + Decoder + Default,
[src]
R: Debug + Encoder + Decoder + Default,
impl<R> Decoder for FetchRequest<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
pub fn decode<T>(&mut self, src: &mut T, version: i16) -> Result<(), Error> where
T: Buf,
[src]
T: Buf,
pub fn decode_from<T>(src: &mut T, version: i16) -> Result<Self, Error> where
Self: Default,
T: Buf,
Self: Default,
T: Buf,
impl<R> Default for FetchRequest<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
pub fn default() -> FetchRequest<R>
[src]
impl<R> Encoder for FetchRequest<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
pub fn as_bytes(&self, version: i16) -> Result<Bytes, Error>
impl<R> Request for FetchRequest<R> where
R: Debug + Decoder + Encoder,
[src]
R: Debug + Decoder + Encoder,
pub const API_KEY: u16
[src]
pub const MIN_API_VERSION: i16
[src]
pub const MAX_API_VERSION: i16
[src]
pub const DEFAULT_API_VERSION: i16
[src]
type Response = FetchResponse<R>
Auto Trait Implementations
impl<R> RefUnwindSafe for FetchRequest<R> where
R: RefUnwindSafe,
[src]
R: RefUnwindSafe,
impl<R> Send for FetchRequest<R> where
R: Send,
[src]
R: Send,
impl<R> Sync for FetchRequest<R> where
R: Sync,
[src]
R: Sync,
impl<R> Unpin for FetchRequest<R> where
R: Unpin,
[src]
R: Unpin,
impl<R> UnwindSafe for FetchRequest<R> where
R: UnwindSafe,
[src]
R: UnwindSafe,
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> Erased for T
impl<T> From<T> for T
[src]
impl<T> Instrument for T
[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T> Instrument for T
[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<T> WithSubscriber for T
[src]
pub fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
[src]
S: Into<Dispatch>,