//#region src/core/types.d.ts
/** Lifecycle state of a workflow run. */
type RunStatus = 'pending' | 'running' | 'completed' | 'failed' | 'cancelled';
/** Lifecycle state of a single step within a run. */
type StepStatus = 'pending' | 'running' | 'completed' | 'completed-early' | 'failed';
/** Primitive values that can be persisted to storage. */
type PersistedPrimitive = string | number | boolean | null | undefined | Date;
/** Object whose values are all persistable. */
interface PersistedObject {
  [key: string]: PersistedValue;
}
/**
 * Any value that can be stored as step input/output.
 * Supports plain objects, arrays, strings, numbers, booleans, null, undefined, and Date.
 */
type PersistedValue = PersistedPrimitive | PersistedValue[] | PersistedObject;
/** A persisted workflow run record. */
interface WorkflowRun {
  id: string;
  workflow: string;
  input: PersistedValue;
  idempotencyKey: string | null;
  status: RunStatus;
  createdAt: number;
  updatedAt: number;
}
/** A workflow run that has been claimed by an engine instance for execution. */
interface ClaimedRun extends WorkflowRun {
  leaseId: string;
}
/** The persisted result of a single step execution. */
interface StepResult {
  id: string;
  runId: string;
  name: string;
  status: StepStatus;
  output: PersistedValue;
  error: string | null;
  attempts: number;
  createdAt: number;
  updatedAt: number;
}
/** Configuration for automatic step retries. */
interface RetryConfig {
  /** Maximum number of attempts before the step fails. */
  maxAttempts: number;
  /** Delay growth strategy between retries. */
  backoff: 'linear' | 'exponential';
  /** Base delay in milliseconds (default: 1000). Grows according to the backoff strategy. */
  initialDelayMs?: number;
  /** Timeout per attempt in milliseconds. Overridden by step-level `timeoutMs`. */
  timeoutMs?: number;
}
/** A workflow run together with its step results, returned by `engine.getRunStatus()`. */
interface RunInfo {
  run: WorkflowRun;
  steps: StepResult[];
}
/** Result of `storage.createRun()`. `created` is false when an existing idempotent run was returned. */
interface CreateRunResult {
  run: WorkflowRun;
  created: boolean;
}
/**
 * Interface for durable workflow storage backends.
 *
 * Implement this to use a custom database. Reflow ships with `SQLiteStorage` (for both Bun and Node.js) and `MemoryStorage`.
 */
interface StorageAdapter {
  /** Create tables/indexes. Called once by `engine.start()`. */
  initialize(): Promise<void>;
  /** Persist a new run. Must handle idempotency key conflicts. */
  createRun(run: WorkflowRun): Promise<CreateRunResult>;
  /** Atomically claim the next pending (or stale) run for execution. */
  claimNextRun(workflowNames: readonly string[], staleBefore?: number): Promise<ClaimedRun | null>;
  /** Renew the lease on a running run. Returns false if the lease was lost. */
  heartbeatRun(runId: string, leaseId: string): Promise<boolean>;
  /** Fetch a run by ID, or null if not found. */
  getRun(runId: string): Promise<WorkflowRun | null>;
  /** Fetch all step results for a run, ordered by creation time. */
  getStepResults(runId: string): Promise<StepResult[]>;
  /** Persist a step result. If `leaseId` is provided, fails when the lease is no longer held. */
  saveStepResult(result: StepResult, leaseId?: string): Promise<boolean>;
  /** Update run status without a lease check (used for cancellation). Returns false if the run does not exist. */
  updateRunStatus(runId: string, status: RunStatus): Promise<boolean>;
  /** Update run status only if the caller still holds the lease. */
  updateClaimedRunStatus(runId: string, leaseId: string, status: RunStatus): Promise<boolean>;
  /** Release resources (e.g. close the database connection). */
  close(): void;
}
//#endregion
export { PersistedValue as a, RunStatus as c, StorageAdapter as d, WorkflowRun as f, PersistedPrimitive as i, StepResult as l, CreateRunResult as n, RetryConfig as o, PersistedObject as r, RunInfo as s, ClaimedRun as t, StepStatus as u };
//# sourceMappingURL=types-nm947ViN.d.mts.map