Struct SqliteStore 

pub struct SqliteStore { /* private fields */ }

Implementations

impl SqliteStore

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

pub fn in_memory() -> Result<SqliteStore>

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>>