Struct Runtime 

pub struct Runtime {
    pub store: Arc<UnifiedGraphStore>,
    pub watcher: Option<Watcher>,
    pub indexer: IncrementalIndexer,
    pub cache: QueryCache<String, String>,
    pub pool: Option<ConnectionPool>,
}

Runtime combining all phase 2 components.

The Runtime manages file watching, incremental indexing, query caching, and connection pooling for enhanced performance.

Examples

use forgekit_core::runtime::Runtime;
use std::path::PathBuf;

let mut runtime = Runtime::new(PathBuf::from("./project")).await?;

// Start watching for file changes
let _result = runtime.start_with_watching().await?;

// Process events as they arrive
let _stats = runtime.process_events().await?;

Fields

store: Arc<UnifiedGraphStore>

The underlying graph store.

watcher: Option<Watcher>

File watcher for hot-reload.

indexer: IncrementalIndexer

Incremental indexer for processing changes.

cache: QueryCache<String, String>

Query cache layer.

pool: Option<ConnectionPool>

Connection pool (when enabled).

Implementations

impl Runtime

pub async fn new(path: PathBuf) -> Result<Self>

Creates a new runtime instance.

Arguments

• path - Path to the codebase directory

Returns

A Runtime instance or an error.

Errors

Returns an error if the graph store cannot be initialized.

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

Starts file watching on the codebase.

Returns

Ok(()) if watching started successfully, or an error.

Errors

Returns an error if the directory cannot be watched.

pub async fn process_events(&self) -> Result<FlushStats>

Processes any pending file change events.

This method flushes the incremental indexer, applying all queued file changes to the graph store.

Returns

Flush statistics or an error.

Errors

Returns an error if flushing fails.

pub fn cache(&self) -> &QueryCache<String, String>

Returns a reference to the cache.

pub fn pool(&self) -> Option<&ConnectionPool>

Returns a reference to the connection pool (if available).

pub async fn pending_changes(&self) -> usize

Returns the number of pending file changes.

pub fn is_watching(&self) -> bool

Returns true if watching is active.

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

Starts file watching (alias for start_with_watching).

Returns

Ok(()) if watching started successfully, or an error.

Errors

Returns an error if the directory cannot be watched.

pub fn stop_watching(&mut self)

Stops file watching.

This removes the watcher and stops receiving file system events.

pub async fn indexer_stats(&self) -> FlushStats

Returns indexer statistics.

This returns pending changes count as a FlushStats-like structure.

Trait Implementations

impl Clone for Runtime

fn clone(&self) -> Runtime

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Runtime

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

Formats the value using the given formatter.