Struct BuildCheckpoint 

pub struct BuildCheckpoint {
    pub tier: TierKind,
    pub embedder_id: String,
    pub last_offset: i64,
    pub docs_embedded: u64,
    pub conversations_processed: u64,
    pub total_conversations: u64,
    pub db_fingerprint: String,
    pub schema_version: u32,
    pub chunking_version: u32,
    pub saved_at_ms: i64,
    pub last_message_id: Option<i64>,
}

Resumable position for an interrupted semantic build.

Sub-fix 2 for cass#257 added the optional last_message_id cursor. Resume strictly advances past this cursor when present, so that a rerun of an interrupted bounded backfill never re-embeds messages that already made it into the staged index. Pre-#257 binaries wrote checkpoints without the field (it deserializes to None via #[serde(default)]), and modern binaries fall back to the conversation offset when last_message_id is absent.

Fields

tier: TierKind

Which tier is being built.

embedder_id: String

Embedder ID for this build.

last_offset: i64

Last conversation offset processed (for pagination).

docs_embedded: u64

Total documents embedded so far in this build.

conversations_processed: u64

Total conversations processed so far.

total_conversations: u64

Total conversations expected (from DB at start of build).

db_fingerprint: String

DB fingerprint when this build started.

schema_version: u32

Schema version for this build.

chunking_version: u32

Chunking version for this build.

saved_at_ms: i64

Unix timestamp (ms) when this checkpoint was saved.

last_message_id: Option<i64>

Highest canonical message PK embedded in this run so far.

Added in cass#257 (sub-fix 2). None for checkpoints written by pre-#257 binaries; new code falls back to last_offset (conversation-granularity) when this is absent. New code strictly resumes past this cursor when present.

Implementations

impl BuildCheckpoint

pub fn progress_pct(&self) -> u8

Progress as a percentage (0–100).

pub fn is_complete(&self) -> bool

Whether the build is complete (all conversations processed).

pub fn is_valid(&self, current_db_fingerprint: &str) -> bool

Whether this checkpoint is still valid against the current DB and policy.

Trait Implementations

impl Clone for BuildCheckpoint

fn clone(&self) -> BuildCheckpoint

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BuildCheckpoint

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for BuildCheckpoint

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for BuildCheckpoint

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

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for BuildCheckpoint

impl StructuralPartialEq for BuildCheckpoint