continuo 0.8.0

Runtime service composition for multi-service Rust applications: typed provider resolution, dependency-ordered lifecycle, reload, runnable tasks, graceful drain, and finalization.
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
43
44
45
46
47

//! # continuo
//!
//! Agnostic service composition primitives for multi-service Rust applications.
//!
//! No application state, no configuration, no HTTP, no TLS, no DB dependency.
//! Pull this crate into any Rust project with multiple services; bring your
//! own state type, implement [`state::SharedState`] and optionally
//! [`registry::ReloadState`] on it, then use [`registry::Registry`] with the
//! [`registry::Provider`] / [`registry::Reloadable`] /
//! [`registry::Runnable`] / [`registry::Finalizable`] traits.
//!
//! The error model (`registry::Error`, `registry::BoxError`, `registry::Result`)
//! lives *inside* the [`registry`] module because it is a registry concern —
//! helper primitives such as [`gate`] have their own semantics and do not
//! share this error type.
#[cfg(feature = "events")]
pub mod events;
#[cfg(feature = "support")]
pub mod gate;
#[cfg(feature = "support")]
pub mod guard;
pub mod registry;
mod runtime;
mod service;
pub mod state;

#[cfg(feature = "events")]
pub use events::{Event, ProcessEventBus, ShutdownInitiated};
#[cfg(feature = "support")]
pub use gate::{Gate, GateDrainOutcome, Permit};
#[cfg(feature = "support")]
pub use guard::{Guard, GuardGroup};
pub use registry::{
    BoxError, Error, Finalizable, FinalizeFailure, FinalizeOutcome, Provider, ProviderOrder,
    Registry, ReloadFailure, ReloadOutcome, ReloadState, Reloadable, Result, Runnable, StdError,
    ValidationFailure, ValidationOutcome,
};
pub use runtime::Runtime;
pub use service::{
    RunContext, ServiceManager, ServiceManagerError, ServiceSnapshot, ServiceStartPolicy,
    ServiceStatus,
};
#[cfg(feature = "events")]
pub use state::HasEvents;
#[cfg(feature = "registry")]
pub use state::HasRegistry;
pub use state::SharedState;