nexus-graph-sdk 1.14.0

Official Rust SDK for Nexus graph database
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70

//! Performance monitoring example for Nexus Rust SDK

use nexus_sdk::*;

#[tokio::main]
async fn main() -> Result<()> {
    let client = NexusClient::new("http://localhost:15474")?;

    tracing::info!("=== Performance Monitoring Example ===\n");

    // Get query statistics
    tracing::info!("1. Getting query statistics...");
    match client.get_query_statistics().await {
        Ok(stats) => {
            tracing::info!("   Total queries: {}", stats.statistics.total_queries);
            tracing::info!("   Successful: {}", stats.statistics.successful_queries);
            tracing::info!("   Failed: {}", stats.statistics.failed_queries);
            tracing::info!(
                "   Average execution time: {}ms",
                stats.statistics.average_execution_time_ms
            );
            tracing::info!("   Slow queries: {}", stats.statistics.slow_query_count);
            tracing::info!("   Patterns tracked: {}", stats.patterns.len());
        }
        Err(e) => tracing::info!("   Error: {}", e),
    }

    // Get slow queries
    tracing::info!("\n2. Getting slow queries...");
    match client.get_slow_queries().await {
        Ok(slow_queries) => {
            tracing::info!("   Found {} slow queries", slow_queries.count);
            for (i, query) in slow_queries.queries.iter().take(5).enumerate() {
                tracing::info!(
                    "   {}. {}ms - {}",
                    i + 1,
                    query.execution_time_ms,
                    query.query
                );
            }
        }
        Err(e) => tracing::info!("   Error: {}", e),
    }

    // Get plan cache statistics
    tracing::info!("\n3. Getting plan cache statistics...");
    match client.get_plan_cache_statistics().await {
        Ok(cache_stats) => {
            tracing::info!("   Cached plans: {}", cache_stats.cached_plans);
            tracing::info!("   Max size: {}", cache_stats.max_size);
            tracing::info!(
                "   Current memory: {} bytes",
                cache_stats.current_memory_bytes
            );
            tracing::info!("   Max memory: {} bytes", cache_stats.max_memory_bytes);
            tracing::info!("   Hit rate: {:.2}%", cache_stats.hit_rate * 100.0);
        }
        Err(e) => tracing::info!("   Error: {}", e),
    }

    // Clear plan cache
    tracing::info!("\n4. Clearing plan cache...");
    match client.clear_plan_cache().await {
        Ok(_) => tracing::info!("   Plan cache cleared successfully"),
        Err(e) => tracing::info!("   Error: {}", e),
    }

    tracing::info!("\n=== Example completed ===");
    Ok(())
}