Enum SemanticProgressEvent 

pub enum SemanticProgressEvent {
    SelectionStart,
    SelectionDone,
    PacketReplayStart,
    PacketReplayProgress,
    PacketReplayDone,
    EmbedBatchStart,
    EmbedBatchDone,
    StagingWriteStart,
    StagingWriteDone,
    CheckpointSaveStart,
    CheckpointSaveDone,
    PublishStart,
    PublishDone,
    Error,
    Cancelled,
    Complete,
}

The 16 named transition events. Strings deliberately mirror the phase + sub_phase columns in each emitted record so a jq user can filter on event name OR phase as they prefer.

Variants

SelectionStart

Backfill is about to materialize the message-selection query.

SelectionDone

Selection finished; downstream knows how many candidate rows will be considered for this batch.

PacketReplayStart

Canonical packet replay is about to begin (envelope fetch + per-conversation message materialization + packet build).

PacketReplayProgress

Periodic per-conversation tick during packet replay so a stuck conversation does not look like a stuck model.

PacketReplayDone

Packet replay finished — EmbeddingInputs are ready.

EmbedBatchStart

About to call embedder.embed_batch_sync for a single batch.

EmbedBatchDone

embedder.embed_batch_sync returned for this batch.

StagingWriteStart

About to write the embedded vectors into the staging index.

StagingWriteDone

Staging write returned.

CheckpointSaveStart

About to fsync the updated manifest with this batch’s checkpoint.

CheckpointSaveDone

Manifest fsync returned.

PublishStart

About to atomically rename the staged index into the published index path (only fires on the batch that completes the tier).

PublishDone

Publish rename + fsync done; tier is queryable.

Error

Backfill aborted with an error.

Cancelled

Backfill cancelled cooperatively (signal, idle-yield, etc).

Complete

All work finished cleanly (terminal — emitted exactly once per run, after publish_done or in the no-op path).

Implementations

impl SemanticProgressEvent

pub fn as_str(self) -> &'static str

Stable snake_case string for the event field. Used both as the JSONL event value and (with phase()) as a discriminator in downstream consumers.

pub fn phase(self) -> &'static str

Coarse phase classification, useful to a downstream jq consumer that wants to bucket time across selection / replay / embed / staging / checkpoint / publish without enumerating every event.

pub fn sub_phase(self) -> &'static str

start / done / progress / single (sub_phase=event).

Trait Implementations

impl Clone for SemanticProgressEvent

fn clone(&self) -> SemanticProgressEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for SemanticProgressEvent

impl Debug for SemanticProgressEvent

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

Formats the value using the given formatter.

impl Eq for SemanticProgressEvent

impl PartialEq for SemanticProgressEvent

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

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 SemanticProgressEvent