Crate phago_distributed 

Phago Distributed

Distributed colony implementation enabling horizontal scaling across multiple processes with consistent hashing, cross-shard queries, and fault tolerance.

Re-exports

pub use bench::compare_single_vs_distributed;

pub use bench::create_bench_cluster;

pub use bench::generate_documents;

pub use bench::print_scaling_results;

pub use bench::run_benchmark;

pub use bench::run_quick_benchmark;

pub use bench::scaling_benchmark;

pub use bench::BenchConfig;

pub use bench::BenchResults;

pub use coordinator::ClusterStats;

pub use coordinator::Coordinator;

pub use coordinator::RegisteredShard;

pub use coordinator::ShardRegistry;

pub use coordinator::TickBarrier;

pub use hashing::ConsistentHashRing;

pub use query::merge_results;

pub use query::tokenize;

pub use query::DistributedHybridConfig;

pub use query::DistributedQueryEngine;

pub use runner::DistributedRunner;

pub use runner::DistributedTickResult;

pub use runner::RunnerConfig;

pub use shard::GhostCacheStats;

pub use shard::GhostNodeCache;

pub use shard::ShardedColony;

pub use types::*;

Modules

bench

Benchmarking utilities for distributed colony.

coordinator

Coordinator for distributed colony orchestration.

hashing

Consistent hashing for document-to-shard routing.

query

Distributed query implementation.

rpc

RPC protocol definitions using tarpc.

runner

Async distributed tick runner.

shard

Sharded colony implementation.

types

Core types for distributed colony coordination.