id_effect 0.4.0

Effect<A, E, R> (sync + async), capability DI, pipe — interpreter-style, no bundled executor
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

//! Compute Fabric
#![allow(missing_docs)]
// stratum 5.5 — expand rustdoc in book pass — resource-aware execution substrate (Stratum 5.5).
//!
//! Every effect passes through Fabric at the runtime boundary. The supervisor compares live
//! telemetry against [`ResourcePolicy`] and adjusts admission, pool sizing, and placement.

mod adaptive;
mod admission;
mod cluster;
mod dispatch;
mod fabric;
mod fiber_pool;
mod policy;
mod rayon_pool;
mod spread;
mod supervisor;
mod telemetry;

pub use adaptive::{
  AdaptiveContext, current_adaptive_context, ensure_run_context, install_fabric,
  refresh_adaptive_context,
};
pub use admission::AdmissionController;
pub use cluster::{ClusterResourcePolicy, FabricJobSpec, PlacementMode};
pub(crate) use dispatch::parallel_if_profitable;
pub use fabric::ComputeFabric;
pub use fiber_pool::FiberPool;
pub use policy::{MetricMode, MetricPolicy, RebalanceStrategy, ResourcePolicy, WorkProfile};
pub use rayon_pool::{configure_rayon_threads, install_parallel};
pub use spread::CpuSpreadBucket;
pub use supervisor::ComputeSupervisor;
pub use telemetry::{MockTelemetry, SysinfoTelemetry, TelemetryEngine, TelemetrySnapshot};