Struct SqliteSketchStore 

pub struct SqliteSketchStore { /* private fields */ }

Implementations

impl SqliteSketchStore

pub fn new(pool: SqlitePool) -> Self

Trait Implementations

impl Clone for SqliteSketchStore

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl SketchStore for SqliteSketchStore

fn put_sketch<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, iri: &'life1 str, signature: &'life2 Signature, bands: &'life3 [u64], ) -> Pin<Box<dyn Future<Output = Result<(), DomainError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Persist iri’s signature and its band buckets, replacing any prior sketch and bands for that IRI so a re-index leaves no stale postings.

fn sketch_of<'life0, 'life1, 'async_trait>( &'life0 self, iri: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Signature>, DomainError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The stored signature for iri, or None when it is unsketched.

fn candidates_by_bands<'life0, 'life1, 'async_trait>( &'life0 self, bands: &'life1 [u64], ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, DomainError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The distinct sequence IRIs sharing at least one of bands, the LSH candidate set for a query with those band hashes. Order is unspecified.

fn all_sketches<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<(String, Signature)>, DomainError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Every stored (sequence_iri, signature) pair, for a full rebuild. Order is unspecified.

fn replace_all_sketches<'life0, 'async_trait>( &'life0 self, entries: Vec<(String, Signature, Vec<u64>)>, ) -> Pin<Box<dyn Future<Output = Result<(), DomainError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Replace every stored sketch and band posting with entries in one transaction: after it returns the index reflects exactly these (sequence_iri, signature, band_hashes) and nothing prior. The search-index rebuild swaps the whole index in through this, the sketch counterpart of ClusterStore::replace_clusters and PageRankStore::replace_all_ranks, so a rebuild never leaves a stale posting behind.