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
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53

//! Supplies shared readable text for admission diagnostics.
//!
//! ```text
//! registry or controller decision
//!      ├── category ──► RejectionKind
//!      └── detail ────► reason text built from these fragments
//! ```
//!
//! Registry and controller paths reuse these strings when they build event and
//! watched-outcome payloads. The text is diagnostic only and has no stability
//! guarantee. Consumers must branch on typed categories instead of parsing it.

/// Name conflict detected during registry admission.
pub(crate) const ALREADY_EXISTS: &str = "a registered task already uses this name";

/// Static batch item rejected because another item failed admission.
pub(crate) const BATCH_REJECTED: &str = "another item rejected the all-or-nothing batch";

/// Queued controller submission removed before it started.
#[cfg(feature = "controller")]
pub(crate) const REMOVED_FROM_QUEUE: &str = "removed from controller queue before start";

/// Queued submission displaced by a newer replacement.
#[cfg(feature = "controller")]
pub(crate) const SUPERSEDED_BY_REPLACE: &str = "superseded by a newer replacement";

/// Submission rejected during controller shutdown.
#[cfg(feature = "controller")]
pub(crate) const CONTROLLER_SHUTTING_DOWN: &str = "controller is shutting down";

/// Controller admission ended before ownership transfer committed.
#[cfg(feature = "controller")]
pub(crate) const CONTROLLER_ADMISSION_INTERRUPTED: &str =
    "controller admission was interrupted before ownership transfer";

/// Busy-slot rejection under `DropIfRunning`.
#[cfg(feature = "controller")]
pub(crate) const DROP_IF_RUNNING: &str = "slot is busy; DropIfRunning rejected the submission";

/// Controller slot queue capacity rejection.
#[cfg(feature = "controller")]
pub(crate) const QUEUE_FULL: &str = "slot queue is full";

/// Registry membership limit rejection.
pub(crate) const REGISTERED_TASK_LIMIT: &str = "registered task limit reached";

/// Controller slot-count limit rejection.
#[cfg(feature = "controller")]
pub(crate) const CONTROLLER_SLOT_LIMIT: &str = "controller slot limit reached";

/// Aggregate controller pending-work limit rejection.
#[cfg(feature = "controller")]
pub(crate) const CONTROLLER_PENDING_LIMIT: &str = "controller pending limit reached";