Struct InMemoryTaskStorage 

pub struct InMemoryTaskStorage { /* private fields */ }

In-memory task storage backend.

Uses Arc<RwLock<HashMap>> for concurrent access. Task IDs are UUID v7 for temporal ordering.

Implementations

impl InMemoryTaskStorage

pub fn new() -> Self

Create a new in-memory task storage with default configuration.

pub fn with_config(config: InMemoryTaskConfig) -> Self

Create a new in-memory task storage with custom configuration.

pub fn generate_task_id() -> String

Generate a new task ID using UUID v7 (temporal ordering).

Trait Implementations

impl Clone for InMemoryTaskStorage

fn clone(&self) -> InMemoryTaskStorage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for InMemoryTaskStorage

fn default() -> Self

Returns the “default value” for a type.

impl TaskStorage for InMemoryTaskStorage

fn backend_name(&self) -> &'static str

Human-readable name of the storage backend (e.g., “in-memory”, “sqlite”)

fn create_task<'life0, 'async_trait>( &'life0 self, task: TaskRecord, ) -> Pin<Box<dyn Future<Output = Result<TaskRecord, TaskStorageError>> + Send + 'async_trait>>

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

Create a new task record. Returns the created record.

fn get_task<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<TaskRecord>, TaskStorageError>> + Send + 'async_trait>>

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

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

fn update_task<'life0, 'async_trait>( &'life0 self, task: TaskRecord, ) -> Pin<Box<dyn Future<Output = Result<(), TaskStorageError>> + Send + 'async_trait>>

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

Update an existing task record (full replacement).

fn delete_task<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<bool, TaskStorageError>> + Send + 'async_trait>>

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

Delete a task by ID. Returns true if deleted, false if not found.

fn list_tasks<'life0, 'life1, 'async_trait>( &'life0 self, cursor: Option<&'life1 str>, limit: Option<u32>, ) -> Pin<Box<dyn Future<Output = Result<TaskListPage, TaskStorageError>> + Send + 'async_trait>>

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

List tasks with cursor-based pagination.

fn update_task_status<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, new_status: TaskStatus, status_message: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<TaskRecord, TaskStorageError>> + Send + 'async_trait>>

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

Update a task’s status with state machine validation.

fn store_task_result<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, result: TaskOutcome, ) -> Pin<Box<dyn Future<Output = Result<(), TaskStorageError>> + Send + 'async_trait>>

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

Store the outcome of the underlying request for a task.

fn get_task_result<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<TaskOutcome>, TaskStorageError>> + Send + 'async_trait>>

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

Get the stored outcome for a task.

fn expire_tasks<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, TaskStorageError>> + Send + 'async_trait>>

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

Expire tasks that have exceeded their TTL. Returns IDs of expired tasks.

fn task_count<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<usize, TaskStorageError>> + Send + 'async_trait>>

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

Get the total number of tasks in storage.

fn maintenance<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), TaskStorageError>> + Send + 'async_trait>>

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

Perform periodic maintenance (cleanup, compaction, etc.)

fn list_tasks_for_session<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, cursor: Option<&'life2 str>, limit: Option<u32>, ) -> Pin<Box<dyn Future<Output = Result<TaskListPage, TaskStorageError>> + Send + 'async_trait>>

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

List tasks bound to a specific session, with cursor-based pagination.

fn recover_stuck_tasks<'life0, 'async_trait>( &'life0 self, max_age_ms: u64, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, TaskStorageError>> + Send + 'async_trait>>

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

Mark all non-terminal tasks older than max_age_ms as Failed.