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. Implements Store so a single Arc<InMemoryStore> covers runs, users, API keys, and secrets.

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();

pub async fn set_run_created_at(&self, run_id: Uuid, created_at: DateTime<Utc>)

Override a run’s created_at timestamp for testing retention policies.

Examples

use chrono::{Utc, TimeDelta};
use ironflow_store::memory::InMemoryStore;
use uuid::Uuid;

let old = Utc::now() - TimeDelta::days(100);
store.set_run_created_at(run_id, old).await;

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 ArtifactStore for InMemoryStore

fn create_artifact(&self, artifact: NewArtifact) -> StoreFuture<'_, Artifact>

Record a new artifact.

fn get_artifact( &self, step_id: Uuid, name: &str, ) -> StoreFuture<'_, Option<Artifact>>

Look up one artifact of a step by name.

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

List every artifact of a run, across all steps and attempts.

fn find_artifact_for_input( &self, lookup: ArtifactLookup, ) -> StoreFuture<'_, Option<Artifact>>

Resolve the artifact a step declared as an input.

impl AuditLogStore for InMemoryStore

fn append_audit_log( &self, entry: NewAuditLogEntry, ) -> StoreFuture<'_, AuditLogEntry>

Persist a new audit log entry.

fn list_audit_logs( &self, filter: AuditLogFilter, page: u32, per_page: u32, ) -> StoreFuture<'_, Page<AuditLogEntry>>

List audit log entries matching the given filter, with pagination.

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 LogStore for InMemoryStore

fn append_logs(&self, entries: NewLogEntries) -> StoreFuture<'_, ()>

Persist a batch of log lines.

fn get_logs( &self, run_id: Uuid, filter: LogFilter, cursor: Option<Uuid>, limit: u32, ) -> StoreFuture<'_, Vec<LogEntry>>

Retrieve log entries for a run with cursor-based pagination.

impl RunStore for InMemoryStore

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

Create a new run in Pending status.

fn find_run_by_idempotency_key(&self, key: &str) -> StoreFuture<'_, Option<Run>>

Look up the run bound to an idempotency key.

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, lease: Option<LeaseRequest>, ) -> StoreFuture<'_, Option<Run>>

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

fn renew_lease( &self, id: Uuid, lease: LeaseRequest, ) -> StoreFuture<'_, DateTime<Utc>>

Extend the worker lease on a run and return the new expiry.

fn reap_expired_leases(&self, limit: u32) -> StoreFuture<'_, Vec<ReapedRun>>

Recover runs whose worker lease expired, at most limit per call.

fn list_purgeable_runs( &self, policy: &PurgePolicy, batch_size: u32, ) -> StoreFuture<'_, Vec<PurgeableRun>>

List runs eligible for purging according to the given policy.

fn delete_run(&self, id: Uuid) -> StoreFuture<'_, Vec<String>>

Delete a run and all its associated data (steps, step dependencies).

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 get_step(&self, id: Uuid) -> StoreFuture<'_, Option<Step>>

Get a single step by ID. Returns None if not found.

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

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

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

Get aggregated statistics across runs matching the filter.

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 SecretStore for InMemoryStore

fn get_secret(&self, key: &str) -> StoreFuture<'_, Option<Secret>>

Retrieve a secret by key.

fn set_secret(&self, key: &str, value: &str) -> StoreFuture<'_, Secret>

Create or update a secret.

fn delete_secret(&self, key: &str) -> StoreFuture<'_, bool>

Delete a secret by key.

fn list_secret_keys(&self, prefix: &str) -> StoreFuture<'_, Vec<String>>

List all secret keys matching a prefix.

fn list_secrets( &self, prefix: &str, page: u32, per_page: u32, ) -> StoreFuture<'_, Page<SecretMetadata>>

List secret metadata matching a prefix, with pagination.

fn secret_key_status(&self) -> StoreFuture<'_, KeyVersionStatus>

Report how the configured key ring lines up with the stored secrets.

fn rotate_secrets( &self, request: RotationRequest, ) -> StoreFuture<'_, RotationBatch>

Re-encrypt one batch of secrets towards the target key version.

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.

fn count_users(&self) -> StoreFuture<'_, u64>

Count all users in the store.

fn list_users(&self, page: u32, per_page: u32) -> StoreFuture<'_, Page<User>>

List users with pagination, ordered by created_at descending.

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

Delete a user by ID.

fn update_user_role(&self, id: Uuid, is_admin: bool) -> StoreFuture<'_, User>

Update a user’s admin role.