[−][src]Struct fluvio::dataplane::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, Global>>
The aborted transactions.
records: R
The record data.
Trait Implementations
impl<R> Debug for FetchablePartitionResponse<R> where
R: Debug + Encoder + Decoder + Default,
[src]
R: Debug + Encoder + Decoder + Default,
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: 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 FetchablePartitionResponse<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
pub fn default() -> FetchablePartitionResponse<R>
[src]
impl<R> Encoder for FetchablePartitionResponse<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 FileWrite for FetchablePartitionResponse<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 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> 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>,