Struct IndexJobRepository 

pub struct IndexJobRepository<'a> { /* private fields */ }

Implementations

impl<'a> IndexJobRepository<'a>

pub const fn new(conn: &'a Connection) -> Self

pub fn claim_due(&self, now: i64, duration_us: i64) -> Result<Option<IndexJob>>

pub fn renew(&self, job: &IndexJob, now: i64, duration_us: i64) -> Result<bool>

pub fn retry( &self, job: &IndexJob, now: i64, next_attempt_us: i64, error: &str, dead: bool, ) -> Result<bool>

pub fn commit_chunks( &self, job: &IndexJob, now_us: i64, chunks: Option<&[&(ChunkKind, &[f32])]>, source: &str, ) -> Result<bool>

Fenced chunk commit: delete the owner’s old chunk rows, insert the new ones, and advance the durable generation in one transaction. A delete operation passes None as the chunks and removes the rows. Every vector is validated against the profile before it is stored, so a wrong dimension, a NaN, or a non-unit L2 vector fails the job instead of poisoning the snapshot.

pub fn owner_revision( &self, conn: &Connection, owner_kind: OwnerKind, owner_id: i64, ) -> Result<Option<(i64, bool)>>