Struct RemoteLogSegmentMetadata 

pub struct RemoteLogSegmentMetadata { /* private fields */ }

Metadata describing one segment stored (or being stored) in the remote tier.

Implementations

impl RemoteLogSegmentMetadata

pub fn new( remote_log_segment_id: RemoteLogSegmentId, start_offset: i64, end_offset: i64, max_timestamp_ms: i64, broker_id: i32, event_timestamp_ms: i64, segment_size_in_bytes: i32, state: RemoteLogSegmentState, segment_leader_epochs: BTreeMap<i32, i64>, ) -> Result<Self, RemoteStorageError>

Construct a RemoteLogSegmentMetadata.

Errors

Returns RemoteStorageError::InvalidArgument when segment_leader_epochs is empty, end_offset < start_offset, or segment_size_in_bytes < 0.

pub fn with_update( &self, update: &RemoteLogSegmentMetadataUpdate, ) -> Result<Self, RemoteStorageError>

Apply a RemoteLogSegmentMetadataUpdate, returning the updated copy. The update advances state, refreshes event_timestamp_ms and broker_id, and replaces custom_metadata when the update carries Some.

Errors

Returns RemoteStorageError::InvalidArgument if the update’s segment id does not match, or RemoteStorageError::InvalidSegmentTransition if the state change is not permitted from the current state.

pub fn remote_log_segment_id(&self) -> &RemoteLogSegmentId

The segment’s unique id.

pub fn start_offset(&self) -> i64

First offset (inclusive) covered by this segment.

pub fn end_offset(&self) -> i64

Last offset (inclusive) covered by this segment.

pub fn max_timestamp_ms(&self) -> i64

Highest record timestamp in this segment.

pub fn broker_id(&self) -> i32

Id of the broker that produced this metadata.

pub fn event_timestamp_ms(&self) -> i64

Wall-clock time the latest event for this segment was created.

pub fn segment_size_in_bytes(&self) -> i32

Size of the .log data in bytes.

pub fn custom_metadata(&self) -> Option<&CustomMetadata>

Opaque metadata the RemoteStorageManager attached at copy time, if any.

pub fn state(&self) -> RemoteLogSegmentState

Current lifecycle state.

pub fn segment_leader_epochs(&self) -> &BTreeMap<i32, i64>

Map of leader epoch → first offset that epoch contributed to this segment.

pub fn with_custom_metadata(self, custom: CustomMetadata) -> Self

Attach custom metadata (builder-style; used by RSM copy paths that produce a key before recording CopySegmentFinished).

pub fn txn_index_empty(&self) -> bool

true if the segment has no transaction index (KIP-405 txnIndexEmpty). Defaults to false. Serialized as the JVM record’s tagged field (tag 0).

pub fn with_txn_index_empty(self, empty: bool) -> Self

Builder-style setter for Self::txn_index_empty.

Trait Implementations

impl Clone for RemoteLogSegmentMetadata

fn clone(&self) -> RemoteLogSegmentMetadata

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RemoteLogSegmentMetadata

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

Formats the value using the given formatter.

impl Eq for RemoteLogSegmentMetadata

impl PartialEq for RemoteLogSegmentMetadata

fn eq(&self, other: &RemoteLogSegmentMetadata) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for RemoteLogSegmentMetadata