Enum GrepIndexLifecycle 

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

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

Each status contains only the fields valid for that lifecycle state. Backfilling reports its target and current position. Active reports how far the index has been built. Clients should treat a namespace as searchable only when the index is Active.

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.

Active

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