Struct AbortedTransactionIndex 

pub struct AbortedTransactionIndex { /* private fields */ }

Index of aborted transactions for a partition

Used for efficient filtering when isolation.level=read_committed

Implementations

impl AbortedTransactionIndex

pub fn new() -> Self

Create a new empty index

pub fn record_abort( &self, producer_id: ProducerId, first_offset: u64, last_offset: u64, )

Record an aborted transaction

Tracks both first and last offset to bound the aborted range. Checks first_offset <= offset <= last_offset (bounded range).

pub fn get_aborted_in_range( &self, start_offset: u64, end_offset: u64, ) -> Vec<AbortedTransaction>

Get aborted transactions that overlap with a range of offsets

Returns aborted transactions whose first_offset is within [start_offset, end_offset]

pub fn is_aborted(&self, producer_id: ProducerId, offset: u64) -> bool

Check if a specific producer’s message at an offset is from an aborted transaction

Checks bounded range first_offset <= offset <= last_offset to avoid false-positives on committed messages from the same producer in later transactions.

pub fn truncate_before(&self, offset: u64)

Remove aborted transactions older than a given offset (for log truncation)

pub fn len(&self) -> usize

Get count of tracked aborted transactions

pub fn is_empty(&self) -> bool

Check if index is empty

Trait Implementations

impl Debug for AbortedTransactionIndex

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

Formats the value using the given formatter.

impl Default for AbortedTransactionIndex

fn default() -> AbortedTransactionIndex

Returns the “default value” for a type.