Crate solti_core 

solti-core - orchestration layer.

Bridges 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

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.

Re-exports

pub use supervisor::SupervisorApi;

Modules

supervisor

High-level API over taskvisor Supervisor used by solti-core.

Structs

StateConfig

Configuration for in-memory state retention and periodic sweep.

Enums

CoreError

Functions

uptime_seconds

Get agent uptime in seconds.