Struct PgGraph 

pub struct PgGraph { /* private fields */ }

PostgreSQL-backed GraphBackend over one mutex-guarded connection.

Opening applies the schema and runs pending migrations, matching SqliteGraph::open in the main crate.

Implementations

impl PgGraph

pub fn connect(url: &str) -> Result<Self>

Connect to url (libpq connstring or postgresql:// URL), apply schema and migrations, and return a ready backend.

pub fn connect_config(config: &Config) -> Result<Self>

Connect from a pre-built Config (useful for overriding dbname, e.g. when targeting a throwaway test database).

pub fn connect_tls<T>(url: &str, connector: T) -> Result<Self>

where T: MakeTlsConnect<Socket> + Send + 'static, T::TlsConnect: Send, T::Stream: Send, <T::TlsConnect as TlsConnect<Socket>>::Future: Send,

Connect to url using a caller-supplied TLS connector — for servers requiring sslmode=require or stricter (e.g. RDS with rds.force_ssl). See Self::connect_native_tls for the common case of a system-trust-store native-tls connector.

pub fn connect_config_tls<T>(config: &Config, connector: T) -> Result<Self>

where T: MakeTlsConnect<Socket> + Send + 'static, T::TlsConnect: Send, T::Stream: Send, <T::TlsConnect as TlsConnect<Socket>>::Future: Send,

Connect from a pre-built Config using a caller-supplied TLS connector. Mirrors Self::connect_config but negotiates TLS instead of postgres::NoTls.

pub fn connect_native_tls(url: &str) -> Result<Self>

Connect to url over TLS using native-tls with the system trust store (default settings — full certificate chain and hostname verification against the system trust store, not weakened) — covers the common case of a Postgres server with a publicly-trusted certificate (e.g. RDS sslmode=require). For custom CA bundles or client certificates, build a connector and call Self::connect_tls directly.

pub fn list_nodes(&self, limit: usize) -> Result<Vec<GraphNode>>

List up to limit nodes (uncapped — unlike GraphBackend::query_nodes, which is capped at 200). Used by the migration CLI to enumerate a source backend of arbitrary size.

pub fn list_edges(&self, limit: usize) -> Result<Vec<GraphEdge>>

List up to limit edges (uncapped).

Trait Implementations

impl GraphBackend for PgGraph

fn upsert_node(&self, node: &GraphNode) -> Result<()>

Insert or replace a node.

fn read_node(&self, id: &str) -> Result<Option<GraphNode>>

Read a single node by ID (None if absent).

fn delete_node(&self, id: &str) -> Result<bool>

Delete a node by ID. Returns true if a row was removed.

fn search_nodes(&self, query: &str, limit: usize) -> Result<Vec<GraphNode>>

FTS5 full-text search, ranked by importance DESC.

fn query_nodes( &self, tag: Option<&str>, node_type: Option<&str>, project: Option<&str>, limit: usize, ) -> Result<Vec<GraphNode>>

Dynamic filter by tag / node_type / project.

fn smart_recall( &self, project: Option<&str>, hint: Option<&str>, limit: usize, ) -> Result<Vec<ScoredNode>>

Composite recall — rank nodes by recency, importance, access, FTS, and graph boost. The canonical high-level read path for “what’s relevant”.

fn related_nodes(&self, start_id: &str, depth: usize) -> Result<Vec<String>>

BFS-traverse up to depth hops from start_id, returning related node IDs (excluding the start).

fn append_edge(&self, edge: &GraphEdge) -> Result<()>

Append an edge (duplicates by edge ID are ignored).

fn edges_for_node(&self, node_id: &str) -> Result<Vec<GraphEdge>>

Read edges where the given node is source or target.

fn delete_edge(&self, id: &str) -> Result<bool>

Delete an edge by ID. Returns true if a row was removed.

fn remove_edges_for_node(&self, node_id: &str) -> Result<()>

Remove every edge connected to a node.

fn current_version(&self) -> Result<u32>

Recorded schema version for this backend.

fn migrate(&self) -> Result<u32>

Apply pending migrations up to the backend’s latest schema version. Returns the resulting version.