Skip to main content

phago_distributed/
lib.rs

1//! # Phago Distributed
2//!
3//! Distributed colony implementation enabling horizontal scaling across
4//! multiple processes with consistent hashing, cross-shard queries,
5//! and fault tolerance.
6
7pub mod bench;
8pub mod coordinator;
9pub mod hashing;
10pub mod query;
11pub mod rpc;
12pub mod runner;
13pub mod shard;
14pub mod types;
15
16pub use bench::{
17    compare_single_vs_distributed, create_bench_cluster, generate_documents, print_scaling_results,
18    run_benchmark, run_quick_benchmark, scaling_benchmark, BenchConfig, BenchResults,
19};
20pub use coordinator::{ClusterStats, Coordinator, RegisteredShard, ShardRegistry, TickBarrier};
21pub use hashing::ConsistentHashRing;
22pub use query::{merge_results, tokenize, DistributedHybridConfig, DistributedQueryEngine};
23pub use runner::{DistributedRunner, DistributedTickResult, RunnerConfig};
24pub use shard::{GhostCacheStats, GhostNodeCache, ShardedColony};
25pub use types::*;