Struct AsyncGraphRAG 

pub struct AsyncGraphRAG { /* private fields */ }

Async version of the main GraphRAG system

Implementations

impl AsyncGraphRAG

pub async fn new(config: Config) -> Result<Self>

Create a new async GraphRAG instance

pub async fn with_hierarchical_config( config: Config, hierarchical_config: HierarchicalConfig, ) -> Result<Self>

Create with custom hierarchical configuration

pub async fn set_language_model(&mut self, model: Arc<BoxedAsyncLanguageModel>)

Set the async language model

pub async fn initialize(&mut self) -> Result<()>

Initialize the async GraphRAG system

pub async fn add_document(&mut self, document: Document) -> Result<()>

Add a document to the system asynchronously

pub async fn build_document_tree(&mut self, document: &Document) -> Result<()>

Build hierarchical tree for a document asynchronously

pub async fn build_graph(&mut self) -> Result<()>

Build the knowledge graph from documents asynchronously

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

Query the system asynchronously

pub async fn answer_question(&self, question: &str) -> Result<GeneratedAnswer>

Generate an answer to a question using async pipeline

pub async fn hierarchical_query( &self, query: &str, max_results: usize, ) -> Result<Vec<QueryResult>>

Query using hierarchical summarization asynchronously

pub async fn add_documents_batch( &mut self, documents: Vec<Document>, ) -> Result<()>

Batch process multiple documents concurrently

pub async fn answer_questions_batch( &self, questions: &[&str], ) -> Result<Vec<GeneratedAnswer>>

Batch answer multiple questions concurrently

pub async fn get_performance_stats(&self) -> AsyncPerformanceStats

Get performance statistics

pub async fn health_check(&self) -> Result<AsyncHealthStatus>

Health check for all async components

pub async fn save_state_async(&self, output_dir: &str) -> Result<()>

Save state asynchronously