Struct MockDatabase

pub struct MockDatabase {
    pub projections: RwLock<HashMap<String, MockProjection>>,
    pub should_fail_on: Option<String>,
    pub call_count: RwLock<HashMap<String, usize>>,
}

Simple in-memory mock database for testing

Fields

projections: RwLock<HashMap<String, MockProjection>>

should_fail_on: Option<String>

call_count: RwLock<HashMap<String, usize>>

Implementations

impl MockDatabase

pub fn new() -> Self

pub fn with_projection(self, name: &str, nodes: Vec<NodeMetrics>) -> Self

Add a test projection with predefined data

pub fn fail_on(self, operation: &str) -> Self

Configure the mock to fail on a specific operation

pub fn get_call_count(&self, method: &str) -> usize

Get the number of times a method was called

Trait Implementations

impl AnalysisDatabase for MockDatabase

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. If a projection with the same name exists, it should ideally be dropped and recreated.

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 if it exists. Should succeed even if the projection does not exist (making it idempotent).

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.

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. Returns a vector of NodeMetrics containing in-degree, out-degree, and total degree for each node in the graph.

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, degree distribution, and degree statistics.

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.

impl Debug for MockDatabase

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for MockDatabase

fn default() -> Self

Returns the “default value” for a type.