Struct AccelRepository 

pub struct AccelRepository { /* private fields */ }

Derives, maintains, and queries the accelerator indexes for the Postgres backend.

Implementations

impl AccelRepository

pub fn new(pool: PgPool, triples: TripleRepository) -> Self

pub async fn run( &self, query: &AcceleratedQuery, ) -> Result<AccelSolutions, DomainError>

Answer a recognized query from the graph’s accelerator indexes, which the write path keeps in sync with the committed triples (see Self::refresh_graph).

pub async fn refresh_graph( &self, conn: &mut PgConnection, graph: &str, ) -> Result<(), DomainError>

Rebuild a graph’s accelerator indexes from its triples, inside the caller’s write transaction (atomic with the triple write). The triple scan runs through conn, so it sees the triples the same transaction just wrote; the rebuilt indexes are deleted and reinserted on conn and commit together with the triples. Callers invoke this after every write that changes a graph’s triples.

Trait Implementations

impl Clone for AccelRepository

fn clone(&self) -> AccelRepository

Returns a duplicate of the value.

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

Performs copy-assignment from source.