Struct fluvio_dataplane_protocol::fetch::FetchRequest [−][src]
pub struct FetchRequest<R> where
R: Encoder + Decoder + Default + Debug, {
pub max_wait: i32,
pub min_bytes: i32,
pub max_bytes: i32,
pub isolation_level: Isolation,
pub topics: Vec<FetchableTopic>,
pub forgotten: Vec<ForgottenTopic>,
pub data: PhantomData<R>,
}
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>
The topics to fetch.
forgotten: Vec<ForgottenTopic>
In an incremental fetch request, the partitions to remove.
data: PhantomData<R>
Trait Implementations
Auto Trait Implementations
impl<R> RefUnwindSafe for FetchRequest<R> where
R: RefUnwindSafe,
impl<R> Send for FetchRequest<R> where
R: Send,
impl<R> Sync for FetchRequest<R> where
R: Sync,
impl<R> Unpin for FetchRequest<R> where
R: Unpin,
impl<R> UnwindSafe for FetchRequest<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