Struct ParallelDBExecutor 

pub struct ParallelDBExecutor { /* private fields */ }

Parallel Database Executor

Executes multiple database queries concurrently across different databases, collecting results and providing detailed execution statistics.

Example

use rust_logic_graph::multi_db::ParallelDBExecutor;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    let mut executor = ParallelDBExecutor::new();
     
    // Register query closures for different databases
    executor
        .add_query("oms_db", "user_query", Box::new(|| Box::pin(async {
            // Execute query against OMS database
            Ok(serde_json::json!({"user_id": 123, "name": "John"}))
        })))
        .add_query("inventory_db", "stock_query", Box::new(|| Box::pin(async {
            // Execute query against Inventory database
            Ok(serde_json::json!({"product_id": "PROD-001", "qty": 50}))
        })));
     
    let results = executor.execute_all().await?;
    println!("Executed {} queries in parallel", results.len());
    Ok(())
}

Implementations

impl ParallelDBExecutor

pub fn new() -> Self

Create a new parallel database executor

pub fn with_max_concurrent(self, max: usize) -> Self

Set maximum number of concurrent queries

pub fn add_query<F, Fut>( &mut self, database: impl Into<String>, query_id: impl Into<String>, query_fn: F, ) -> &mut Self

where F: FnOnce() -> Fut + Send + 'static, Fut: Future<Output = Result<Value, RustLogicGraphError>> + Send + 'static,

Add a query to execute

Arguments

• database - Database identifier (e.g., “oms_db”, “inventory_db”)
• query_id - Unique query identifier for tracking
• query_fn - Async closure that executes the query

pub async fn execute_all( &mut self, ) -> Result<HashMap<String, QueryResult>, RustLogicGraphError>

Execute all registered queries in parallel

Returns a HashMap with query_id as key and QueryResult as value.

Errors

If any query fails, returns the first encountered error.

Trait Implementations

impl Default for ParallelDBExecutor

fn default() -> Self

Returns the “default value” for a type.