pub enum LowPriCommand {
WriteConceptsChunk {
chunk: Vec<ConceptUpsert>,
responder: Sender<Result<usize>>,
},
WriteAnalyticsChunk {
chunk: Vec<Annotation>,
responder: Sender<Result<usize>>,
},
UpsertEmbeddingChunk {
model: ModelName,
chunk: Vec<(String, Vec<f32>)>,
responder: Sender<Result<usize>>,
},
BulkImportChunk {
chunk: Vec<EdgeAssertion>,
responder: Sender<Result<usize>>,
},
Archive {
cutoff: String,
archive_path: PathBuf,
responder: Sender<Result<ArchiveReport>>,
},
RebuildFts {
responder: Sender<Result<()>>,
},
ShadowRebuild {
step: ShadowStep,
responder: Sender<Result<ShadowOutcome>>,
},
}Expand description
Commands sent to the Write Actor on the low-priority channel (background work).
Variants§
WriteConceptsChunk
One chunk of concepts — a ledger write, logged and versioned.
WriteAnalyticsChunk
One chunk of derived annotations — off-ledger, no log trigger (D-041).
The pair is named apart deliberately: this variant was WriteAnalyticsChunk
beside a WriteAnnotationsChunk that carried concepts, which is the
crossing D-075 undid.
UpsertEmbeddingChunk
One chunk of vectors for one model (§5.9, D-048).
Low priority: embedding is bulk derived work and must never preempt an interactive assertion.
BulkImportChunk
Archive
RebuildFts
Reconstruct the FTS index from concepts (§5.9, D-036, D-051).
Low priority: it is maintenance on a derivative table, and a search index that is a few seconds stale is a smaller cost than an interactive write that waits behind a full reindex.
ShadowRebuild
One step of a chunked shadow rebuild (§5.8, T1.2, D-082).
Low priority, and one command per step rather than one per rebuild: the
whole value of building beside the live table is that the actor returns
here between chunks. See Database::rebuild_current_chunked.
Auto Trait Implementations§
impl !RefUnwindSafe for LowPriCommand
impl !UnwindSafe for LowPriCommand
impl Freeze for LowPriCommand
impl Send for LowPriCommand
impl Sync for LowPriCommand
impl Unpin for LowPriCommand
impl UnsafeUnpin for LowPriCommand
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T in a tonic::Request