[−][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 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,
fn decode<T>(&mut self, src: &mut T, version: i16) -> 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,
fn default() -> FetchablePartitionResponse<R>
[src]
impl<'de, R> Deserialize<'de> for FetchablePartitionResponse<R> where
R: Encoder + Decoder + Default + Debug + Deserialize<'de>,
[src]
R: Encoder + Decoder + Default + Debug + Deserialize<'de>,
fn deserialize<__D>(
__deserializer: __D
) -> Result<FetchablePartitionResponse<R>, <__D as Deserializer<'de>>::Error> where
__D: Deserializer<'de>,
[src]
__deserializer: __D
) -> Result<FetchablePartitionResponse<R>, <__D as Deserializer<'de>>::Error> where
__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, src: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
fn write_size(&self, version: i16) -> usize
[src]
fn as_bytes(&self, version: i16) -> Result<Bytes, Error>
[src]
impl FileWrite for FetchablePartitionResponse<KfFileRecordSet>
[src]
fn file_encode(
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: i16
) -> Result<(), Error>
[src]
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: i16
) -> Result<(), Error>
impl<R> Serialize for FetchablePartitionResponse<R> where
R: Encoder + Decoder + Default + Debug + Serialize,
[src]
R: Encoder + Decoder + Default + Debug + Serialize,
fn serialize<__S>(
&self,
__serializer: __S
) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error> where
__S: Serializer,
[src]
&self,
__serializer: __S
) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error> where
__S: Serializer,
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>,