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::DEFAULT_WORKFLOW_RUN_WAIT_TIMEOUT;
pub use crate::jobs::JOB_SCHEDULE_MAX_JITTER_SECONDS;
pub use crate::jobs::JobCompletionUpdate;
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::JobFailureCompletionDisposition;
pub use crate::jobs::JobFailureCompletionOutcome;
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::JobPayloadUuidArrayFieldUpdate;
pub use crate::jobs::JobPayloadUuidArrayFieldUpdateRejection;
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::JobSuccessCompletionOutcome;
pub use crate::jobs::ReapExpiredLeaseDeferredError;
pub use crate::jobs::ReapExpiredLeasesDetailedResult;
pub use crate::jobs::ReapExpiredLeasesResult;
pub use crate::jobs::ReapedLeaseDisposition;
pub use crate::jobs::ReapedLeaseRecord;
pub use crate::jobs::ReapedTerminalLeaseRecord;
pub use crate::jobs::WorkflowRunDbRecord;
pub use crate::jobs::WorkflowRunHandle;
pub use crate::jobs::WorkflowRunHandleError;
pub use crate::jobs::WorkflowRunHandleScope;
pub use crate::jobs::WorkflowRunListFilter;
pub use crate::jobs::WorkflowRunResultRecord;
pub use crate::jobs::WorkflowRunWaitOptions;
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_failure_with_outcome;
pub use crate::jobs::complete_job_success;
pub use crate::jobs::complete_job_success_with_outcome;
pub use crate::jobs::count_workflow_step_dependencies;
pub use crate::jobs::count_workflow_steps;
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_handle;
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_job_schedule_by_name;
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_step_dependencies_page;
pub use crate::jobs::list_workflow_steps;
pub use crate::jobs::list_workflow_steps_page;
pub use crate::jobs::prepare_schedule_exact_sync_critical_section_tx;
pub use crate::jobs::reap_expired_leases_with_diagnostics;
pub use crate::jobs::requeue_job;
pub use crate::jobs::retrieve_workflow_run_handle;
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::sync_catalog_job_schedules_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::jobs::workflow_run_handle;
pub use crate::jobs::JobScheduleCatalogSyncEntry;
pub use crate::jobs::JobScheduleCatalogSyncReport;
pub use crate::jobs::deactivate_schedules_absent_from_names_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;