Struct PostgresBackend 

pub struct PostgresBackend { /* private fields */ }

PostgreSQL backend for FHIR resource storage.

Implementations

impl PostgresBackend

pub async fn new(config: PostgresConfig) -> StorageResult<Self>

Creates a new PostgreSQL backend with the given configuration.

pub async fn from_connection_string(url: &str) -> StorageResult<Self>

Creates a backend from a connection string.

pub async fn from_env() -> StorageResult<Self>

Creates a backend from environment variables.

Reads the following environment variables:

• HFS_PG_HOST (default: “localhost”)
• HFS_PG_PORT (default: 5432)
• HFS_PG_DBNAME (default: “helios”)
• HFS_PG_USER (default: “helios”)
• HFS_PG_PASSWORD
• HFS_PG_MAX_CONNECTIONS (default: 10)

pub async fn init_schema(&self) -> StorageResult<()>

Initialize the database schema.

pub fn config(&self) -> &PostgresConfig

Returns the backend configuration.

pub fn search_registry(&self) -> &Arc<RwLock<SearchParameterRegistry>>

Returns a reference to the search parameter registry.

pub fn search_extractor(&self) -> &Arc<SearchParameterExtractor>

Returns a reference to the search parameter extractor.

pub fn is_search_offloaded(&self) -> bool

Returns whether search indexing is offloaded to a secondary backend.

pub fn set_search_offloaded(&mut self, offloaded: bool)

Sets the search offloaded flag.

Trait Implementations

impl Backend for PostgresBackend

type Connection = PostgresConnection

The type of raw connection used by this backend.

fn kind(&self) -> BackendKind

Returns the kind of backend.

fn name(&self) -> &'static str

Returns a human-readable name for this backend.

fn supports(&self, capability: BackendCapability) -> bool

Checks if this backend supports the given capability.

fn capabilities(&self) -> Vec<BackendCapability>

Returns all capabilities supported by this backend.

fn acquire<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Self::Connection, BackendError>> + Send + 'async_trait>>

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

Acquires a connection from the pool.

fn release<'life0, 'async_trait>( &'life0 self, _conn: Self::Connection, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Returns the connection back to the pool.

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

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

Checks if the backend is healthy and accepting connections.

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

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

Initializes the database schema if needed.

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

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

Runs any pending migrations.

impl BulkExportStorage for PostgresBackend

fn start_export<'life0, 'life1, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, input: StartExportInput, ) -> Pin<Box<dyn Future<Output = StorageResult<ExportJobId>> + Send + 'async_trait>>

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

Starts a new export job.

fn get_export_status<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, job_id: &'life2 ExportJobId, ) -> Pin<Box<dyn Future<Output = StorageResult<ExportProgress>> + Send + 'async_trait>>

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

Gets the current status of an export job.

fn cancel_export<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, job_id: &'life2 ExportJobId, ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>

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

Cancels an in-progress export job.

fn delete_export<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, job_id: &'life2 ExportJobId, ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>

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

Deletes an export job and its output files.

fn get_export_manifest<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, job_id: &'life2 ExportJobId, ) -> Pin<Box<dyn Future<Output = StorageResult<RawExportManifest>> + Send + 'async_trait>>

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

Gets the storage-side manifest for a completed export.

fn get_export_job_metadata<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, job_id: &'life2 ExportJobId, ) -> Pin<Box<dyn Future<Output = StorageResult<ExportJobMetadata>> + Send + 'async_trait>>

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

Returns lightweight job metadata for an authorization check.

fn get_export_file_metadata<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, job_id: &'life2 ExportJobId, part: &'life3 str, ) -> Pin<Box<dyn Future<Output = StorageResult<ExportFileMetadata>> + Send + 'async_trait>>

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

Returns file metadata for a single output/error part, for the download handler. part is the {resource_type}-{part_index} route segment.

fn count_active_exports<'life0, 'life1, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, ) -> Pin<Box<dyn Future<Output = StorageResult<u64>> + Send + 'async_trait>>

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

Counts active (accepted or in_progress) jobs for a tenant — used to enforce the per-tenant concurrency cap at kickoff.

fn list_expired_exports<'life0, 'async_trait>( &'life0 self, now: DateTime<Utc>, output_ttl: StdDuration, limit: u32, ) -> Pin<Box<dyn Future<Output = StorageResult<Vec<ExpiredExportRef>>> + Send + 'async_trait>>

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

Lists expired completed jobs across all tenants, for the cleanup task.

fn list_exports<'life0, 'life1, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, include_completed: bool, ) -> Pin<Box<dyn Future<Output = StorageResult<Vec<ExportProgress>>> + Send + 'async_trait>>

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

Lists export jobs for a tenant.

impl BulkSubmitProvider for PostgresBackend

fn create_submission<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, id: &'life2 SubmissionId, metadata: Option<Value>, ) -> Pin<Box<dyn Future<Output = StorageResult<SubmissionSummary>> + Send + 'async_trait>>

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

Creates a new submission.

fn get_submission<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, id: &'life2 SubmissionId, ) -> Pin<Box<dyn Future<Output = StorageResult<Option<SubmissionSummary>>> + Send + 'async_trait>>

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

Gets a submission by ID.

fn list_submissions<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, submitter: Option<&'life2 str>, status: Option<SubmissionStatus>, limit: u32, offset: u32, ) -> Pin<Box<dyn Future<Output = StorageResult<Vec<SubmissionSummary>>> + Send + 'async_trait>>

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

Lists submissions.

fn complete_submission<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, id: &'life2 SubmissionId, ) -> Pin<Box<dyn Future<Output = StorageResult<SubmissionSummary>> + Send + 'async_trait>>

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

Marks a submission as complete.

fn abort_submission<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, id: &'life2 SubmissionId, _reason: &'life3 str, ) -> Pin<Box<dyn Future<Output = StorageResult<u64>> + Send + 'async_trait>>

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

Aborts a submission.

fn add_manifest<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, submission_id: &'life2 SubmissionId, manifest_url: Option<&'life3 str>, replaces_manifest_url: Option<&'life4 str>, ) -> Pin<Box<dyn Future<Output = StorageResult<SubmissionManifest>> + Send + 'async_trait>>

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

Adds a manifest to a submission.

fn get_manifest<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, submission_id: &'life2 SubmissionId, manifest_id: &'life3 str, ) -> Pin<Box<dyn Future<Output = StorageResult<Option<SubmissionManifest>>> + Send + 'async_trait>>

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

Gets a manifest by ID.

fn list_manifests<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, submission_id: &'life2 SubmissionId, ) -> Pin<Box<dyn Future<Output = StorageResult<Vec<SubmissionManifest>>> + Send + 'async_trait>>

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

Lists manifests in a submission.

fn process_entries<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, submission_id: &'life2 SubmissionId, manifest_id: &'life3 str, entries: Vec<NdjsonEntry>, options: &'life4 BulkProcessingOptions, ) -> Pin<Box<dyn Future<Output = StorageResult<Vec<BulkEntryResult>>> + Send + 'async_trait>>

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

Processes entries from a manifest.

fn get_entry_results<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, submission_id: &'life2 SubmissionId, manifest_id: &'life3 str, outcome_filter: Option<BulkEntryOutcome>, limit: u32, offset: u32, ) -> Pin<Box<dyn Future<Output = StorageResult<Vec<BulkEntryResult>>> + Send + 'async_trait>>

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

Gets entry results for a manifest.

fn get_entry_counts<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, submission_id: &'life2 SubmissionId, manifest_id: &'life3 str, ) -> Pin<Box<dyn Future<Output = StorageResult<EntryCountSummary>> + Send + 'async_trait>>

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

Gets entry counts for a manifest.

impl BulkSubmitRollbackProvider for PostgresBackend

fn record_change<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, submission_id: &'life2 SubmissionId, change: &'life3 SubmissionChange, ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>

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

Records a change for potential rollback.

fn list_changes<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, submission_id: &'life2 SubmissionId, limit: u32, offset: u32, ) -> Pin<Box<dyn Future<Output = StorageResult<Vec<SubmissionChange>>> + Send + 'async_trait>>

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

Lists recorded changes for a submission.

fn rollback_change<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, _submission_id: &'life2 SubmissionId, change: &'life3 SubmissionChange, ) -> Pin<Box<dyn Future<Output = StorageResult<bool>> + Send + 'async_trait>>

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

Rolls back a single change.

impl BundleProvider for PostgresBackend

fn process_transaction<'life0, 'life1, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, entries: Vec<BundleEntry>, ) -> Pin<Box<dyn Future<Output = Result<BundleResult, TransactionError>> + Send + 'async_trait>>

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

Processes a transaction bundle (all-or-nothing).

fn process_batch<'life0, 'life1, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, entries: Vec<BundleEntry>, ) -> Pin<Box<dyn Future<Output = StorageResult<BundleResult>> + Send + 'async_trait>>

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

Processes a batch bundle (independent operations).

impl ChainedSearchProvider for PostgresBackend

fn resolve_chain<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, base_type: &'life2 str, chain: &'life3 str, value: &'life4 str, ) -> Pin<Box<dyn Future<Output = StorageResult<Vec<String>>> + Send + 'async_trait>>

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

Evaluates a chained search and returns matching resource IDs.

fn resolve_reverse_chain<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, base_type: &'life2 str, reverse_chain: &'life3 ReverseChainedParameter, ) -> Pin<Box<dyn Future<Output = StorageResult<Vec<String>>> + Send + 'async_trait>>

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

Evaluates a reverse chain (_has) and returns matching resource IDs.

impl ConditionalStorage for PostgresBackend

fn conditional_create<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: &'life2 str, resource: Value, search_params: &'life3 str, fhir_version: FhirVersion, ) -> Pin<Box<dyn Future<Output = StorageResult<ConditionalCreateResult>> + Send + 'async_trait>>

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

Creates a resource only if no matching resource exists.

fn conditional_update<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: &'life2 str, resource: Value, search_params: &'life3 str, upsert: bool, fhir_version: FhirVersion, ) -> Pin<Box<dyn Future<Output = StorageResult<ConditionalUpdateResult>> + Send + 'async_trait>>

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

Updates a resource based on search criteria.

fn conditional_delete<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: &'life2 str, search_params: &'life3 str, ) -> Pin<Box<dyn Future<Output = StorageResult<ConditionalDeleteResult>> + Send + 'async_trait>>

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

Deletes a resource based on search criteria.

fn conditional_patch<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: &'life2 str, search_params: &'life3 str, patch: &'life4 PatchFormat, ) -> Pin<Box<dyn Future<Output = StorageResult<ConditionalPatchResult>> + Send + 'async_trait>>

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

Patches a resource based on search criteria.

impl Debug for PostgresBackend

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl DifferentialHistoryProvider for PostgresBackend

fn modified_since<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: Option<&'life2 str>, since: DateTime<Utc>, pagination: &'life3 Pagination, ) -> Pin<Box<dyn Future<Output = StorageResult<Page<StoredResource>>> + Send + 'async_trait>>

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

Gets resources modified since a given timestamp.

impl ExportClaimStrategy for PostgresBackend

fn claim_next<'life0, 'life1, 'async_trait>( &'life0 self, worker_id: &'life1 WorkerId, lease_duration: StdDuration, ) -> Pin<Box<dyn Future<Output = StorageResult<Option<ExportJobLease>>> + Send + 'async_trait>>

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

Atomically transitions one eligible job (accepted, or in_progress with an expired lease) to held-by-this-worker, bumping the fencing token. Returns Ok(None) when no job is available.

fn heartbeat<'life0, 'life1, 'async_trait>( &'life0 self, lease: &'life1 ExportJobLease, ) -> Pin<Box<dyn Future<Output = Result<DateTime<Utc>, LeaseError>> + Send + 'async_trait>>

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

Renews a lease the worker still holds; returns the new expiry, or LeaseError::LeaseLost if the job was reclaimed.

fn release<'life0, 'async_trait>( &'life0 self, lease: ExportJobLease, ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>

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

Releases a lease early (graceful shutdown). Best-effort.

impl ExportDataProvider for PostgresBackend

fn list_export_types<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, request: &'life2 ExportRequest, ) -> Pin<Box<dyn Future<Output = StorageResult<Vec<String>>> + Send + 'async_trait>>

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

Lists resource types available for export.

fn count_export_resources<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, request: &'life2 ExportRequest, resource_type: &'life3 str, ) -> Pin<Box<dyn Future<Output = StorageResult<u64>> + Send + 'async_trait>>

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

Counts resources of a type for export.

fn fetch_export_batch<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, request: &'life2 ExportRequest, resource_type: &'life3 str, cursor: Option<&'life4 str>, batch_size: u32, ) -> Pin<Box<dyn Future<Output = StorageResult<NdjsonBatch>> + Send + 'async_trait>>

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

Fetches a batch of resources for export.

impl ExportWorkerStorage for PostgresBackend

fn get_export_job_for_worker<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, job_id: &'life2 ExportJobId, worker_id: &'life3 WorkerId, fencing_token: u64, ) -> Pin<Box<dyn Future<Output = Result<WorkerJobView, LeaseError>> + Send + 'async_trait>>

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

Loads the claimed job’s request, level, frozen metadata and persisted per-type progress (for resume). Fenced.

fn mark_export_in_progress<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, job_id: &'life2 ExportJobId, worker_id: &'life3 WorkerId, fencing_token: u64, ) -> Pin<Box<dyn Future<Output = Result<(), LeaseError>> + Send + 'async_trait>>

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

Marks the job in_progress (sets started_at if unset). Fenced.

fn update_export_type_progress<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, job_id: &'life2 ExportJobId, worker_id: &'life3 WorkerId, fencing_token: u64, progress: &'life4 TypeExportProgress, ) -> Pin<Box<dyn Future<Output = Result<(), LeaseError>> + Send + 'async_trait>>

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

Idempotent upsert of per-type progress (cursor + counts). Fenced.

fn record_export_file<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, job_id: &'life2 ExportJobId, worker_id: &'life3 WorkerId, fencing_token: u64, part: &'life4 FinalizedPart, file_type: &'life5 str, ) -> Pin<Box<dyn Future<Output = Result<(), LeaseError>> + 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,

Idempotent upsert of a finalized output/error file row. Fenced.

fn finish_export_job<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, job_id: &'life2 ExportJobId, worker_id: &'life3 WorkerId, fencing_token: u64, ) -> Pin<Box<dyn Future<Output = Result<(), LeaseError>> + Send + 'async_trait>>

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

Marks the job complete (sets completed_at). Fenced.

fn fail_export_job<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, job_id: &'life2 ExportJobId, worker_id: &'life3 WorkerId, fencing_token: u64, error_message: &'life4 str, ) -> Pin<Box<dyn Future<Output = Result<(), LeaseError>> + Send + 'async_trait>>

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

Marks the job error with a message (sets completed_at). Fenced.

impl GroupExportProvider for PostgresBackend

fn get_group_members<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, group_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = StorageResult<Vec<String>>> + Send + 'async_trait>>

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

Gets the members of a group.

fn resolve_group_patient_ids<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, group_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = StorageResult<Vec<String>>> + Send + 'async_trait>>

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

Resolves group members to patient IDs.

fn get_group_members_with_periods<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, group_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = StorageResult<Vec<(String, Option<DateTime<Utc>>)>>> + Send + 'async_trait>>

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

Returns each member’s reference together with its Group.member.period.start.

impl IncludeProvider for PostgresBackend

fn resolve_includes<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resources: &'life2 [StoredResource], includes: &'life3 [IncludeDirective], ) -> Pin<Box<dyn Future<Output = StorageResult<Vec<StoredResource>>> + Send + 'async_trait>>

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

Resolves _include directives for search results.

impl InstanceHistoryProvider for PostgresBackend

fn history_instance<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: &'life2 str, id: &'life3 str, params: &'life4 HistoryParams, ) -> Pin<Box<dyn Future<Output = StorageResult<HistoryPage>> + Send + 'async_trait>>

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

Gets the history for a specific resource instance.

fn history_instance_count<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: &'life2 str, id: &'life3 str, ) -> Pin<Box<dyn Future<Output = StorageResult<u64>> + Send + 'async_trait>>

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

Gets the total number of versions for a resource.

fn delete_instance_history<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: &'life2 str, id: &'life3 str, ) -> Pin<Box<dyn Future<Output = StorageResult<u64>> + Send + 'async_trait>>

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

Deletes all history for a specific resource instance.

fn delete_version<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: &'life2 str, id: &'life3 str, version_id: &'life4 str, ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>

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

Deletes a specific version from a resource’s history.

impl MultiTypeSearchProvider for PostgresBackend

fn search_multi<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_types: &'life2 [&'life3 str], query: &'life4 SearchQuery, ) -> Pin<Box<dyn Future<Output = StorageResult<SearchResult>> + Send + 'async_trait>>

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

Searches across multiple resource types.

impl PatientExportProvider for PostgresBackend

fn list_patient_ids<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, request: &'life2 ExportRequest, cursor: Option<&'life3 str>, batch_size: u32, ) -> Pin<Box<dyn Future<Output = StorageResult<(Vec<String>, Option<String>)>> + Send + 'async_trait>>

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

Lists patient IDs to include in the export.

fn fetch_patient_compartment_batch<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, request: &'life2 ExportRequest, resource_type: &'life3 str, patient_ids: &'life4 [String], cursor: Option<&'life5 str>, batch_size: u32, ) -> Pin<Box<dyn Future<Output = StorageResult<NdjsonBatch>> + 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,

Fetches a batch of resources from the patient compartment.

impl PurgableStorage for PostgresBackend

fn purge<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: &'life2 str, id: &'life3 str, ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>

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

Permanently deletes a resource and all its history.

fn purge_all<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: &'life2 str, ) -> Pin<Box<dyn Future<Output = StorageResult<u64>> + Send + 'async_trait>>

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

Permanently deletes all resources of a type for a tenant.

impl ReindexableStorage for PostgresBackend

fn list_resource_types<'life0, 'life1, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, ) -> Pin<Box<dyn Future<Output = StorageResult<Vec<String>>> + Send + 'async_trait>>

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

Lists all resource types that have resources in the tenant.

fn count_resources<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: &'life2 str, ) -> Pin<Box<dyn Future<Output = StorageResult<u64>> + Send + 'async_trait>>

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

Counts resources of a specific type.

fn fetch_resources_page<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: &'life2 str, cursor: Option<&'life3 str>, limit: u32, ) -> Pin<Box<dyn Future<Output = StorageResult<ResourcePage>> + Send + 'async_trait>>

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

Fetches a page of resources for reindexing.

fn delete_search_entries<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: &'life2 str, resource_id: &'life3 str, ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>

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

Deletes search index entries for a resource.

fn write_search_entries<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: &'life2 str, resource_id: &'life3 str, resource: &'life4 Value, ) -> Pin<Box<dyn Future<Output = StorageResult<usize>> + Send + 'async_trait>>

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

Writes search index entries for a resource.

fn clear_search_index<'life0, 'life1, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, ) -> Pin<Box<dyn Future<Output = StorageResult<u64>> + Send + 'async_trait>>

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

Clears all search index entries for a tenant.

impl ResourceStorage for PostgresBackend

fn backend_name(&self) -> &'static str

Returns a human-readable name for this storage backend.

fn sof_runner(&self) -> Option<Arc<dyn SofRunner>>

Returns the SQL-on-FHIR runner for this backend, if it supports in-DB execution.

fn create<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: &'life2 str, resource: Value, fhir_version: FhirVersion, ) -> Pin<Box<dyn Future<Output = StorageResult<StoredResource>> + Send + 'async_trait>>

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

Creates a new resource.

fn create_or_update<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: &'life2 str, id: &'life3 str, resource: Value, fhir_version: FhirVersion, ) -> Pin<Box<dyn Future<Output = StorageResult<(StoredResource, bool)>> + Send + 'async_trait>>

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

Creates a resource with a specific ID (PUT semantics).

fn read<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: &'life2 str, id: &'life3 str, ) -> Pin<Box<dyn Future<Output = StorageResult<Option<StoredResource>>> + Send + 'async_trait>>

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

Reads a resource by type and ID.

fn update<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, current: &'life2 StoredResource, resource: Value, ) -> Pin<Box<dyn Future<Output = StorageResult<StoredResource>> + Send + 'async_trait>>

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

Updates an existing resource.

fn delete<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: &'life2 str, id: &'life3 str, ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>

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

Deletes a resource (soft delete).

fn count<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: Option<&'life2 str>, ) -> Pin<Box<dyn Future<Output = StorageResult<u64>> + Send + 'async_trait>>

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

Counts the total number of resources of a given type.

fn exists<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: &'life2 str, id: &'life3 str, ) -> Pin<Box<dyn Future<Output = StorageResult<bool>> + Send + 'async_trait>>

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

Checks if a resource exists.

fn read_batch<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: &'life2 str, ids: &'life3 [&'life4 str], ) -> Pin<Box<dyn Future<Output = StorageResult<Vec<StoredResource>>> + Send + 'async_trait>>

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

Reads multiple resources by their IDs.

impl RevincludeProvider for PostgresBackend

fn resolve_revincludes<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resources: &'life2 [StoredResource], revincludes: &'life3 [IncludeDirective], ) -> Pin<Box<dyn Future<Output = StorageResult<Vec<StoredResource>>> + Send + 'async_trait>>

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

Resolves _revinclude directives for search results.

impl SearchCapabilityProvider for PostgresBackend

fn resource_search_capabilities( &self, resource_type: &str, ) -> Option<ResourceSearchCapabilities>

Returns detailed search capabilities for a resource type.

fn global_search_capabilities(&self) -> GlobalSearchCapabilities

Returns global search capabilities that apply to all resource types.

fn validate_search_query( &self, query: &SearchQuery, ) -> Result<(), UnsupportedSearchFeature>

Validates a search query against the backend’s capabilities.

impl SearchProvider for PostgresBackend

fn search<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, query: &'life2 SearchQuery, ) -> Pin<Box<dyn Future<Output = StorageResult<SearchResult>> + Send + 'async_trait>>

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

Searches for resources matching the query.

fn search_count<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, query: &'life2 SearchQuery, ) -> Pin<Box<dyn Future<Output = StorageResult<u64>> + Send + 'async_trait>>

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

Counts resources matching the query without returning them.

fn search_param_registry(&self) -> &Arc<RwLock<SearchParameterRegistry>>

Returns the backend’s search parameter registry.

fn supports_contained_search(&self) -> bool

Whether this backend can evaluate _contained=true|both searches (which require contained-resource indexing). Defaults to false; backends that index contained[] entries override this. The REST layer uses it to reject _contained with 501 on backends that don’t support it rather than silently returning an unfiltered result.

fn modifiers_for_param_type( &self, param_type: SearchParamType, ) -> Vec<&'static str>

Returns the search modifiers this backend actually honors for a given parameter type (e.g. exact, contains for strings; not, in for tokens). Used by the REST layer to advertise supported modifiers in the CapabilityStatement.

impl StreamingBulkSubmitProvider for PostgresBackend

fn process_ndjson_stream<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, submission_id: &'life2 SubmissionId, manifest_id: &'life3 str, resource_type: &'life4 str, reader: Box<dyn AsyncBufRead + Send + Unpin>, options: &'life5 BulkProcessingOptions, ) -> Pin<Box<dyn Future<Output = StorageResult<StreamProcessingResult>> + 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,

Processes NDJSON data from a stream.

impl SubmitClaimStrategy for PostgresBackend

fn claim_next_manifest<'life0, 'life1, 'async_trait>( &'life0 self, worker_id: &'life1 WorkerId, lease_duration: StdDuration, ) -> Pin<Box<dyn Future<Output = StorageResult<Option<ManifestLease>>> + Send + 'async_trait>>

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

Atomically transitions one eligible manifest (pending, or processing with an expired lease) to held-by-this-worker, bumping the fencing token. Returns Ok(None) when no manifest is available.

fn heartbeat<'life0, 'life1, 'async_trait>( &'life0 self, lease: &'life1 ManifestLease, ) -> Pin<Box<dyn Future<Output = Result<DateTime<Utc>, LeaseError>> + Send + 'async_trait>>

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

Renews a lease the worker still holds; returns the new expiry, or LeaseError::LeaseLost if the manifest was reclaimed.

fn release<'life0, 'async_trait>( &'life0 self, lease: ManifestLease, ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>

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

Releases a lease early (graceful shutdown). Best-effort.

impl SubmitWorkerStorage for PostgresBackend

fn get_manifest_for_worker<'life0, 'life1, 'async_trait>( &'life0 self, lease: &'life1 ManifestLease, ) -> Pin<Box<dyn Future<Output = Result<ManifestWorkerView, LeaseError>> + Send + 'async_trait>>

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

Loads the claimed manifest’s fetch parameters and resume cursor. Fenced.

fn mark_manifest_processing<'life0, 'life1, 'async_trait>( &'life0 self, lease: &'life1 ManifestLease, ) -> Pin<Box<dyn Future<Output = Result<(), LeaseError>> + Send + 'async_trait>>

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

Marks the manifest processing. Fenced.

fn update_manifest_progress<'life0, 'life1, 'async_trait>( &'life0 self, lease: &'life1 ManifestLease, processed_entries: u64, failed_entries: u64, last_processed_line: u64, ) -> Pin<Box<dyn Future<Output = Result<(), LeaseError>> + Send + 'async_trait>>

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

Idempotent update of per-manifest progress (counts + resume cursor). Fenced.

fn record_submit_file<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, lease: &'life1 ManifestLease, file: &'life2 SubmitFileRecord, ) -> Pin<Box<dyn Future<Output = Result<(), LeaseError>> + Send + 'async_trait>>

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

Idempotent upsert of a finalized status-manifest artifact row. Fenced.

fn finish_manifest<'life0, 'life1, 'async_trait>( &'life0 self, lease: &'life1 ManifestLease, ) -> Pin<Box<dyn Future<Output = Result<(), LeaseError>> + Send + 'async_trait>>

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

Marks the manifest completed. Fenced.

fn fail_manifest<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, lease: &'life1 ManifestLease, _error_message: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), LeaseError>> + Send + 'async_trait>>

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

Marks the manifest failed with a message. Fenced.

fn set_manifest_fetch_params<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'life6, 'life7, 'life8, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, id: &'life2 SubmissionId, manifest_id: &'life3 str, fhir_base_url: Option<&'life4 str>, output_format: Option<&'life5 str>, file_request_headers: &'life6 [(String, String)], oauth_metadata_urls: &'life7 [String], file_encryption_key: Option<&'life8 Value>, ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + 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,

Persists the remote-fetch parameters for a manifest that the kickoff handler added via crate::core::bulk_submit::BulkSubmitProvider::add_manifest.

fn replace_manifest_by_url<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, id: &'life2 SubmissionId, manifest_url: &'life3 str, ) -> Pin<Box<dyn Future<Output = StorageResult<Vec<String>>> + Send + 'async_trait>>

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

Marks a previously-submitted manifest (identified by its submitted manifest_url) as replaced, for replacesManifestUrl handling. Returns the manifest_ids that were superseded (so the caller can roll back their changes).

fn set_submission_kickoff_meta<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, id: &'life2 SubmissionId, owner_subject: Option<&'life3 str>, request_url: &'life4 str, requires_access_token: bool, ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>

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

Persists kickoff metadata (owner subject, request URL, access-token posture).

fn ensure_poll_token<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, id: &'life2 SubmissionId, ) -> Pin<Box<dyn Future<Output = StorageResult<String>> + Send + 'async_trait>>

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

Idempotently mints + stores a poll token on the submission (UNIQUE index guards collisions). Returns the existing token if one is already set.

fn list_expired_submissions<'life0, 'async_trait>( &'life0 self, now: DateTime<Utc>, ttl: StdDuration, limit: u32, ) -> Pin<Box<dyn Future<Output = StorageResult<Vec<(TenantContext, SubmissionId)>>> + Send + 'async_trait>>

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

Lists submissions whose updated_at is older than now - ttl, across all tenants, for the periodic cleanup task. Returns (tenant, submission_id) pairs (bounded by limit) so the caller can delete their output-store artifacts and rows.

fn resolve_poll_token<'life0, 'life1, 'async_trait>( &'life0 self, token: &'life1 str, ) -> Pin<Box<dyn Future<Output = StorageResult<Option<PollTokenTarget>>> + Send + 'async_trait>>

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

Resolves a poll token to its submission, or None after deletion/unknown.

fn clear_poll_token<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, id: &'life2 SubmissionId, ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>

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

Clears the poll token so subsequent Self::resolve_poll_token returns None.

fn list_submit_files<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, id: &'life2 SubmissionId, ) -> Pin<Box<dyn Future<Output = StorageResult<Vec<SubmitFileRow>>> + Send + 'async_trait>>

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

Lists the recorded status-manifest artifact rows for a submission.

fn delete_submission_artifacts<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, id: &'life2 SubmissionId, ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>

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

Deletes the bulk_submit_files rows for a submission (idempotent).

fn count_active_submissions<'life0, 'life1, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, ) -> Pin<Box<dyn Future<Output = StorageResult<u64>> + Send + 'async_trait>>

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

Counts non-terminal submissions for a tenant (per-tenant concurrency cap).

fn ensure_transaction_time<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, id: &'life2 SubmissionId, ) -> Pin<Box<dyn Future<Output = StorageResult<DateTime<Utc>>> + Send + 'async_trait>>

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

Records a transaction time on the submission when its status manifest is first finalized (idempotent — only sets if currently unset).

impl SystemHistoryProvider for PostgresBackend

fn history_system<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, params: &'life2 HistoryParams, ) -> Pin<Box<dyn Future<Output = StorageResult<HistoryPage>> + Send + 'async_trait>>

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

Gets the history for all resources in the system.

fn history_system_count<'life0, 'life1, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, ) -> Pin<Box<dyn Future<Output = StorageResult<u64>> + Send + 'async_trait>>

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

Gets the total number of history entries in the system.

impl TextSearchProvider for PostgresBackend

fn search_text<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: &'life2 str, text: &'life3 str, pagination: &'life4 Pagination, ) -> Pin<Box<dyn Future<Output = StorageResult<SearchResult>> + Send + 'async_trait>>

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

Performs a full-text search on resource narratives.

fn search_content<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: &'life2 str, content: &'life3 str, pagination: &'life4 Pagination, ) -> Pin<Box<dyn Future<Output = StorageResult<SearchResult>> + Send + 'async_trait>>

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

Performs a full-text search on entire resource content.

impl TransactionProvider for PostgresBackend

type Transaction = PostgresTransaction

The transaction type returned by this provider.

fn begin_transaction<'life0, 'life1, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, _options: TransactionOptions, ) -> Pin<Box<dyn Future<Output = StorageResult<Self::Transaction>> + Send + 'async_trait>>

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

Begins a new transaction.

fn with_transaction<'life0, 'life1, 'async_trait, F, Fut, R>( &'life0 self, tenant: &'life1 TenantContext, options: TransactionOptions, f: F, ) -> Pin<Box<dyn Future<Output = StorageResult<R>> + Send + 'async_trait>>

where F: FnOnce(Self::Transaction) -> Fut + Send + 'async_trait, Fut: Future<Output = StorageResult<R>> + Send + 'async_trait, R: Send + 'async_trait, Self: Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Executes a function within a transaction.

impl TypeHistoryProvider for PostgresBackend

fn history_type<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: &'life2 str, params: &'life3 HistoryParams, ) -> Pin<Box<dyn Future<Output = StorageResult<HistoryPage>> + Send + 'async_trait>>

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

Gets the history for all resources of a type.

fn history_type_count<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: &'life2 str, ) -> Pin<Box<dyn Future<Output = StorageResult<u64>> + Send + 'async_trait>>

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

Gets the total number of history entries for a resource type.

impl VersionedStorage for PostgresBackend

fn vread<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: &'life2 str, id: &'life3 str, version_id: &'life4 str, ) -> Pin<Box<dyn Future<Output = StorageResult<Option<StoredResource>>> + Send + 'async_trait>>

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

Reads a specific version of a resource (vread).

fn update_with_match<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: &'life2 str, id: &'life3 str, expected_version: &'life4 str, resource: Value, ) -> Pin<Box<dyn Future<Output = StorageResult<StoredResource>> + Send + 'async_trait>>

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

Updates a resource with optimistic locking (If-Match).

fn delete_with_match<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: &'life2 str, id: &'life3 str, expected_version: &'life4 str, ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>

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

Deletes a resource with optimistic locking (If-Match).

fn list_versions<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: &'life2 str, id: &'life3 str, ) -> Pin<Box<dyn Future<Output = StorageResult<Vec<String>>> + Send + 'async_trait>>

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

Lists all version IDs for a resource.

fn current_version<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tenant: &'life1 TenantContext, resource_type: &'life2 str, id: &'life3 str, ) -> Pin<Box<dyn Future<Output = StorageResult<Option<String>>> + Send + 'async_trait>>

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

Gets the current version ID of a resource without reading the full content.