taskvisor 0.1.2

Event-driven task orchestration with restart, backoff, and user-defined subscribers
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

//! # Subscriber infrastructure.
//!
//! [`Subscribe`] is the trait you implement to consume runtime events.
//! The supervisor delivers events to each subscriber via a dedicated bounded queue and worker task.
//!
//! See [`Subscribe`] for the full contract.
//!
//! ## Overview
//!
//! ```text
//! Bus (broadcast) ──► Supervisor::subscriber_listener
//!                         ├─► AliveTracker::update()
//!                         └─► SubscriberSet::emit_arc()
//!                                   ├─► [queue for S1] ──► worker ──► S1.on_event()
//!                                   ├─► [queue for S2] ──► worker ──► S2.on_event()
//!                                   └─► ...
//! ```
//!
//! See [`Event`](crate::Event) and [`EventKind`](crate::EventKind) for the event structure.

mod subscriber;
mod subscriber_set;

#[cfg(feature = "logging")]
mod embedded;

pub use subscriber::Subscribe;
pub(crate) use subscriber_set::SubscriberSet;

#[cfg(feature = "logging")]
pub use embedded::LogWriter;