solti-core 0.0.1

Solti SDK supervisor orchestration.
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

//! # solti-core - orchestration layer.
//!
//! Bridges [`solti-model`](solti_model) (public API types) with the [`taskvisor`] runtime.
//! Provides [`SupervisorApi`]: the main entry point for submitting, querying, and cancelling tasks.
//!
//! ## Responsibilities
//!
//! | Component            | What it does                                                 |
//! |----------------------|--------------------------------------------------------------|
//! | [`SupervisorApi`]    | High-level facade: submit, query, cancel, sweep              |
//! | `TaskState`          | In-memory task + run storage (`Arc<RwLock>`)                 |
//! | `StateSubscriber`    | Wires taskvisor events into `TaskState`                      |
//! | `state_sweep`        | Embedded periodic task sweeping expired state (auto-started) |
//! | `map`                | Policy adapter: `solti-model` → `taskvisor` enums            |
//!
//! ## Quick start
//!
//! ```text
//! let api = SupervisorApi::new(sup_cfg, ctrl_cfg, subscribers, router, StateConfig::default()).await?;
//!
//! let task_id = api.submit(&spec).await?;
//! let task    = api.get_task(&task_id);
//! let runs    = api.list_task_runs(&task_id);
//! ```
//!
//! ## Also
//!
//! - [`solti_model::TaskSpec`] input spec submitted via [`SupervisorApi::submit`].
//! - [`taskvisor::Supervisor`] underlying runtime that manages actor lifecycle.
//! - [`solti_runner::RunnerRouter`] picks a runner for each `TaskKind`.

mod error;
pub use error::CoreError;

mod map;

pub mod supervisor;
pub use supervisor::SupervisorApi;

mod system;
pub use system::uptime_seconds;

mod state;
pub use state::StateConfig;