Struct ActiveRun 

pub struct ActiveRun { /* private fields */ }

Cheap to clone (an Arc<Mutex<..>> underneath), matching crate::state::AppState’s own Clone requirement for axum’s State extractor.

Implementations

impl ActiveRun

pub async fn start( &self, run_id: i64, cancel: CtrlCHandle, task: impl Future<Output = ()> + Send + 'static, ) -> Result<(), RunAlreadyActive>

Registers task as a background tune, recording cancel so a later ActiveRun::cancel or ActiveRun::cancel_and_wait call can trigger it. The registration is released automatically after the task returns or panics. If registration is rejected, task is dropped without being spawned, releasing anything it captured (such as Demo concurrency permits).

Multiple tune tasks may be registered at the same time. The only conflict is with an exclusive post-hoc write/revert reservation, which protects direct live-loop mutation.

pub async fn reserve(&self, run_id: i64) -> Result<(), RunAlreadyActive>

Reserves the registry for a short operation the caller awaits directly – currently only a post-hoc PID write or revert (api-post-run-write). Unlike ActiveRun::start, nothing is spawned here: the caller must still call ActiveRun::release itself once its own operation finishes, on every exit path including an error return.

The reservation is accepted only when all tune tasks and any other reservation have finished. This keeps direct live-loop mutation serialized without preventing independent tune tasks from running concurrently.

pub async fn exclusive_id(&self) -> Option<i64>

Returns the run id associated with the current exclusive write/revert reservation, if any. This is a cheap, non-authoritative pre-check; ActiveRun::start still re-checks under the same mutex to close the race with a reservation beginning between this call and the actual task registration.

pub async fn active_run_ids(&self) -> Vec<i64>

Returns the ids of all registered background tune tasks. Cancellation always targets one id at a time.

pub async fn cancel(&self, run_id: i64) -> bool

Triggers cancellation for run_id if that tune is registered, exactly as if Ctrl+C had been pressed against an equivalent CLI-driven run. Returns whether a matching tune or exclusive reservation was found.

pub async fn release(&self, run_id: i64)

Releases the tune registration or exclusive reservation for run_id. Spawned tune registrations release themselves; direct callers use this for exclusive reservations. A no-op if the id is not registered, which is expected when graceful shutdown has already taken the registry’s entries for cancellation and waiting.

pub async fn cancel_and_wait(&self, wait_timeout: Duration)

Triggers cancellation for every registered tune and waits up to wait_timeout for their background tasks to actually finish, including restore attempts. If the timeout elapses, the remaining tasks are abandoned and a loud error names all affected runs.

Trait Implementations

impl Clone for ActiveRun

fn clone(&self) -> ActiveRun

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for ActiveRun

fn default() -> ActiveRun

Returns the “default value” for a type.