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, request: ExportRequest, ) -> 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<ExportManifest>> + Send + 'async_trait>>

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

Gets the manifest for a completed export.

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 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 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.

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 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.

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 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.