Enum LeaderRegionManifestInfo

pub enum LeaderRegionManifestInfo {
    Mito {
        manifest_version: u64,
        flushed_entry_id: u64,
        topic_latest_entry_id: u64,
    },
    Metric {
        data_manifest_version: u64,
        data_flushed_entry_id: u64,
        data_topic_latest_entry_id: u64,
        metadata_manifest_version: u64,
        metadata_flushed_entry_id: u64,
        metadata_topic_latest_entry_id: u64,
    },
}

Variants

Mito

Fields

manifest_version: u64

flushed_entry_id: u64

topic_latest_entry_id: u64

Metric

Fields

data_manifest_version: u64

data_flushed_entry_id: u64

data_topic_latest_entry_id: u64

metadata_manifest_version: u64

metadata_flushed_entry_id: u64

metadata_topic_latest_entry_id: u64

Implementations

impl LeaderRegionManifestInfo

pub fn from_region_stat(region_stat: &RegionStat) -> LeaderRegionManifestInfo

Generate a LeaderRegionManifestInfo from RegionStat.

pub fn manifest_version(&self) -> u64

Returns the manifest version of the leader region.

pub fn flushed_entry_id(&self) -> u64

Returns the flushed entry id of the leader region.

pub fn prunable_entry_id(&self) -> u64

Returns prunable entry id of the leader region. It is used to determine the entry id that can be pruned in remote wal.

For a mito region, the prunable entry id should max(flushed_entry_id, latest_entry_id_since_flush).

For a metric region, the prunable entry id should min( max(data_flushed_entry_id, data_latest_entry_id_since_flush), max(metadata_flushed_entry_id, metadata_latest_entry_id_since_flush) ).

pub fn is_inactive(&self) -> bool

A region is considered inactive if the flushed entry id is less than the topic’s latest entry id.

The topic_latest_entry_id of a region is updated only when its memtable is empty during a flush. This means that within the range [flushed_entry_id, topic_latest_entry_id], there is no data written to the memtable. Therefore, such a region can be considered inactive.

Trait Implementations

impl Clone for LeaderRegionManifestInfo

fn clone(&self) -> LeaderRegionManifestInfo

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for LeaderRegionManifestInfo

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

Formats the value using the given formatter.

impl Hash for LeaderRegionManifestInfo

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for LeaderRegionManifestInfo

fn eq(&self, other: &LeaderRegionManifestInfo) -> 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 Copy for LeaderRegionManifestInfo

impl Eq for LeaderRegionManifestInfo

impl StructuralPartialEq for LeaderRegionManifestInfo