Struct PgClusterStore 

pub struct PgClusterStore { /* private fields */ }

Implementations

impl PgClusterStore

pub fn new(pool: PgPool) -> Self

Trait Implementations

impl Clone for PgClusterStore

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ClusterStore for PgClusterStore

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

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

The cluster a sequence IRI belongs to, or None when it is unclustered.

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

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

The other members of iri’s cluster, excluding iri itself. Empty when iri is unclustered or the sole member. This is the /similar candidate set, which the caller then ranks by PageRank. Order is unspecified.

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

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

Replace every cluster assignment with pairs in one transaction: after it returns the table reflects exactly these (sequence_iri, cluster_id) pairs and nothing prior.

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

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

Every persisted (sequence_iri, cluster_id) assignment, a full scan of the cluster table. The ranked-text path builds its cluster-duplicate map from these, so a non-centroid cluster member is demoted in free-text search. Order is unspecified.

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

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

Assign one sequence to a cluster, upserting: a later assignment for the same IRI overwrites the earlier one. This is the incremental write path a single new sequence takes, sparing the whole-table replace_clusters a full rebuild runs.

fn max_cluster_id<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<ClusterId>, DomainError>> + Send + 'async_trait>>

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

The largest cluster id in use, or None when no sequence is clustered. The incremental assign path opens a fresh cluster at one past this id.