Struct InmemoryRemoteLogMetadataManager 

pub struct InmemoryRemoteLogMetadataManager { /* private fields */ }

In-memory RemoteLogMetadataManager: one RemoteLogMetadataCache per partition behind a single mutex. Not durable — state is lost on restart — but enforces the full lifecycle state machine, so it is a faithful stand-in for the topic-backed production manager in tests and single-process setups.

Implementations

impl InmemoryRemoteLogMetadataManager

pub fn new() -> Self

Construct an empty manager.

pub fn export(&self) -> RlmmCacheDump

Dump every partition’s segment + partition-delete metadata for snapshotting. The result is order-independent; Self::import re-derives ordering and the epoch index.

pub fn import(&self, dump: RlmmCacheDump)

Seed the cache from a dump, bypassing transition validation Intended for a freshly-constructed manager during snapshot restore; existing partitions are overwritten.

Trait Implementations

impl Debug for InmemoryRemoteLogMetadataManager

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

Formats the value using the given formatter.

impl Default for InmemoryRemoteLogMetadataManager

fn default() -> InmemoryRemoteLogMetadataManager

Returns the “default value” for a type.

impl RemoteLogMetadataManager for InmemoryRemoteLogMetadataManager

fn add_remote_log_segment_metadata( &self, metadata: RemoteLogSegmentMetadata, ) -> Result<(), RemoteStorageError>

Record a newly-started segment copy. The metadata’s state must be CopySegmentStarted and its id must not already be known.

fn update_remote_log_segment_metadata( &self, update: RemoteLogSegmentMetadataUpdate, ) -> Result<(), RemoteStorageError>

Advance a known segment’s lifecycle state.

fn remote_log_segment_metadata( &self, topic_id_partition: &TopicIdPartition, leader_epoch: i32, offset: i64, ) -> Result<Option<RemoteLogSegmentMetadata>, RemoteStorageError>

Find the finished segment that contains offset for the given leader_epoch, if any.

fn highest_offset_for_epoch( &self, topic_id_partition: &TopicIdPartition, leader_epoch: i32, ) -> Result<Option<i64>, RemoteStorageError>

The highest offset that the remote tier holds for leader_epoch (the max end_offset across finished segments carrying that epoch).

fn list_remote_log_segments( &self, topic_id_partition: &TopicIdPartition, ) -> Result<Vec<RemoteLogSegmentMetadata>, RemoteStorageError>

All segments known for a partition, ordered by start_offset (regardless of state).

fn list_remote_log_segments_by_epoch( &self, topic_id_partition: &TopicIdPartition, leader_epoch: i32, ) -> Result<Vec<RemoteLogSegmentMetadata>, RemoteStorageError>

All segments carrying leader_epoch, ordered by start_offset (regardless of state).

fn put_remote_partition_delete_metadata( &self, metadata: RemotePartitionDeleteMetadata, ) -> Result<(), RemoteStorageError>

Record a partition-delete lifecycle event.