Struct ApiRunStore 

pub struct ApiRunStore { /* private fields */ }

RunStore implementation that communicates with the API server via HTTP.

Implementations

impl ApiRunStore

pub fn new(base_url: &str, token: &str) -> Self

Trait Implementations

impl ApiKeyStore for ApiRunStore

fn create_api_key( &self, _req: NewApiKey, ) -> Pin<Box<dyn Future<Output = Result<ApiKey, StoreError>> + Send + '_>>

Create a new API key.

fn find_api_key_by_prefix( &self, _prefix: &str, ) -> Pin<Box<dyn Future<Output = Result<Option<ApiKey>, StoreError>> + Send + '_>>

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

fn find_api_key_by_id( &self, _id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Option<ApiKey>, StoreError>> + Send + '_>>

Find an API key by ID.

fn list_api_keys_by_user( &self, _user_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Vec<ApiKey>, StoreError>> + Send + '_>>

List all API keys for a user.

fn update_api_key( &self, _id: Uuid, _update: ApiKeyUpdate, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + '_>>

Update an API key.

fn touch_api_key( &self, _id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + '_>>

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

fn delete_api_key( &self, _id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + '_>>

Delete an API key.

impl ApprovalDelegationStore for ApiRunStore

fn create_delegation( &self, _req: NewApprovalDelegation, ) -> Pin<Box<dyn Future<Output = Result<ApprovalDelegation, StoreError>> + Send + '_>>

Create a new delegation.

fn find_delegation_by_id( &self, _id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Option<ApprovalDelegation>, StoreError>> + Send + '_>>

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

fn list_active_delegations( &self, _filter: DelegationFilter, _page: u32, _per_page: u32, ) -> Pin<Box<dyn Future<Output = Result<Page<ApprovalDelegation>, StoreError>> + Send + '_>>

List one page of the delegations matching filter, newest first.

fn find_active_delegation( &self, _from_user_id: Uuid, _to_user_id: Uuid, _workflow_name: &str, ) -> Pin<Box<dyn Future<Output = Result<Option<ApprovalDelegation>, StoreError>> + Send + '_>>

Find an active delegation from from_user_id to to_user_id whose workflow filter matches workflow_name. Returns None if there is none.

fn delete_delegation( &self, _id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + '_>>

Revoke a delegation by ID.

impl ArtifactStore for ApiRunStore

fn create_artifact( &self, artifact: NewArtifact, ) -> Pin<Box<dyn Future<Output = Result<Artifact, StoreError>> + Send + '_>>

Record a new artifact.

fn get_artifact( &self, _step_id: Uuid, _name: &str, ) -> Pin<Box<dyn Future<Output = Result<Option<Artifact>, StoreError>> + Send + '_>>

Look up one artifact of a step by name.

fn list_artifacts_for_run( &self, run_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Vec<Artifact>, StoreError>> + Send + '_>>

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

fn find_artifact_for_input( &self, lookup: ArtifactLookup, ) -> Pin<Box<dyn Future<Output = Result<Option<Artifact>, StoreError>> + Send + '_>>

Resolve the artifact a step declared as an input.

fn find_artifact_by_sha256( &self, _sha256: &str, ) -> Pin<Box<dyn Future<Output = Result<Option<Artifact>, StoreError>> + Send + '_>>

Find any artifact with the given SHA-256 hash.

fn count_artifacts_by_storage_key( &self, _storage_key: &str, ) -> Pin<Box<dyn Future<Output = Result<u64, StoreError>> + Send + '_>>

Count artifacts that share the same storage key.

fn list_all_storage_keys( &self, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, StoreError>> + Send + '_>>

List every distinct storage key referenced by at least one artifact.

impl AuditLogStore for ApiRunStore

fn append_audit_log( &self, _entry: NewAuditLogEntry, ) -> Pin<Box<dyn Future<Output = Result<AuditLogEntry, StoreError>> + Send + '_>>

Persist a new audit log entry.

fn list_audit_logs( &self, _filter: AuditLogFilter, _page: u32, _per_page: u32, ) -> Pin<Box<dyn Future<Output = Result<Page<AuditLogEntry>, StoreError>> + Send + '_>>

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

impl Clone for ApiRunStore

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ApiRunStore

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

Formats the value using the given formatter.

impl LogStore for ApiRunStore

fn append_logs( &self, _entries: NewLogEntries, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + '_>>

Persist a batch of log lines.

fn get_logs( &self, _run_id: Uuid, _filter: LogFilter, _cursor: Option<Uuid>, _limit: u32, ) -> Pin<Box<dyn Future<Output = Result<Vec<LogEntry>, StoreError>> + Send + '_>>

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

impl RunStore for ApiRunStore

fn create_run( &self, req: NewRun, ) -> Pin<Box<dyn Future<Output = Result<RunCreation, StoreError>> + Send + '_>>

Create a new run in Pending status.

fn find_run_by_idempotency_key( &self, _key: &str, ) -> Pin<Box<dyn Future<Output = Result<Option<Run>, StoreError>> + Send + '_>>

Look up the run bound to an idempotency key.

fn get_run( &self, id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Option<Run>, StoreError>> + Send + '_>>

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

fn list_runs( &self, _filter: RunFilter, _page: u32, _per_page: u32, ) -> Pin<Box<dyn Future<Output = Result<Page<Run>, StoreError>> + Send + '_>>

List runs matching the given filter, with pagination.

fn update_run_status( &self, id: Uuid, new_status: RunStatus, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + '_>>

Update a run’s status with FSM validation.

fn update_run( &self, id: Uuid, update: RunUpdate, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + '_>>

Apply a partial update to a run.

fn pick_next_pending( &self, lease: Option<LeaseRequest>, ) -> Pin<Box<dyn Future<Output = Result<Option<Run>, StoreError>> + Send + '_>>

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

fn renew_lease( &self, id: Uuid, lease: LeaseRequest, ) -> Pin<Box<dyn Future<Output = Result<DateTime<Utc>, StoreError>> + Send + '_>>

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

fn reap_expired_leases( &self, _limit: u32, ) -> Pin<Box<dyn Future<Output = Result<Vec<ReapedRun>, StoreError>> + Send + '_>>

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

fn claim_due_approval_deadlines( &self, _limit: u32, ) -> Pin<Box<dyn Future<Output = Result<Vec<Step>, StoreError>> + Send + '_>>

Atomically claim approval steps whose SLA deadline has passed.

fn list_purgeable_runs( &self, _policy: &PurgePolicy, _batch_size: u32, ) -> Pin<Box<dyn Future<Output = Result<Vec<PurgeableRun>, StoreError>> + Send + '_>>

List runs eligible for purging according to the given policy.

fn delete_run( &self, _id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, StoreError>> + Send + '_>>

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

fn create_step( &self, req: NewStep, ) -> Pin<Box<dyn Future<Output = Result<Step, StoreError>> + Send + '_>>

Create a new step for a run.

fn update_step( &self, id: Uuid, update: StepUpdate, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + '_>>

Apply a partial update to a step after execution.

fn get_step( &self, _id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Option<Step>, StoreError>> + Send + '_>>

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

fn record_step_approval( &self, _step_id: Uuid, _approval: StepApproval, ) -> Pin<Box<dyn Future<Output = Result<Step, StoreError>> + Send + '_>>

Record a vote on an approval gate and return the updated step.

fn list_steps( &self, run_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Vec<Step>, StoreError>> + Send + '_>>

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

fn get_stats( &self, _filter: RunFilter, ) -> Pin<Box<dyn Future<Output = Result<RunStats, StoreError>> + Send + '_>>

Get aggregated statistics across runs matching the filter.

fn get_stats_history( &self, _filter: StatsHistoryFilter, ) -> Pin<Box<dyn Future<Output = Result<Vec<StatsHistoryBucket>, StoreError>> + Send + '_>>

Get time-bucketed historical statistics for trend charts.

fn create_step_dependencies( &self, deps: Vec<NewStepDependency>, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + '_>>

Create step dependency edges in batch.

fn list_step_dependencies( &self, _run_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Vec<StepDependency>, StoreError>> + Send + '_>>

List all step dependencies for a given run.

fn update_run_returning( &self, id: Uuid, update: RunUpdate, ) -> Pin<Box<dyn Future<Output = Result<Run, StoreError>> + Send + '_>>

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

impl ScheduleStore for ApiRunStore

fn create_schedule( &self, _req: NewSchedule, ) -> Pin<Box<dyn Future<Output = Result<Schedule, StoreError>> + Send + '_>>

Create a new schedule.

fn find_schedule_by_id( &self, _id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Option<Schedule>, StoreError>> + Send + '_>>

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

fn list_schedules( &self, _page: u32, _per_page: u32, ) -> Pin<Box<dyn Future<Output = Result<Page<Schedule>, StoreError>> + Send + '_>>

List schedules with pagination, ordered by created_at descending.

fn update_schedule( &self, _id: Uuid, _update: ScheduleUpdate, ) -> Pin<Box<dyn Future<Output = Result<Schedule, StoreError>> + Send + '_>>

Update a schedule by ID.

fn delete_schedule( &self, _id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + '_>>

Delete a schedule by ID.

fn claim_due_schedules( &self, ) -> Pin<Box<dyn Future<Output = Result<Vec<Schedule>, StoreError>> + Send + '_>>

Atomically claim enabled schedules whose next_trigger_at is in the past, setting last_triggered_at = now and next_trigger_at = None.

impl SecretStore for ApiRunStore

fn get_secret( &self, key: &str, ) -> Pin<Box<dyn Future<Output = Result<Option<Secret>, StoreError>> + Send + '_>>

Retrieve a secret by key.

fn set_secret( &self, _key: &str, _value: &str, ) -> Pin<Box<dyn Future<Output = Result<Secret, StoreError>> + Send + '_>>

Create or update a secret.

fn delete_secret( &self, _key: &str, ) -> Pin<Box<dyn Future<Output = Result<bool, StoreError>> + Send + '_>>

Delete a secret by key.

fn list_secret_keys( &self, _prefix: &str, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, StoreError>> + Send + '_>>

List all secret keys matching a prefix.

fn list_secrets( &self, _prefix: &str, _page: u32, _per_page: u32, ) -> Pin<Box<dyn Future<Output = Result<Page<SecretMetadata>, StoreError>> + Send + '_>>

List secret metadata matching a prefix, with pagination.

fn secret_key_status( &self, ) -> Pin<Box<dyn Future<Output = Result<KeyVersionStatus, StoreError>> + Send + '_>>

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

fn rotate_secrets( &self, _request: RotationRequest, ) -> Pin<Box<dyn Future<Output = Result<RotationBatch, StoreError>> + Send + '_>>

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

impl UserStore for ApiRunStore

fn create_user( &self, _req: NewUser, ) -> Pin<Box<dyn Future<Output = Result<User, StoreError>> + Send + '_>>

Create a new user.

fn find_user_by_email( &self, _email: &str, ) -> Pin<Box<dyn Future<Output = Result<Option<User>, StoreError>> + Send + '_>>

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

fn find_user_by_username( &self, _username: &str, ) -> Pin<Box<dyn Future<Output = Result<Option<User>, StoreError>> + Send + '_>>

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

fn find_user_by_id( &self, _id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Option<User>, StoreError>> + Send + '_>>

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

fn count_users( &self, ) -> Pin<Box<dyn Future<Output = Result<u64, StoreError>> + Send + '_>>

Count all users in the store.

fn list_users( &self, _page: u32, _per_page: u32, ) -> Pin<Box<dyn Future<Output = Result<Page<User>, StoreError>> + Send + '_>>

List users with pagination, ordered by created_at descending.

fn delete_user( &self, _id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + '_>>

Delete a user by ID.

fn update_user_role( &self, _id: Uuid, _is_admin: bool, ) -> Pin<Box<dyn Future<Output = Result<User, StoreError>> + Send + '_>>

Update a user’s admin role.

fn update_user_password( &self, _id: Uuid, _password_hash: String, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + '_>>

Update a user’s password hash.

fn list_user_groups( &self, _user_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, StoreError>> + Send + '_>>

List the groups a user belongs to, sorted by name.

fn set_user_groups( &self, _user_id: Uuid, _groups: Vec<String>, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, StoreError>> + Send + '_>>

Replace the groups a user belongs to.