Skip to main content

Module prelude

Module prelude 

Source
Expand description

Common runledger-postgres imports for integration crates.

This prelude contains persistence APIs, DB types, and database record/input structs. It avoids generic Result or Error aliases and does not re-export runledger-core contracts, so it can be glob-imported alongside runledger_core::prelude::* and runledger_runtime::prelude::*.

Re-exportsยง

pub use crate::jobs::AppendWorkflowStepsInput;
pub use crate::jobs::AppendWorkflowStepsOutcome;
pub use crate::jobs::AppendWorkflowStepsResult;
pub use crate::jobs::CompleteExternalWorkflowStepInput;
pub use crate::jobs::JobDefinitionListFilter;
pub use crate::jobs::JobDefinitionRecord;
pub use crate::jobs::JobDefinitionUpdate;
pub use crate::jobs::JobDefinitionUpsert;
pub use crate::jobs::JobEnqueue;
pub use crate::jobs::JobEventRecord;
pub use crate::jobs::JobFailureUpdate;
pub use crate::jobs::JobListFilter;
pub use crate::jobs::JobLogRecord;
pub use crate::jobs::JobLogRecordInput;
pub use crate::jobs::JobMetricsRecord;
pub use crate::jobs::JobProgressUpdate;
pub use crate::jobs::JobQueueRecord;
pub use crate::jobs::JobRuntimeConfigListFilter;
pub use crate::jobs::JobRuntimeConfigRecord;
pub use crate::jobs::JobRuntimeConfigUpsert;
pub use crate::jobs::JobScheduleRecord;
pub use crate::jobs::JobScheduleUpsert;
pub use crate::jobs::ReapExpiredLeasesResult;
pub use crate::jobs::ReapedTerminalLeaseRecord;
pub use crate::jobs::WorkflowRunDbRecord;
pub use crate::jobs::WorkflowRunListFilter;
pub use crate::jobs::WorkflowStepDbRecord;
pub use crate::jobs::WorkflowStepDependencyDbRecord;
pub use crate::jobs::append_workflow_steps;
pub use crate::jobs::append_workflow_steps_tx;
pub use crate::jobs::cancel_job;
pub use crate::jobs::cancel_workflow_run_tx;
pub use crate::jobs::complete_external_workflow_step;
pub use crate::jobs::complete_external_workflow_step_tx;
pub use crate::jobs::complete_job_failure;
pub use crate::jobs::complete_job_success;
pub use crate::jobs::enqueue_job;
pub use crate::jobs::enqueue_job_tx;
pub use crate::jobs::enqueue_workflow_run;
pub use crate::jobs::enqueue_workflow_run_tx;
pub use crate::jobs::get_job_by_id;
pub use crate::jobs::get_job_definition_by_type;
pub use crate::jobs::get_job_metrics;
pub use crate::jobs::get_job_payload_by_idempotency_key;
pub use crate::jobs::get_job_runtime_config_by_type;
pub use crate::jobs::get_latest_job_payload_for_run;
pub use crate::jobs::get_latest_workflow_run_by_type;
pub use crate::jobs::get_required_job_runtime_config_by_type;
pub use crate::jobs::get_workflow_run_by_id;
pub use crate::jobs::get_workflow_run_by_type_and_idempotency_key;
pub use crate::jobs::get_workflow_run_id_for_job;
pub use crate::jobs::insert_job_definition_if_missing_tx;
pub use crate::jobs::insert_job_log;
pub use crate::jobs::insert_job_runtime_config_if_missing;
pub use crate::jobs::list_job_definitions;
pub use crate::jobs::list_job_events;
pub use crate::jobs::list_job_logs;
pub use crate::jobs::list_job_runtime_configs;
pub use crate::jobs::list_jobs;
pub use crate::jobs::list_workflow_runs;
pub use crate::jobs::list_workflow_step_dependencies;
pub use crate::jobs::list_workflow_steps;
pub use crate::jobs::requeue_job;
pub use crate::jobs::set_job_schedule_active;
pub use crate::jobs::set_job_schedule_active_tx;
pub use crate::jobs::set_job_schedule_next_fire_at;
pub use crate::jobs::set_job_schedule_next_fire_at_tx;
pub use crate::jobs::update_job_definition;
pub use crate::jobs::update_job_payload_uuid_array_field;
pub use crate::jobs::update_workflow_step_and_pending_job_payload_tx;
pub use crate::jobs::upsert_job_definition_tx;
pub use crate::jobs::upsert_job_runtime_config;
pub use crate::jobs::upsert_job_runtime_config_tx;
pub use crate::jobs::upsert_job_schedule;
pub use crate::jobs::upsert_job_schedule_tx;
pub use crate::DbPool;
pub use crate::DbTx;
pub use crate::FrameworkConstraintSpec;
pub use crate::MIGRATOR;
pub use crate::QueryError;
pub use crate::QueryErrorCategory;
pub use crate::SchemaCompatibilityError;
pub use crate::ensure_schema_compatible_after_idempotency_cutover;
pub use crate::migrate_after_idempotency_cutover;