Struct TaskState 

pub struct TaskState { /* private fields */ }

In-memory task state storage.

Also

• StateConfig TTL settings consumed by sweep.
• [StateSubscriber] wires taskvisor events into mutations.
• [state_sweep] builds an embedded periodic sweep task.

Implementations

impl TaskState

pub fn new() -> Self

Create empty task state.

pub fn add_task(&self, id: TaskId, spec: TaskSpec)

Register a new task (called on TaskAdded event).

pub fn unregister_task(&self, id: &TaskId)

Unregister a task from state (called on TaskRemoved event).

Removes the task entry and its slot index, but preserves run history (cleaned later by sweep). Compare with delete_task which removes both.

pub fn delete_task(&self, id: &TaskId) -> bool

Delete a task and its run history. Returns true if the task existed.

This is the API-driven full removal. Compare with unregister_task which preserves runs.

pub fn transition_starting(&self, id: &TaskId) -> Option<u32>

Atomically transition a task to Running.

pub fn transition_finished( &self, id: &TaskId, phase: TaskPhase, error: Option<String>, exit_code: Option<i32>, ) -> bool

Atomically transition a task to a terminal phase and close the active run.

pub fn list_runs(&self, id: &TaskId) -> Vec<TaskRun>

List all runs for a task (oldest first).

pub fn get(&self, id: &TaskId) -> Option<Task>

Get task by ID.

pub fn list_by_slot(&self, slot: &str) -> Vec<Task>

List all tasks in a specific slot.

pub fn list_all(&self) -> Vec<Task>

List all tasks.

pub fn list_by_status(&self, phase: TaskPhase) -> Vec<Task>

List tasks matching a phase filter.

pub fn sweep(&self, config: &StateConfig) -> (usize, usize)

Run a sweep pass.

Two passes under a single write lock:

1. Remove finished runs older than run_ttl.
2. Remove terminal tasks that have no remaining runs and whose updated_at is older than task_ttl.

Returns (runs_removed, tasks_removed) for observability.

pub fn query(&self, q: &TaskQuery) -> TaskPage<Task>

Query tasks with combined filters and pagination.

Filters are applied inside a single read lock. When slot is specified, uses the by_slot index to narrow the scan. total in the result reflects the count after filtering, before pagination.

Trait Implementations

impl Clone for TaskState

fn clone(&self) -> TaskState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for TaskState

fn default() -> Self

Returns the “default value” for a type.