Struct PostgresGraphStore 

pub struct PostgresGraphStore { /* private fields */ }

Implementations

impl PostgresGraphStore

pub fn new(pool: PgPool) -> Self

pub async fn open(database_url: &str) -> Result<Self, Error>

Open a connection pool from a database URL and return a store.

pub async fn migrate(&self) -> Result<(), Error>

Apply the DDL. Safe to call multiple times (uses IF NOT EXISTS).

Trait Implementations

impl GraphStore for PostgresGraphStore

fn upsert_entity<'life0, 'life1, 'async_trait>( &'life0 self, entity: &'life1 Entity, ) -> Pin<Box<dyn Future<Output = Result<(), MemoryError>> + Send + 'async_trait>>

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

Insert or update an entity.

fn upsert_relationship<'life0, 'life1, 'async_trait>( &'life0 self, rel: &'life1 Relationship, ) -> Pin<Box<dyn Future<Output = Result<(), MemoryError>> + Send + 'async_trait>>

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

Insert or update a relationship.

fn invalidate_relationship<'life0, 'async_trait>( &'life0 self, id: RelationshipId, invalid_at: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<(), MemoryError>> + Send + 'async_trait>>

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

Mark a relationship as invalid as of invalid_at.

fn get_entity<'life0, 'async_trait>( &'life0 self, id: EntityId, ) -> Pin<Box<dyn Future<Output = Result<Option<Entity>, MemoryError>> + Send + 'async_trait>>

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

Retrieve a single entity by id. Returns None if not found.

fn neighbors<'life0, 'async_trait>( &'life0 self, id: EntityId, depth: u8, as_of: Option<DateTime<Utc>>, ) -> Pin<Box<dyn Future<Output = Result<SubGraph, MemoryError>> + Send + 'async_trait>>

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

BFS neighbourhood query starting from id.

fn search_entities<'life0, 'life1, 'async_trait>( &'life0 self, query: &'life1 str, top_k: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<Entity>, MemoryError>> + Send + 'async_trait>>

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

Full-text search over entity names.

fn delete_by_scope<'life0, 'life1, 'async_trait>( &'life0 self, scope: &'life1 Scope, ) -> Pin<Box<dyn Future<Output = Result<u64, MemoryError>> + Send + 'async_trait>>

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

Hard-delete all entities and relationships belonging to scope.