Struct Neo4jAnalysisClient

pub struct Neo4jAnalysisClient { /* private fields */ }

A client for interacting with Neo4j, tailored for eRPC analysis tasks.

Implementations

impl Neo4jAnalysisClient

pub async fn new(config: &Neo4jConfig) -> Result<Self, AnalysisError>

Creates a new Neo4jAnalysisClient instance.

Establishes a connection to the Neo4j database using the provided configuration.

Arguments

• config - A reference to Neo4jConfig containing the URI, username, and password.

Errors

Returns AnalysisError::ConnectionFailed if the connection cannot be established.

Trait Implementations

impl AnalysisDatabase for Neo4jAnalysisClient

fn create_graph_projection<'life0, 'life1, 'async_trait>( &'life0 self, params: &'life1 GraphProjectionParams, ) -> Pin<Box<dyn Future<Output = Result<(), AnalysisError>> + Send + 'async_trait>>

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

Creates or recreates a GDS graph projection in Neo4j.

This implementation first attempts to delete an existing projection with the same name to ensure idempotency, then creates a new one based on the provided parameters.

Arguments

• params - A reference to GraphProjectionParams specifying the projection name, node label, relationship types, and properties to project.

Errors

Returns AnalysisError if any step (deletion of old projection, creation of new projection) fails. This includes driver errors, query failures, or issues with GDS procedures

fn delete_graph_projection<'life0, 'life1, 'async_trait>( &'life0 self, projection_name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), AnalysisError>> + Send + 'async_trait>>

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

Deletes an existing GDS graph projection from Neo4j if it exists.

This method first checks if the projection exists using gds.graph.exists (via check_graph_projection_exists). If it does, gds.graph.drop is called.

The operation is idempotent and will succeed even if the projection does not initially exist.

Arguments

• projection_name - The name of the GDS graph projection to delete.

Errors

Returns AnalysisError if checking for existence or executing the drop query fails

fn check_graph_projection_exists<'life0, 'life1, 'async_trait>( &'life0 self, projection_name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<bool, AnalysisError>> + Send + 'async_trait>>

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

Checks if a GDS graph projection with the given name exists in Neo4j.

This method calls the gds.graph.exists procedure.

Arguments

• projection_name - The name of the GDS graph projection to check.

Returns

Ok(true) if the projection exists, Ok(false) otherwise.

Errors

Returns AnalysisError if the query to gds.graph.exists fails or the result cannot be parsed correctly.

fn calculate_graph_metrics<'life0, 'life1, 'async_trait>( &'life0 self, projection_name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<GraphMetrics, AnalysisError>> + Send + 'async_trait>>

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

Calculates comprehensive graph metrics for a given GDS projection including basic counts (node count, relationship count), degree distribution, and degree statistics.

fn calculate_node_degrees<'life0, 'life1, 'async_trait>( &'life0 self, projection_name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<NodeMetrics>, AnalysisError>> + Send + 'async_trait>>

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

Calculates node-level degree metrics for all nodes in a given GDS projection. Uses both Neo4j GDS library for total degree and direct Cypher for in/out degree calculation.

fn calculate_weakly_connected_components<'life0, 'life1, 'async_trait>( &'life0 self, projection_name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<ComponentAnalysisResult, AnalysisError>> + Send + 'async_trait>>

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

Calculates weakly connected components using Neo4j GDS WCC algorithm. Returns analysis results containing components, sizes, and statistics.

fn calculate_strongly_connected_components<'life0, 'life1, 'async_trait>( &'life0 self, projection_name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<ComponentAnalysisResult, AnalysisError>> + Send + 'async_trait>>

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

Calculates strongly connected components using Neo4j GDS SCC algorithm. Returns analysis results containing components, sizes, and statistics.