Struct InProcessMetadataEventLog 

pub struct InProcessMetadataEventLog { /* private fields */ }

Single-process MetadataEventLog used by unit tests and as the multi-broker fixture (multiple manager instances cloning the same Arc observe each other’s writes).

Implementations

impl InProcessMetadataEventLog

pub fn new(partition_count: i32) -> Arc<Self>

Construct an empty log with partition_count partitions.

Panics

Panics when partition_count <= 0.

Trait Implementations

impl MetadataEventLog for InProcessMetadataEventLog

fn partition_count(&self) -> i32

Number of partitions the log holds. Stable for the lifetime of the log; the manager hashes user partitions into [0, partition_count()).

fn publish<'life0, 'async_trait>( &'life0 self, partition: i32, event: Bytes, ) -> Pin<Box<dyn Future<Output = Result<i64, MetadataLogError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Append event to partition. Resolves to the assigned offset.

fn subscribe( &self, assignment: Vec<PartitionStart>, ) -> (MetadataEventStream, Arc<dyn AssignmentHandle>)

Start consuming the given partitions, each from its start offset (inclusive). Returns the event stream plus a handle to mutate the live assignment.

fn high_water_marks<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<i64>, MetadataLogError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

One past the highest written offset for each partition, indexed by partition.