Struct InMemoryBackend 

pub struct InMemoryBackend { /* private fields */ }

In-memory backend that stores snapshots in a HashMap.

This implementation is thread-safe and suitable for testing. For production use, consider implementing the persistence traits for a more durable storage backend (Redis, PostgreSQL, etc.).

Implementations

impl InMemoryBackend

pub fn new() -> Self

Create a new in-memory backend.

Trait Implementations

impl Clone for InMemoryBackend

fn clone(&self) -> InMemoryBackend

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for InMemoryBackend

fn default() -> InMemoryBackend

Returns the “default value” for a type.

impl SignalStore for InMemoryBackend

async fn store_signal( &self, instance_id: &str, kind: SignalKind, request: SignalRequest, ) -> Result<(), BackendError>

Store a signal (cancel or pause) for a workflow instance.

async fn get_signal( &self, instance_id: &str, kind: SignalKind, ) -> Result<Option<SignalRequest>, BackendError>

Get the pending signal of the given kind, if any.

async fn clear_signal( &self, instance_id: &str, kind: SignalKind, ) -> Result<(), BackendError>

Clear the signal of the given kind.

async fn send_event( &self, instance_id: &str, signal_name: &str, payload: Bytes, ) -> Result<(), BackendError>

Send an external event to a workflow instance.

async fn consume_event( &self, instance_id: &str, signal_name: &str, ) -> Result<Option<Bytes>, BackendError>

Consume the oldest buffered event for the given signal name, if any.

async fn check_and_cancel( &self, instance_id: &str, interrupted_at_task: Option<&str>, ) -> Result<bool, BackendError>

Atomically check for cancellation and transition to cancelled state.

async fn check_and_pause(&self, instance_id: &str) -> Result<bool, BackendError>

Atomically check for a pause request and transition to paused state.

async fn unpause( &self, instance_id: &str, ) -> Result<WorkflowSnapshot, BackendError>

Transition a paused workflow back to in-progress and return the updated snapshot.

impl SnapshotStore for InMemoryBackend

async fn save_snapshot( &self, snapshot: &WorkflowSnapshot, ) -> Result<(), BackendError>

Save a workflow snapshot.

async fn save_task_result( &self, instance_id: &str, task_id: &str, output: Bytes, ) -> Result<(), BackendError>

Save a single task result atomically.

async fn load_snapshot( &self, instance_id: &str, ) -> Result<WorkflowSnapshot, BackendError>

Load a workflow snapshot by instance ID.

async fn delete_snapshot(&self, instance_id: &str) -> Result<(), BackendError>

Delete a workflow snapshot.

async fn list_snapshots(&self) -> Result<Vec<String>, BackendError>

List all snapshot instance IDs.

impl TaskClaimStore for InMemoryBackend

async fn claim_task( &self, instance_id: &str, task_id: &str, worker_id: &str, ttl: Option<Duration>, ) -> Result<Option<TaskClaim>, BackendError>

Claim a task for execution by a worker node.

async fn release_task_claim( &self, instance_id: &str, task_id: &str, worker_id: &str, ) -> Result<(), BackendError>

Release a task claim.

async fn extend_task_claim( &self, instance_id: &str, task_id: &str, worker_id: &str, additional_duration: Duration, ) -> Result<(), BackendError>

Extend a task claim’s expiration time.

async fn find_available_tasks( &self, worker_id: &str, limit: usize, ) -> Result<Vec<AvailableTask>, BackendError>

Find available tasks across all workflow instances.