Enum GrepIndexLifecycle 

pub enum GrepIndexLifecycle {
    Disabled,
    Backfilling {
        target_seq: ChangeSeq,
        cursor_inode_id: Option<InodeId>,
        checkpoint_id: CheckpointId,
    },
    Steady {
        built_through_seq: ChangeSeq,
        next_event_index: u32,
    },
}

Where a namespace’s grep index is in its lifecycle.

The phases carry different facts and never share a field: a backfill reports the sequence it is walking toward and how far the walk got, and only a steady index reports a watermark it has actually built through. A reader that wants “is this searchable, and through what?” asks the steady phase and nothing else.

Variants

Disabled

No index is maintained for this namespace.

Backfilling

The initial walk over a pinned checkpoint is running. Nothing is searchable yet.

Fields

target_seq: ChangeSeq

Namespace sequence the pinned checkpoint captured. Reaching it is what completes the backfill.

cursor_inode_id: Option<InodeId>

Inode the walk resumes strictly after. Absent before the first page.

checkpoint_id: CheckpointId

Checkpoint pinning the state being walked.

Steady

The index follows the change feed. Commits at or below the watermark are searchable.

Fields

built_through_seq: ChangeSeq

Sequence of the commit at the index cursor.

next_event_index: u32

Offset of the next change event within built_through_seq, or zero when the whole commit is represented.

Implementations

impl GrepIndexLifecycle

pub fn is_built_through(&self, target_seq: ChangeSeq) -> bool

Whether every commit at or below target_seq is represented.

A watermark inside a commit (next_event_index above zero) has that commit only partly indexed, so it counts as reached only for earlier sequences.

Trait Implementations

impl Clone for GrepIndexLifecycle

fn clone(&self) -> GrepIndexLifecycle

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GrepIndexLifecycle

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for GrepIndexLifecycle

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for GrepIndexLifecycle

impl PartialEq for GrepIndexLifecycle

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for GrepIndexLifecycle

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 GrepIndexLifecycle