Struct PgStore 

pub struct PgStore { /* private fields */ }

Implementations

impl PgStore

pub fn connect(url: &str) -> Result<PgStore>

pub fn connect_with(url: &str, mode: PgMode) -> Result<PgStore>

Connect with a write mode (see PgMode).

pub fn mode(&self) -> PgMode

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

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

pub fn append_rollover( &mut self, state: &ExecutionState, events: &[HistoryEvent], rollover: Rollover<'_>, ) -> Result<()>

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

pub fn execution_status(&self, id: &str) -> Result<Option<String>>

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

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

impl PgStore

pub fn insert_schedule(&self, row: &ScheduleRow) -> Result<bool>

pub fn update_schedule(&self, row: &ScheduleRow) -> Result<bool>

pub fn schedule(&self, id: &str) -> Result<Option<ScheduleRow>>

pub fn schedules(&self) -> Result<Vec<ScheduleRow>>

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

pub fn due_schedules(&self, now: u64) -> Result<Vec<ScheduleRow>>

pub fn claim_schedule( &self, id: &str, next_fire_ms: u64, node: &str, now: u64, until: u64, ) -> Result<bool>

pub fn finish_schedule_fire( &self, id: &str, next_fire_ms: u64, node: &str, now: u64, rec: &FireRecord, ) -> Result<bool>

pub fn release_schedule_claims(&self) -> Result<u64>

pub fn release_schedule_claim( &self, id: &str, node: &str, retry_at: u64, error: &str, now: u64, ) -> Result<()>

pub fn record_schedule_trigger( &self, id: &str, execution_id: &str, now: u64, ) -> Result<()>