Struct PostgresPersistence 

pub struct PostgresPersistence { /* private fields */ }

PostgreSQL-backed persistence implementation.

Implementations

impl PostgresPersistence

pub fn new(pool: PgPool) -> Self

Create a new Postgres-backed persistence implementation.

Trait Implementations

impl Clone for PostgresPersistence

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Persistence for PostgresPersistence

fn register_instance<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, instance_id: &'life1 str, tenant_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn get_instance<'life0, 'life1, 'async_trait>( &'life0 self, instance_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<InstanceRecord>, CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn update_instance_status<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, instance_id: &'life1 str, status: &'life2 str, started_at: Option<DateTime<Utc>>, ) -> Pin<Box<dyn Future<Output = Result<(), CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn update_instance_checkpoint<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, instance_id: &'life1 str, checkpoint_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn complete_instance<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, instance_id: &'life1 str, output: Option<&'life2 [u8]>, error: Option<&'life3 str>, ) -> Pin<Box<dyn Future<Output = Result<(), CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

fn save_checkpoint<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, instance_id: &'life1 str, checkpoint_id: &'life2 str, state: &'life3 [u8], ) -> Pin<Box<dyn Future<Output = Result<(), CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

fn load_checkpoint<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, instance_id: &'life1 str, checkpoint_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<CheckpointRecord>, CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn list_checkpoints<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, instance_id: &'life1 str, checkpoint_id: Option<&'life2 str>, limit: i64, offset: i64, created_after: Option<DateTime<Utc>>, created_before: Option<DateTime<Utc>>, ) -> Pin<Box<dyn Future<Output = Result<Vec<CheckpointRecord>, CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn count_checkpoints<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, instance_id: &'life1 str, checkpoint_id: Option<&'life2 str>, created_after: Option<DateTime<Utc>>, created_before: Option<DateTime<Utc>>, ) -> Pin<Box<dyn Future<Output = Result<i64, CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn insert_event<'life0, 'life1, 'async_trait>( &'life0 self, event: &'life1 EventRecord, ) -> Pin<Box<dyn Future<Output = Result<(), CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn insert_signal<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, instance_id: &'life1 str, signal_type: &'life2 str, payload: &'life3 [u8], ) -> Pin<Box<dyn Future<Output = Result<(), CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

fn get_pending_signal<'life0, 'life1, 'async_trait>( &'life0 self, instance_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<SignalRecord>, CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn acknowledge_signal<'life0, 'life1, 'async_trait>( &'life0 self, instance_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn insert_custom_signal<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, instance_id: &'life1 str, checkpoint_id: &'life2 str, payload: &'life3 [u8], ) -> Pin<Box<dyn Future<Output = Result<(), CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

fn take_pending_custom_signal<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, instance_id: &'life1 str, checkpoint_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<CustomSignalRecord>, CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn save_retry_attempt<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, instance_id: &'life1 str, checkpoint_id: &'life2 str, attempt: i32, error_message: Option<&'life3 str>, ) -> Pin<Box<dyn Future<Output = Result<(), CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

fn list_instances<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant_id: Option<&'life1 str>, status: Option<&'life2 str>, limit: i64, offset: i64, ) -> Pin<Box<dyn Future<Output = Result<Vec<InstanceRecord>, CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn health_check_db<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<bool, CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn count_active_instances<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<i64, CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn set_instance_sleep<'life0, 'life1, 'async_trait>( &'life0 self, instance_id: &'life1 str, sleep_until: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<(), CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Set the sleep_until timestamp for an instance.

fn clear_instance_sleep<'life0, 'life1, 'async_trait>( &'life0 self, instance_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Clear the sleep_until timestamp for an instance.

fn get_sleeping_instances_due<'life0, 'async_trait>( &'life0 self, limit: i64, ) -> Pin<Box<dyn Future<Output = Result<Vec<InstanceRecord>, CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get instances that are due to wake (sleep_until <= now).

fn list_events<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, instance_id: &'life1 str, filter: &'life2 ListEventsFilter, limit: i64, offset: i64, ) -> Pin<Box<dyn Future<Output = Result<Vec<EventRecord>, CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

List events for an instance with filtering and pagination.

fn count_events<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, instance_id: &'life1 str, filter: &'life2 ListEventsFilter, ) -> Pin<Box<dyn Future<Output = Result<i64, CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Count events for an instance with filtering.

fn list_step_summaries<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, instance_id: &'life1 str, filter: &'life2 ListStepSummariesFilter, limit: i64, offset: i64, ) -> Pin<Box<dyn Future<Output = Result<Vec<StepSummaryRecord>, CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

List step summaries for an instance, pairing step_debug_start and step_debug_end events.

fn count_step_summaries<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, instance_id: &'life1 str, filter: &'life2 ListStepSummariesFilter, ) -> Pin<Box<dyn Future<Output = Result<i64, CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Count step summaries for an instance with filtering.

fn complete_instance_extended<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'life6, 'async_trait>( &'life0 self, instance_id: &'life1 str, status: &'life2 str, output: Option<&'life3 [u8]>, error: Option<&'life4 str>, stderr: Option<&'life5 str>, checkpoint_id: Option<&'life6 str>, ) -> Pin<Box<dyn Future<Output = Result<(), CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait, 'life6: 'async_trait,

Complete an instance with extended fields (stderr, checkpoint).

fn complete_instance_if_running<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'life6, 'async_trait>( &'life0 self, instance_id: &'life1 str, status: &'life2 str, output: Option<&'life3 [u8]>, error: Option<&'life4 str>, stderr: Option<&'life5 str>, checkpoint_id: Option<&'life6 str>, ) -> Pin<Box<dyn Future<Output = Result<bool, CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait, 'life6: 'async_trait,

Complete an instance only if its current status is ‘running’.

fn complete_instance_with_termination<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'life6, 'life7, 'async_trait>( &'life0 self, instance_id: &'life1 str, status: &'life2 str, termination_reason: Option<&'life3 str>, exit_code: Option<i32>, output: Option<&'life4 [u8]>, error: Option<&'life5 str>, stderr: Option<&'life6 str>, checkpoint_id: Option<&'life7 str>, ) -> Pin<Box<dyn Future<Output = Result<(), CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait, 'life6: 'async_trait, 'life7: 'async_trait,

Complete an instance with termination tracking metadata.

fn complete_instance_with_termination_if_running<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'life6, 'life7, 'async_trait>( &'life0 self, instance_id: &'life1 str, status: &'life2 str, termination_reason: Option<&'life3 str>, exit_code: Option<i32>, output: Option<&'life4 [u8]>, error: Option<&'life5 str>, stderr: Option<&'life6 str>, checkpoint_id: Option<&'life7 str>, ) -> Pin<Box<dyn Future<Output = Result<bool, CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait, 'life6: 'async_trait, 'life7: 'async_trait,

Complete an instance with termination tracking, only if status is ‘running’.

fn update_instance_metrics<'life0, 'life1, 'async_trait>( &'life0 self, instance_id: &'life1 str, memory_peak_bytes: Option<u64>, cpu_usage_usec: Option<u64>, ) -> Pin<Box<dyn Future<Output = Result<(), CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Update execution metrics for an instance (memory, CPU usage).

fn update_instance_stderr<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, instance_id: &'life1 str, stderr: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Update instance stderr output.

fn store_instance_input<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, instance_id: &'life1 str, input: &'life2 [u8], ) -> Pin<Box<dyn Future<Output = Result<(), CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Store input data for an instance.

fn get_terminal_instances_older_than<'life0, 'async_trait>( &'life0 self, older_than: DateTime<Utc>, limit: i64, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get terminal instance IDs older than the specified timestamp.

fn delete_instances_batch<'life0, 'life1, 'async_trait>( &'life0 self, instance_ids: &'life1 [String], ) -> Pin<Box<dyn Future<Output = Result<u64, CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Delete instances by their IDs.

fn record_error<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'life6, 'life7, 'life8, 'life9, 'async_trait>( &'life0 self, _instance_id: &'life1 str, _checkpoint_id: Option<&'life2 str>, _step_id: Option<&'life3 str>, _error_code: &'life4 str, _error_message: &'life5 str, _category: &'life6 str, _severity: &'life7 str, _retry_hint: Option<&'life8 str>, _retry_after_ms: Option<i64>, _attributes: Option<&'life9 Value>, _cause_error_id: Option<i64>, ) -> Pin<Box<dyn Future<Output = Result<i64, CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait, 'life6: 'async_trait, 'life7: 'async_trait, 'life8: 'async_trait, 'life9: 'async_trait,

Record a structured error in the error history table.

fn get_last_error<'life0, 'life1, 'async_trait>( &'life0 self, _instance_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<ErrorHistoryRecord>, CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get the most recent error for an instance.

fn list_errors<'life0, 'life1, 'async_trait>( &'life0 self, _instance_id: &'life1 str, _limit: i64, _offset: i64, ) -> Pin<Box<dyn Future<Output = Result<Vec<ErrorHistoryRecord>, CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

List errors for an instance.

fn register_compensatable_checkpoint<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, _instance_id: &'life1 str, _checkpoint_id: &'life2 str, _compensation_step_id: &'life3 str, _compensation_data: Option<&'life4 [u8]>, _compensation_order: i32, ) -> Pin<Box<dyn Future<Output = Result<(), CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Mark a checkpoint as compensatable (for saga pattern).

fn get_compensatable_checkpoints<'life0, 'life1, 'async_trait>( &'life0 self, _instance_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<CheckpointRecord>, CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get all compensatable checkpoints for an instance (in reverse order).

fn set_checkpoint_compensation_state<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, _instance_id: &'life1 str, _checkpoint_id: &'life2 str, _state: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<(), CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Update the compensation state of a checkpoint.

fn set_instance_compensation_state<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, _instance_id: &'life1 str, _state: &'life2 str, _reason: Option<&'life3 str>, ) -> Pin<Box<dyn Future<Output = Result<(), CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Update the instance-level compensation state.

fn log_compensation_attempt<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, _instance_id: &'life1 str, _checkpoint_id: &'life2 str, _compensation_step_id: &'life3 str, _success: bool, _error_message: Option<&'life4 str>, _error_id: Option<i64>, ) -> Pin<Box<dyn Future<Output = Result<(), CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Log a compensation attempt.

fn count_pending_compensations<'life0, 'life1, 'async_trait>( &'life0 self, _instance_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<i64, CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Count pending compensations for an instance.

fn all_compensations_succeeded<'life0, 'life1, 'async_trait>( &'life0 self, _instance_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<bool, CoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Check if all compensations for an instance succeeded.