Struct InMemoryTaskStore 

pub struct InMemoryTaskStore { /* private fields */ }

Thread-safe in-memory TaskStore.

Implementations

impl InMemoryTaskStore

pub fn new() -> Self

Creates an empty in-memory task store.

pub fn from_records( records: impl IntoIterator<Item = OrchestrationTaskRecord>, ) -> Self

Seeds a store from existing records (used by durable replay). Later records for the same task id overwrite earlier ones.

Trait Implementations

impl Clone for InMemoryTaskStore

fn clone(&self) -> InMemoryTaskStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemoryTaskStore

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

Formats the value using the given formatter.

impl Default for InMemoryTaskStore

fn default() -> InMemoryTaskStore

Returns the “default value” for a type.

impl TaskStore for InMemoryTaskStore

fn insert(&self, spec: OrchestrationTaskSpec) -> Result<OrchestrationTaskRecord>

Inserts a pending task record.

fn get(&self, task_id: &TaskId) -> Option<OrchestrationTaskRecord>

Reads one task by id.

fn list(&self, filter: OrchestrationTaskFilter) -> Vec<OrchestrationTaskRecord>

Lists tasks matching filter.

fn mark_running(&self, task_id: &TaskId) -> Result<OrchestrationTaskRecord>

Marks a pending task as running.

fn mark_awaiting(&self, task_id: &TaskId) -> Result<OrchestrationTaskRecord>

Marks a task as awaiting a child task or external input.

fn complete( &self, task_id: &TaskId, result: OrchestrationTaskResult, ) -> Result<OrchestrationTaskRecord>

Completes a live task.

fn fail( &self, task_id: &TaskId, error: String, ) -> Result<OrchestrationTaskRecord>

Fails a live task.

fn timeout( &self, task_id: &TaskId, error: String, ) -> Result<OrchestrationTaskRecord>

Marks a live task as timed out.

fn request_cancel( &self, task_id: &TaskId, ) -> Result<OrchestrationControlOutcome>

Requests cooperative cancellation of a live task.

fn mark_cancelled(&self, task_id: &TaskId) -> Result<OrchestrationTaskRecord>

Marks a cancellation-requested task as cancelled.

fn kill(&self, task_id: &TaskId) -> Result<OrchestrationControlOutcome>

Marks a live task abandoned after requesting cancellation.

fn set_timeout_ms( &self, task_id: &TaskId, timeout_ms: u64, ) -> Result<OrchestrationTaskRecord>

Updates a non-terminal task deadline in milliseconds.

fn history(&self, task_id: &TaskId) -> Vec<OrchestrationTaskRecord>

Returns the lifecycle history (oldest → newest) for one task.