net-mesh 0.27.0-beta.1

High-performance, schema-agnostic, backend-agnostic event bus
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42

//! Aggregator daemon — bridges subnet tiers by summarizing
//! detail-fold state and republishing the summaries on channels
//! with broader visibility.
//!
//! Design + rationale: `docs/plans/SCALING_SUBNET_SPEC.md`
//! Phases B + C. The async lifecycle sibling trait
//! ([`LifecycleDaemon`](crate::adapter::net::behavior::lifecycle::LifecycleDaemon))
//! and its generic group primitive
//! ([`LifecycleGroup`](crate::adapter::net::behavior::lifecycle::LifecycleGroup))
//! live under `behavior::lifecycle` — `AggregatorDaemon` is the
//! first consumer.

pub mod config;
pub mod daemon;
pub mod query_client;
pub mod query_service;
pub mod registry;
pub mod registry_client;
pub mod registry_service;
pub mod summarizer;

pub use config::AggregatorConfig;
pub use daemon::{AggregatorDaemon, AggregatorError, AggregatorPublishError};
pub use query_client::{
    FoldQueryClient, FoldQueryClientError, DEFAULT_QUERY_CACHE_TTL, DEFAULT_QUERY_DEADLINE,
};
pub use query_service::{
    FoldQueryError, FoldQueryHandler, FoldQueryOp, FoldQueryRequest, FoldQueryResponse,
    FOLD_QUERY_SERVICE,
};
pub use registry::{
    AggregatorGroupEntry, AggregatorRegistry, AggregatorRegistryError, EntrySnapshot,
};
pub use registry_client::{RegistryClient, RegistryClientError, DEFAULT_REGISTRY_DEADLINE};
pub use registry_service::{
    snapshot_group, RegistryGroupSummary, RegistryHandler, RegistryReadHandler,
    RegistryReplicaSummary, RegistryRequest, RegistryResponse, RegistryRpcError, ScaleFn,
    ScaleRequest, SpawnFn, SpawnRequest, REGISTRY_SERVICE,
};
pub use summarizer::{
    CapabilityFoldSummarizer, ReservationFoldSummarizer, Summarizer, SummaryAnnouncement,
};