Struct SqliteDurableStore 

pub struct SqliteDurableStore { /* private fields */ }

SQLite-backed durable workflow store.

Implementations

impl SqliteDurableStore

pub fn insert_local_task_and_run( &mut self, input: LocalTaskAndRunInsert<'_>, ) -> Result<()>

pub fn prepare_resume_run( &mut self, run_id: &str, owner_id: &str, now: i64, ) -> Result<(String, u32)>

pub fn start_attempt(&mut self, input: LocalAttemptStart<'_>) -> Result<()>

pub fn complete_attempt_and_task( &mut self, input: LocalAttemptComplete<'_>, ) -> Result<()>

pub fn fail_attempt(&mut self, input: LocalAttemptFail<'_>) -> Result<()>

pub fn cancel_attempt_and_task( &mut self, input: LocalAttemptCancel<'_>, ) -> Result<()>

pub fn claim_or_replay_agent_step( &mut self, input: AgentStepClaimInput<'_>, ) -> Result<AgentStepClaim>

pub fn complete_agent_step( &mut self, input: AgentStepCompleteInput<'_>, ) -> Result<()>

pub fn claim_or_replay_sleep_step( &mut self, input: SleepStepClaimInput<'_>, ) -> Result<SleepStepClaim>

pub fn complete_sleep_step( &mut self, input: SleepStepCompleteInput<'_>, ) -> Result<()>

pub fn fail_agent_step(&mut self, input: AgentStepFailInput<'_>) -> Result<()>

impl SqliteDurableStore

pub fn open(path: impl AsRef<Path>) -> Result<Self>

Open a durable store at path and apply connection pragmas.

pub fn in_memory() -> Result<Self>

Create an in-memory durable store. Useful for tests.

pub fn path(&self) -> Option<&Path>

Return the durable database path when this store was opened from a file.

pub fn connection(&self) -> &Connection

Borrow the underlying SQLite connection.

pub fn connection_mut(&mut self) -> &mut Connection

Mutably borrow the underlying SQLite connection.

pub fn init(&mut self) -> Result<usize>

Initialize the durable schema by applying all available migrations.

pub fn apply_migrations(&mut self, target_version: Option<i64>) -> Result<usize>

Apply migrations up to target_version, or all available migrations when target_version is None.

Returns the number of migrations applied in this call.

pub fn migration_records(&self) -> Result<Vec<MigrationRecord>>

Return applied migrations in ascending id order.

pub fn current_schema_version(&self) -> Result<i64>

Return the latest applied migration id, or 0 when none are applied.