Struct InMemoryTaskRegistry 

pub struct InMemoryTaskRegistry { /* private fields */ }

In-memory task registry backed by HashMap + Mutex.

Thread-safe via interior mutability. All tasks and dependencies are stored in memory — lost on drop.

Example

use pe_tasks::InMemoryTaskRegistry;

let registry = InMemoryTaskRegistry::new();

Implementations

impl InMemoryTaskRegistry

pub fn new() -> Self

Create with default lifecycle (transition validation only).

pub fn with_lifecycle(lifecycle: impl TaskLifecycle + 'static) -> Self

Create with a custom lifecycle.

Trait Implementations

impl Default for InMemoryTaskRegistry

fn default() -> Self

Returns the “default value” for a type.

impl TaskRegistry for InMemoryTaskRegistry

fn create<'life0, 'async_trait>( &'life0 self, task: Task, ) -> Pin<Box<dyn Future<Output = Result<Task, PeError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Create a new task. Returns the created task with generated ID.

fn get<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 TaskId, ) -> Pin<Box<dyn Future<Output = Result<Option<Task>, PeError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get a task by ID. Returns None if not found or deleted.

fn update<'life0, 'life1, 'async_trait>( &'life0 self, task: &'life1 Task, ) -> Pin<Box<dyn Future<Output = Result<Task, PeError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Update an existing task. Returns the updated task.

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 TaskId, ) -> Pin<Box<dyn Future<Output = Result<bool, PeError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Soft-delete a task (sets deleted_at). Returns true if found.

fn restore<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 TaskId, ) -> Pin<Box<dyn Future<Output = Result<bool, PeError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Restore a soft-deleted task. Returns true if found in trash.

fn update_status<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 TaskId, status: TaskStatus, result: Option<Value>, error: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<Task, PeError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Update task status (with lifecycle validation).

fn list<'life0, 'life1, 'async_trait>( &'life0 self, filter: &'life1 TaskFilter, ) -> Pin<Box<dyn Future<Output = Result<Vec<Task>, PeError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

List tasks matching a filter.

fn get_subtasks<'life0, 'life1, 'async_trait>( &'life0 self, parent_id: &'life1 TaskId, ) -> Pin<Box<dyn Future<Output = Result<Vec<Task>, PeError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get direct subtasks of a parent.

fn get_tree<'life0, 'life1, 'async_trait>( &'life0 self, root_id: &'life1 TaskId, ) -> Pin<Box<dyn Future<Output = Result<Vec<Task>, PeError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get the full subtask tree (recursive) rooted at a task.

fn add_dependency<'life0, 'async_trait>( &'life0 self, dep: TaskDependency, ) -> Pin<Box<dyn Future<Output = Result<(), PeError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Add a dependency edge. Rejects if it would create a cycle.

fn remove_dependency<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, task_id: &'life1 TaskId, depends_on_id: &'life2 TaskId, ) -> Pin<Box<dyn Future<Output = Result<(), PeError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Remove a dependency edge.

fn get_dependencies<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 TaskId, ) -> Pin<Box<dyn Future<Output = Result<Vec<TaskDependency>, PeError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get all dependencies of a task (what it depends on).

fn get_dependents<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 TaskId, ) -> Pin<Box<dyn Future<Output = Result<Vec<TaskDependency>, PeError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get all dependents of a task (what depends on it).

fn get_ready_tasks<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<Task>, PeError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get all tasks that are ready to execute (no incomplete Blocks deps).