Struct InMemoryStore 

pub struct InMemoryStore { /* private fields */ }

In-memory store backed by Arc<RwLock<..>>.

Thread-safe and cheap to clone. All data is held in memory and lost on drop.

Examples

use ironflow_store::memory::InMemoryStore;

let store = InMemoryStore::new();
let store2 = store.clone(); // cheap Arc clone

Implementations

impl InMemoryStore

pub fn new() -> Self

Create a new empty in-memory store.

Examples

use ironflow_store::memory::InMemoryStore;

let store = InMemoryStore::new();

Trait Implementations

impl ApiKeyStore for InMemoryStore

fn create_api_key(&self, req: NewApiKey) -> StoreFuture<'_, ApiKey>

Create a new API key.

fn find_api_key_by_prefix( &self, prefix: &str, ) -> StoreFuture<'_, Option<ApiKey>>

Find an API key by its prefix (first 8 chars).

fn find_api_key_by_id(&self, id: Uuid) -> StoreFuture<'_, Option<ApiKey>>

Find an API key by ID.

fn list_api_keys_by_user(&self, user_id: Uuid) -> StoreFuture<'_, Vec<ApiKey>>

List all API keys for a user.

fn update_api_key(&self, id: Uuid, update: ApiKeyUpdate) -> StoreFuture<'_, ()>

Update an API key.

fn touch_api_key(&self, id: Uuid) -> StoreFuture<'_, ()>

Record that an API key was used (updates last_used_at).

fn delete_api_key(&self, id: Uuid) -> StoreFuture<'_, ()>

Delete an API key.

impl Clone for InMemoryStore

fn clone(&self) -> InMemoryStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemoryStore

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

Formats the value using the given formatter.

impl Default for InMemoryStore

fn default() -> Self

Returns the “default value” for a type.

impl RunStore for InMemoryStore

fn create_run(&self, req: NewRun) -> StoreFuture<'_, Run>

Create a new run in Pending status.

fn get_run(&self, id: Uuid) -> StoreFuture<'_, Option<Run>>

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

fn list_runs( &self, filter: RunFilter, page: u32, per_page: u32, ) -> StoreFuture<'_, Page<Run>>

List runs matching the given filter, with pagination.

fn update_run_status( &self, id: Uuid, new_status: RunStatus, ) -> StoreFuture<'_, ()>

Update a run’s status with FSM validation.

fn update_run(&self, id: Uuid, update: RunUpdate) -> StoreFuture<'_, ()>

Apply a partial update to a run.

fn pick_next_pending(&self) -> StoreFuture<'_, Option<Run>>

Atomically pick the oldest pending run and transition it to Running.

fn create_step(&self, req: NewStep) -> StoreFuture<'_, Step>

Create a new step for a run.

fn update_step(&self, id: Uuid, update: StepUpdate) -> StoreFuture<'_, ()>

Apply a partial update to a step after execution.

fn list_steps(&self, run_id: Uuid) -> StoreFuture<'_, Vec<Step>>

List all steps for a run, ordered by position ascending.

fn get_stats(&self) -> StoreFuture<'_, RunStats>

Get aggregated statistics across all runs.

fn create_step_dependencies( &self, deps: Vec<NewStepDependency>, ) -> StoreFuture<'_, ()>

Create step dependency edges in batch.

fn list_step_dependencies( &self, run_id: Uuid, ) -> StoreFuture<'_, Vec<StepDependency>>

List all step dependencies for a given run.

fn update_run_returning( &self, id: Uuid, update: RunUpdate, ) -> StoreFuture<'_, Run>

Apply a partial update to a run and return the updated run.

impl UserStore for InMemoryStore

fn create_user(&self, req: NewUser) -> StoreFuture<'_, User>

Create a new user.

fn find_user_by_email(&self, email: &str) -> StoreFuture<'_, Option<User>>

Find a user by email. Returns None if not found.

fn find_user_by_id(&self, id: Uuid) -> StoreFuture<'_, Option<User>>

Find a user by ID. Returns None if not found.