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::CompareAndReplaySucceededJob;pub use crate::jobs::CompareAndReplaySucceededJobOutcome;pub use crate::jobs::CompareAndRequeueJob;pub use crate::jobs::CompareAndRequeueJobOutcome;pub use crate::jobs::CompleteExternalWorkflowStepInput;pub use crate::jobs::DEFAULT_WORKFLOW_RUN_WAIT_TIMEOUT;pub use crate::jobs::DecodedJobEventPayload;pub use crate::jobs::DecodedRequeuedEventPayload;pub use crate::jobs::EnqueueActiveWorkflowOutcome;pub use crate::jobs::ExternalWorkflowStepTerminalOutcome;pub use crate::jobs::JOB_SCHEDULE_MAX_JITTER_SECONDS;pub use crate::jobs::JobCancellationScope;pub use crate::jobs::JobCompletionUpdate;pub use crate::jobs::JobContinuationMetricsRecord;pub use crate::jobs::JobContinuationOutcome;pub use crate::jobs::JobContinuationUpdate;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::JobEnqueueDisposition;pub use crate::jobs::JobEnqueueIntent;pub use crate::jobs::JobEnqueueIntentDisposition;pub use crate::jobs::JobEnqueueIntentListFilter;pub use crate::jobs::JobEnqueueIntentMetricsFilter;pub use crate::jobs::JobEnqueueIntentMetricsRecord;pub use crate::jobs::JobEnqueueIntentOutcome;pub use crate::jobs::JobEnqueueIntentOutcomeState;pub use crate::jobs::JobEnqueueIntentPromotionError;pub use crate::jobs::JobEnqueueIntentPromotionReport;pub use crate::jobs::JobEnqueueIntentRecord;pub use crate::jobs::JobEnqueueIntentState;pub use crate::jobs::JobEnqueueIntentStatus;pub use crate::jobs::JobEnqueueOutcome;pub use crate::jobs::JobEventRecord;pub use crate::jobs::JobFailureCompletionDisposition;pub use crate::jobs::JobFailureCompletionOutcome;pub use crate::jobs::JobFailureUpdate;pub use crate::jobs::JobLeaseIdentity;pub use crate::jobs::JobListFilter;pub use crate::jobs::JobLogRecord;pub use crate::jobs::JobLogRecordInput;pub use crate::jobs::JobMetricsRecord;pub use crate::jobs::JobOrdinaryProgressUpdate;pub use crate::jobs::JobPayloadUuidArrayFieldUpdate;pub use crate::jobs::JobPayloadUuidArrayFieldUpdateRejection;pub use crate::jobs::JobProgressUpdate;Deprecated pub use crate::jobs::JobQueueRecord;pub use crate::jobs::JobRequeueStatePolicy;pub use crate::jobs::JobRunningUpdate;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::JobScope;pub use crate::jobs::JobSuccessCompletionOutcome;pub use crate::jobs::NonRequeueableJobStatusError;pub use crate::jobs::ReapExpiredLeaseCleanupError;pub use crate::jobs::ReapExpiredLeaseCleanupOperation;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::RequeueableJobStatus;pub use crate::jobs::SuccessfulReplayEnqueuedEventPayload;pub use crate::jobs::WorkflowRecoveryDisposition;pub use crate::jobs::WorkflowRecoveryMode;pub use crate::jobs::WorkflowRecoveryOutcome;pub use crate::jobs::WorkflowRecoveryRequest;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::WorkflowRunReadCountFilter;pub use crate::jobs::WorkflowRunReadListFilter;pub use crate::jobs::WorkflowRunReadScope;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_job_with_scope;pub use crate::jobs::cancel_workflow_run_tx;pub use crate::jobs::compare_and_replay_succeeded_job;pub use crate::jobs::compare_and_replay_succeeded_job_tx;pub use crate::jobs::compare_and_requeue_job;pub use crate::jobs::compare_and_requeue_job_tx;pub use crate::jobs::complete_external_workflow_step;pub use crate::jobs::complete_external_workflow_step_tx;pub use crate::jobs::complete_job_continuation;pub use crate::jobs::complete_job_continuation_for_lease;pub use crate::jobs::complete_job_continuation_with_outcome;pub use crate::jobs::complete_job_continuation_with_outcome_for_lease;pub use crate::jobs::complete_job_failure;pub use crate::jobs::complete_job_failure_for_lease;pub use crate::jobs::complete_job_failure_with_outcome;pub use crate::jobs::complete_job_failure_with_outcome_for_lease;pub use crate::jobs::complete_job_success;pub use crate::jobs::complete_job_success_for_lease;pub use crate::jobs::complete_job_success_with_outcome;pub use crate::jobs::complete_job_success_with_outcome_for_lease;pub use crate::jobs::count_workflow_runs_with_scope;pub use crate::jobs::count_workflow_step_dependencies;pub use crate::jobs::count_workflow_step_dependencies_with_scope;pub use crate::jobs::count_workflow_steps;pub use crate::jobs::count_workflow_steps_with_scope;pub use crate::jobs::delete_promoted_job_enqueue_intents_before;pub use crate::jobs::delete_promoted_job_enqueue_intents_for_jobs_tx;pub use crate::jobs::enqueue_job;pub use crate::jobs::enqueue_job_tx;pub use crate::jobs::enqueue_job_with_execution_resource;pub use crate::jobs::enqueue_job_with_execution_resource_tx;pub use crate::jobs::enqueue_job_with_outcome_tx;pub use crate::jobs::enqueue_or_get_active_workflow;pub use crate::jobs::enqueue_or_get_active_workflow_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_continuation_metrics;pub use crate::jobs::get_job_definition_by_type;pub use crate::jobs::get_job_enqueue_intent_by_id;pub use crate::jobs::get_job_enqueue_intent_metrics;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_latest_workflow_run_by_type_with_scope;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_id_with_scope;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::heartbeat_job_for_lease;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_enqueue_intents;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_runs_with_scope;pub use crate::jobs::list_workflow_step_dependencies;pub use crate::jobs::list_workflow_step_dependencies_page;pub use crate::jobs::list_workflow_step_dependencies_page_with_scope;pub use crate::jobs::list_workflow_step_dependencies_with_scope;pub use crate::jobs::list_workflow_steps;pub use crate::jobs::list_workflow_steps_page;pub use crate::jobs::list_workflow_steps_page_with_scope;pub use crate::jobs::list_workflow_steps_with_scope;pub use crate::jobs::mark_job_running_for_lease;pub use crate::jobs::prepare_schedule_exact_sync_critical_section_tx;pub use crate::jobs::promote_job_enqueue_intents_for_types;pub use crate::jobs::reap_expired_leases_with_diagnostics;pub use crate::jobs::record_job_enqueue_intent;pub use crate::jobs::record_job_enqueue_intent_tx;pub use crate::jobs::recover_workflow_run;pub use crate::jobs::recover_workflow_run_tx;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_ordinary_progress_for_lease;pub use crate::jobs::update_job_payload_uuid_array_field;pub use crate::jobs::update_job_progress_for_lease;Deprecated 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::QueryErrorKind;pub use crate::SchemaCompatibilityError;pub use crate::WorkflowJobLinkTriggerDiagnostic;pub use crate::WorkflowJobLinkTriggerProblem;pub use crate::ensure_schema_compatible_after_idempotency_cutover;pub use crate::migrate_after_idempotency_cutover;