Struct AsyncGraphRAGCore 

pub struct AsyncGraphRAGCore { /* private fields */ }

Core async GraphRAG processor with concurrency control and monitoring

Implementations

impl AsyncGraphRAGCore

pub async fn new( graph: KnowledgeGraph, config: AsyncConfig, ) -> Result<Self, GraphRAGError>

Creates a new async GraphRAG core instance with configuration

Initializes the knowledge graph, rate limiter, concurrent processor, and metrics tracking system.

Parameters

• graph: Knowledge graph for entity storage
• config: Configuration for async processing behavior

Returns

Configured async GraphRAG instance, or an error if initialization fails

pub async fn process_documents_async( &self, documents: Vec<Document>, ) -> Result<Vec<ProcessingResult>, GraphRAGError>

Processes multiple documents concurrently with rate limiting

Distributes documents across concurrent workers while respecting rate limits and collecting metrics.

Parameters

• documents: Collection of documents to process

Returns

Vector of processing results for all documents, or an error

pub async fn process_single_document_async( &self, document: Document, ) -> Result<ProcessingResult, GraphRAGError>

Processes a single document asynchronously with rate limiting

Applies entity extraction and updates the knowledge graph for one document. Automatically handles rate limiting and metrics collection.

Parameters

• document: Document to process

Returns

Processing result containing extraction statistics, or an error

pub async fn query_async(&self, query: &str) -> Result<String, GraphRAGError>

Executes a query against the knowledge graph asynchronously

Processes a user query by searching the knowledge graph and generating a response using retrieved entities and relationships.

Parameters

• query: User’s query string

Returns

Generated response string, or an error if processing fails

pub fn get_metrics(&self) -> &ProcessingMetrics

Retrieves current processing metrics

Returns

Reference to the metrics collector

pub fn get_config(&self) -> &AsyncConfig

Retrieves current configuration

Returns

Reference to the async processing configuration

pub async fn health_check(&self) -> HealthStatus

Performs health check on all system components

Checks the status of the knowledge graph and rate limiter to determine overall system health.

Returns

Health status summary for all components

pub async fn shutdown(&self) -> Result<(), GraphRAGError>

Shuts down the async processor gracefully

Allows current operations to complete before shutting down. In a full implementation, this cancels pending tasks and cleans up resources.

Returns

Ok on successful shutdown, or an error if cleanup fails

Trait Implementations

impl Debug for AsyncGraphRAGCore

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

Formats the value using the given formatter.