Struct fluvio::dataplane::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<R> Encoder for FetchablePartitionResponse<R> where
    R: Encoder + Decoder + Default + Debug, 

fn encode<T>(&self, dest: &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<FileRecordSet>

fn file_encode(
    &self,
    src: &mut BytesMut,
    data: &mut Vec<StoreValue>,
    version: i16
) -> Result<(), Error>