taskvisor 0.8.0

In-process Tokio task supervisor with retries, graceful shutdown, reliable final outcomes, and per-key admission control
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

//! Starts admitted actors and retains force-aborted actors until physical exit.
//!
//! Admission creates a [`ScheduledActor`] and its registry-owned [`ActorHandle`] before it writes the indexes.
//! [`ActorRuntime`] spawns the actor only after that commit. The wrapper sends a reliable result before
//! its completion identity. Removal can claim a ready result without using lifecycle events.
//!
//! ```text
//! admission commit ──► scheduled actor ──► actor wrapper
//!                                              ├── completed ──────► completion identity
//!                                              └── force-aborted ──► attempt reaper
//! terminal commit ───► attempt reaper ───► deferred cleanup
//! ```
//!
//! Force-abort transfers physical ownership to [`AttemptReaper`] before requesting abort.
//! The reaper keeps the label and activity state until the actor output and terminal cleanup
//! bundle meet. This prevents a replacement from overlapping a physically active attempt.
//! Registry shutdown does not wait for a blocked reaper attempt.
//! The host Tokio runtime is the outer lifetime boundary.

mod actor;
mod reaper;
mod runtime;

pub(in crate::core::registry) use actor::{
    ActorHandle, ActorJoinError, ActorRegistration, ScheduledActor,
};
pub(in crate::core::registry) use reaper::AttemptReaper;
#[cfg(test)]
pub(in crate::core::registry) use reaper::AttemptReservation;
pub(in crate::core::registry) use runtime::ActorRuntime;