[−][src]Struct kf_protocol_message::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,
fn decode<T>(&mut self, src: &mut T, version: Version) -> Result<(), Error> where
T: Buf,
[src]
T: Buf,
fn decode_from<T>(src: &mut T, version: i16) -> Result<Self, Error> where
Self: Default,
T: Buf,
[src]
Self: Default,
T: Buf,
impl<R> Default for FetchablePartitionResponse<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
impl<'de, R> Deserialize<'de> for FetchablePartitionResponse<R> where
R: Encoder + Decoder + Default + Debug,
R: Deserialize<'de>,
[src]
R: Encoder + Decoder + Default + Debug,
R: Deserialize<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
[src]
__D: Deserializer<'de>,
impl<R> Encoder for FetchablePartitionResponse<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
fn write_size(&self, version: Version) -> usize
[src]
fn as_bytes(&self, version: i16) -> Result<Bytes, Error>
[src]
impl<R> Serialize for FetchablePartitionResponse<R> where
R: Encoder + Decoder + Default + Debug,
R: Serialize,
[src]
R: Encoder + Decoder + Default + Debug,
R: Serialize,
Auto Trait Implementations
impl<R> RefUnwindSafe for FetchablePartitionResponse<R> where
R: RefUnwindSafe,
R: RefUnwindSafe,
impl<R> Send for FetchablePartitionResponse<R> where
R: Send,
R: Send,
impl<R> Sync for FetchablePartitionResponse<R> where
R: Sync,
R: Sync,
impl<R> Unpin for FetchablePartitionResponse<R> where
R: Unpin,
R: Unpin,
impl<R> UnwindSafe for FetchablePartitionResponse<R> where
R: UnwindSafe,
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,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> DeserializeOwned for T where
T: for<'de> Deserialize<'de>,
[src]
T: for<'de> Deserialize<'de>,
impl<T> From<T> for T
[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.
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>,