Enum Store 

pub enum Store {
    Sqlite(SqliteStore),
    Postgres(PgStore),
}

The storage backend used by the engine.

Variants

Sqlite(SqliteStore)

Postgres(PgStore)

Implementations

impl Store

pub fn connect(location: &str) -> Result<Store>

Open a backend from a location: a postgres:// / postgresql:// URL, or a SQLite file path.

pub fn open(path: &Path) -> Result<Store>

Open (or create) a SQLite database file.

pub fn in_memory() -> Result<Store>

pub fn backend(&self) -> &'static str

pub fn put_definition(&self, ir: &WorkflowIr, now: u64) -> Result<PutDefinition>

pub fn definitions(&self) -> Result<Vec<WorkflowIr>>

pub fn execution_exists(&self, id: &str) -> Result<bool>

pub fn append( &mut self, state: &ExecutionState, events: &[HistoryEvent], ) -> Result<()>

Atomically append events and update the execution projection.

pub fn history(&self, id: &str) -> Result<Vec<HistoryEvent>>

pub fn active_execution_ids(&self) -> Result<Vec<String>>

Ids of executions that have not reached a terminal status.

pub fn list_executions( &self, status: Option<&str>, workflow: Option<&str>, limit: u32, ) -> Result<Vec<ExecutionSummary>>

pub fn count_by_status(&self) -> Result<Vec<(String, u64)>>

pub fn upsert_worker(&self, w: &WorkerRecord) -> Result<()>

pub fn touch_worker(&self, worker_id: &str, now: u64) -> Result<()>

pub fn workers(&self) -> Result<Vec<WorkerRecord>>