Enum SegmentManifestState 

pub enum SegmentManifestState {
    Active,
    UnderConstruction,
    Optimizing {
        holder: String,
        lease_until: u64,
    },
    Retiring,
}

State of a segment in the manifest.

The shard itself only writes Active; the in-progress states come from out-of-process rewriters (the serverless indexer). A data-carrying state serializes as a tagged object, which readers predating it cannot parse — write it only once every reader understands it.

Variants

Active

Live segment, part of the shard’s data and safe to read.

UnderConstruction

Reserved for future use: a segment being built that is not yet ready to read.

Optimizing

Being rebuilt by an out-of-process optimizer; still live and readable. The claim is a lease: past lease_until another optimizer may take the segment over.

Fields

holder: String

Identity of the optimizer run holding the claim (e.g. pod name).

lease_until: u64

Unix seconds after which the claim is stale.

Retiring

A superseded segment that is still readable but pending removal.

Implementations

impl SegmentManifestState

pub fn is_usable(&self) -> bool

Whether a reader may serve the segment: live (Active), or Optimizing — being rebuilt out-of-process, but live (and still receiving deletes) until the swap.

pub fn is_optimizer_mark(&self) -> bool

Whether the state is a mark owned by an out-of-process optimizer — a rebuild claim (Optimizing) or a pending removal (Retiring) — rather than something derivable from the segment holder. A holder rebuild must not erase such marks (see SegmentsManifest::preserving).

Trait Implementations

impl Clone for SegmentManifestState

fn clone(&self) -> SegmentManifestState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SegmentManifestState

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SegmentManifestState

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for SegmentManifestState

impl PartialEq for SegmentManifestState

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for SegmentManifestState

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for SegmentManifestState