Skip to main content

CompactionPersistence

Trait CompactionPersistence 

Source
pub trait CompactionPersistence: Send + Sync {
    // Required method
    fn after_compaction<'a>(
        &'a self,
        compacted_count: usize,
        summary_content: &'a str,
        summary: &'a str,
    ) -> Pin<Box<dyn Future<Output = (bool, Option<QdrantPersistFuture>)> + Send + 'a>>;
}
Expand description

Persistence completion hook invoked after the in-memory drain/reinsert is finalized.

Returns:

  • persist_failed: whether the synchronous SQLite persistence step failed.
  • qdrant_future: optional 'static future for the off-thread Qdrant write, bubbled back to the caller via CompactionOutcome::Compacted::qdrant_future.

Required Methods§

Source

fn after_compaction<'a>( &'a self, compacted_count: usize, summary_content: &'a str, summary: &'a str, ) -> Pin<Box<dyn Future<Output = (bool, Option<QdrantPersistFuture>)> + Send + 'a>>

Persist the compaction result and return the Qdrant write future.

Implementors§