[−][src]Struct fluvio_dataplane_protocol::fetch::FetchablePartitionResponse
Fields
partition_index: i32
The partiiton index.
error_code: ErrorCode
The error code, or 0 if there was no fetch error
high_watermark: i64
The current high water mark.
last_stable_offset: i64
The last stable offset (or LSO) of the partition. This is the last offset such that the state of all transactional records prior to this offset have been decided (ABORTED or COMMITTED)
log_start_offset: i64
The current log start offset.
aborted: Option<Vec<AbortedTransaction>>
The aborted transactions.
records: R
The record data.
Trait Implementations
impl<R: Debug> Debug for FetchablePartitionResponse<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
impl<R> Decoder for FetchablePartitionResponse<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
pub fn decode<T>(&mut self, src: &mut T, version: Version) -> 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 FetchablePartitionResponse<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
impl<R> Encoder for FetchablePartitionResponse<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
Auto Trait Implementations
impl<R> RefUnwindSafe for FetchablePartitionResponse<R> where
R: RefUnwindSafe,
[src]
R: RefUnwindSafe,
impl<R> Send for FetchablePartitionResponse<R> where
R: Send,
[src]
R: Send,
impl<R> Sync for FetchablePartitionResponse<R> where
R: Sync,
[src]
R: Sync,
impl<R> Unpin for FetchablePartitionResponse<R> where
R: Unpin,
[src]
R: Unpin,
impl<R> UnwindSafe for FetchablePartitionResponse<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> 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, 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>,