Struct QueryBatcher 

pub struct QueryBatcher { /* private fields */ }

Query batcher

Implementations

impl QueryBatcher

pub fn new(config: BatchConfig) -> Self

Create a new query batcher.

Note: without an executor wired in via QueryBatcher::with_executor, every query execution fails loud. This prevents the batcher from silently returning (and caching) fabricated placeholder results.

pub fn with_executor(self, executor: Arc<dyn BatchQueryExecutor>) -> Self

Attach the backend GraphQL executor used to run each batched query.

pub fn set_executor(&mut self, executor: Arc<dyn BatchQueryExecutor>)

Set the backend GraphQL executor after construction.

pub async fn create_batch(&self) -> String

Create a new batch

pub async fn add_query( &self, batch_id: &str, query: BatchedQuery, ) -> Result<(), String>

Add query to batch

pub async fn execute_batch(&self, batch_id: &str) -> Result<BatchResult, String>

Execute batch

pub fn analyze_batch_dependencies( queries: &[BatchedQuery], ) -> HashMap<String, Vec<String>>

Analyze batch dependencies: returns query_id -> list of query_ids it depends on

pub async fn get_statistics(&self, batch_id: &str) -> Option<BatchStatistics>

Get batch statistics

pub async fn clear_cache(&self)

Clear cache

pub async fn cache_size(&self) -> usize

Get cache size