Struct TaskQueue 

pub struct TaskQueue { /* private fields */ }

A task queue with dependency resolution (topological ordering).

Implementations

impl TaskQueue

pub fn new() -> Self

Create a new empty task queue.

pub fn add(&mut self, task: Task) -> Uuid

Add a task to the queue.

pub fn next_ready(&self) -> Option<&Task>

Get the next ready task (all dependencies resolved, status == Pending). Returns tasks in creation-time order among those that are ready.

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

Get all tasks that are ready to execute.

pub fn mark_running(&mut self, id: Uuid) -> bool

Mark a task as running.

pub fn mark_completed(&mut self, id: Uuid) -> bool

Mark a task as completed.

pub fn mark_failed(&mut self, id: Uuid, reason: String) -> bool

Mark a task as failed.

pub fn mark_needs_review(&mut self, id: Uuid) -> bool

Mark a task as needing human review (HITL).

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

Get a task by ID.

pub fn get_mut(&mut self, id: Uuid) -> Option<&mut Task>

Get a mutable reference to a task.

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

List all tasks.

pub fn pending_count(&self) -> usize

Count of pending tasks.

pub fn completed_count(&self) -> usize

Count of completed tasks.

pub fn total_count(&self) -> usize

Total number of tasks.

pub fn is_done(&self) -> bool

Check if all tasks are in a terminal state (completed, failed, or awaiting review).

pub fn needs_review_count(&self) -> usize

Count of tasks awaiting human review.

pub fn has_cycle(&self) -> bool

Check for cycles in the dependency graph. Returns true if a cycle is detected.

Trait Implementations

impl Default for TaskQueue

fn default() -> Self

Returns the “default value” for a type.