etdl-core 0.1.4

ETDL runtime: BranchMonitor, retry policies, SLA anomaly detection, chaos injection, and telemetry for reliability-aware event-driven services
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
48
49
50

//! Runtime library for code generated from Event Tree Definition Language
//! (ETDL) documents — the reliability-aware, event-driven DSL based on
//! [IEC 62502](https://github.com/usamassem/etdl-specification) event tree and
//! [IEC 61025](https://github.com/usamassem/etdl-specification) fault tree analysis.
//!
//! Generated handlers use these components to record branches and failures
//! against build-time-resolved probabilities, enforce declared retry policies,
//! detect SLA anomalies, and inject chaos in controlled environments.
//!
//! # Components
//!
//! - [`BranchMonitor`] — records taken branches and failures per node with their
//!   declared probabilities
//! - [`RetryPolicy`] / [`BackoffStrategy`] — async retry with exponential or fixed
//!   backoff and a total time budget
//! - [`SlaTracker`] — rolling-window anomaly detection
//!   (`ETDL_SLA_WINDOW`, `ETDL_SLA_THRESHOLD`)
//! - [`ChaosController`] — seeded, node-scoped failure injection, guarded off in
//!   production via `ETDL_ENV`
//! - [`inject_traceparent`] — W3C trace context propagation
//!
//! # Example
//!
//! ```
//! use etdl_core::{BranchMonitor, BackoffStrategy, RetryPolicy};
//! use std::time::Duration;
//!
//! let mut monitor = BranchMonitor::new("InventoryCheckBarrier");
//! monitor.record_branch("SUCCESS", 0.95);
//!
//! let retry = RetryPolicy {
//!     max_attempts: 3,
//!     backoff_ms: 250,
//!     strategy: BackoffStrategy::Exponential,
//! };
//! ```

pub mod chaos;
pub mod monitor;
pub mod retry;
pub mod sla;
pub mod telemetry;

pub use monitor::BranchMonitor;
pub use retry::{BackoffStrategy, RetryPolicy};
pub use sla::SlaTracker;
pub use chaos::ChaosController;
pub use telemetry::{
    inject_traceparent, Error as WorkflowError,
};