Struct kf_protocol::message::fetch::FetchablePartitionResponse

pub struct FetchablePartitionResponse<R> where
    R: Encoder + Decoder + Default + Debug,  {
    pub partition_index: i32,
    pub error_code: ErrorCode,
    pub high_watermark: i64,
    pub last_stable_offset: i64,
    pub log_start_offset: i64,
    pub aborted: Option<Vec<AbortedTransaction>>,
    pub records: R,
}

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, 

fn fmt(&self, f: &mut Formatter) -> Result<(), Error>

Formats the value using the given formatter.

impl<R> Decoder for FetchablePartitionResponse<R> where
    R: Encoder + Decoder + Default + Debug, 

fn decode<T>(&mut self, src: &mut T, version: i16) -> Result<(), Error> where
    T: Buf, 

fn decode_from<T>(src: &mut T, version: i16) -> Result<Self, Error> where
    Self: Default,
    T: Buf, 

decode Kafka compliant protocol values from buf

impl<R> Default for FetchablePartitionResponse<R> where
    R: Encoder + Decoder + Default + Debug, 

fn default() -> FetchablePartitionResponse<R>

Returns the "default value" for a type.

impl<'de, R> Deserialize<'de> for FetchablePartitionResponse<R> where
    R: Encoder + Decoder + Default + Debug + Deserialize<'de>, 

fn deserialize<__D>(
    __deserializer: __D
) -> Result<FetchablePartitionResponse<R>, <__D as Deserializer<'de>>::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl<R> Encoder for FetchablePartitionResponse<R> where
    R: Encoder + Decoder + Default + Debug, 

fn encode<T>(&self, src: &mut T, version: i16) -> Result<(), Error> where
    T: BufMut, 

encoding contents for buffer

fn write_size(&self, version: i16) -> usize

size of this object in bytes

fn as_bytes(&self, version: i16) -> Result<Bytes, Error>

impl FileWrite for FetchablePartitionResponse<KfFileRecordSet>

fn file_encode(
    &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, 

fn serialize<__S>(
    &self,
    __serializer: __S
) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.