Struct TaskRegistry 

pub struct TaskRegistry { /* private fields */ }

In-memory registry of tasks and runs for the scheduler.

This is a lightweight state cache — the event store remains the source of truth. The registry lets the scheduler make fast decisions without querying the store.

Implementations

impl TaskRegistry

pub fn new() -> Self

pub fn add_run(&mut self, run: Run)

Register a run with the scheduler.

pub fn add_task(&mut self, task: Task)

Register a task with the scheduler and its parent run.

pub fn get_task(&self, task_id: &TaskId) -> Option<&Task>

Get a task by ID.

pub fn get_task_mut(&mut self, task_id: &TaskId) -> Option<&mut Task>

Get a mutable task by ID.

pub fn get_run(&self, run_id: &RunId) -> Option<&Run>

Get a run by ID.

pub fn get_run_mut(&mut self, run_id: &RunId) -> Option<&mut Run>

Get a mutable run by ID.

pub fn is_task_complete(&self, task_id: &TaskId) -> bool

Check if a task is complete.

pub fn tasks_for_run(&self, run_id: &RunId) -> Vec<&Task>

Get all tasks for a run.

pub fn track_lease(&mut self, queue_id: Uuid, task_id: TaskId)

Track an active lease.

pub fn remove_lease(&mut self, queue_id: &Uuid) -> Option<TaskId>

Remove a tracked lease.

pub fn active_lease_ids(&self) -> Vec<Uuid>

Get all active lease queue_ids.

pub fn run_ids(&self) -> Vec<RunId>

All registered run IDs.

Trait Implementations

impl Debug for TaskRegistry

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for TaskRegistry

fn default() -> Self

Returns the “default value” for a type.