Module async_processing 

Async processing pipelines Async processing utilities for GraphRAG operations

This module provides async processing capabilities including:

• Concurrent document processing
• Rate limiting for API calls
• Performance monitoring and metrics
• Thread pool management
• Task scheduling and coordination

Re-exports

pub use concurrent_pipeline::ConcurrentProcessor;

pub use monitoring::ProcessingMetrics;

pub use rate_limiting::RateLimiter;

Modules

concurrent_pipeline

Concurrent document processing pipeline for parallel GraphRAG operations.

monitoring

Performance monitoring and metrics collection for GraphRAG operations.

rate_limiting

Rate limiting for API call throttling and concurrency control.

Structs

AsyncConfig

Configuration for async processing operations

AsyncGraphRAGCore

Core async GraphRAG processor with concurrency control and monitoring

HealthStatus

Overall health status including all system components

PerformanceTracker

Performance tracker for monitoring async operation timing

ProcessingResult

Result of processing a single document

TaskScheduler

Simple task scheduler for managing async operations

Enums

ComponentStatus

Status of individual system components