Struct PgMetadataConnection 

pub struct PgMetadataConnection { /* private fields */ }

Direct PostgreSQL metadata connection.

Implementations

impl PgMetadataConnection

pub fn observe_error(&self, error: &PgMetaError)

Retains only the first typed failure for the operation’s bounded summary. Mapping an adapter error to a public workflow error must retain this evidence.

pub fn connection_description(&self) -> &str

Returns the connection description safe for logs and diagnostics.

pub fn client(&mut self) -> &mut Client

Returns the underlying synchronous PostgreSQL client.

pub fn health_check(&mut self) -> Result<PgHealth, PgMetaError>

Performs a lightweight database and schema-bootstrap health check.

Errors

Returns an error if either PostgreSQL query fails.

pub fn bootstrap_schema(&mut self) -> Result<SchemaBootstrapReport, PgMetaError>

Creates or verifies the metadata schema inside one transaction.

Errors

Returns an error if the transaction cannot be opened or committed, the migration table cannot be updated, or the bootstrap SQL fails.

pub fn with_metadata_transaction<T, F>( &mut self, f: F, ) -> Result<T, PgMetaError>

where F: FnOnce(&mut Transaction<'_>) -> Result<T, PgMetaError>,

Runs caller-supplied work inside a PostgreSQL transaction.

Errors

Returns an error if the transaction cannot be opened or committed, or if the callback returns an error.

impl PgMetadataConnection

pub fn missing_metadata_tables( &mut self, ) -> Result<Vec<&'static str>, PgMetaError>

pub fn list_study_types( &mut self, ) -> Result<Vec<PgStudyTypeReadModel>, PgMetaError>

pub fn list_studies(&mut self) -> Result<Vec<PgStudyReadModel>, PgMetaError>

pub fn list_studies_for_domain( &mut self, domain_id: DomainId, ) -> Result<Vec<PgStudyReadModel>, PgMetaError>

Lists Studies explicitly linked to domain_id through study_domains. Dataset and Variable relationships are intentionally absent from this authority query.

pub fn get_study( &mut self, study_id: StudyId, ) -> Result<Option<PgStudyReadModel>, PgMetaError>

pub fn get_study_by_name( &mut self, name: &str, ) -> Result<Option<PgStudyReadModel>, PgMetaError>

pub fn list_domains(&mut self) -> Result<Vec<PgDomainReadModel>, PgMetaError>

pub fn list_domains_by_name( &mut self, name: &str, ) -> Result<Vec<PgDomainReadModel>, PgMetaError>

pub fn get_domain( &mut self, domain_id: DomainId, ) -> Result<Option<PgDomainReadModel>, PgMetaError>

pub fn get_domain_by_name( &mut self, name: &str, ) -> Result<Option<PgDomainReadModel>, PgMetaError>

pub fn list_duo_codes(&mut self) -> Result<Vec<PgDuoCodeReadModel>, PgMetaError>

pub fn list_study_domains( &mut self, study_id: StudyId, ) -> Result<Vec<PgDomainReadModel>, PgMetaError>

pub fn list_study_domain_links( &mut self, study_id: StudyId, ) -> Result<Vec<PgStudyDomainReadModel>, PgMetaError>

pub fn list_study_access( &mut self, study_id: StudyId, ) -> Result<Vec<PgStudyAccessReadModel>, PgMetaError>

pub fn list_study_custodians( &mut self, study_id: StudyId, ) -> Result<Vec<PgStudyCustodianReadModel>, PgMetaError>

pub fn list_study_duo_restrictions( &mut self, study_id: StudyId, ) -> Result<Vec<PgDuoRestrictionReadModel>, PgMetaError>

pub fn list_assets_for_study( &mut self, study_id: StudyId, ) -> Result<Vec<PgAssetReadModel>, PgMetaError>

pub fn get_asset( &mut self, asset_id: AssetId, ) -> Result<Option<PgAssetReadModel>, PgMetaError>

pub fn get_asset_by_name( &mut self, study_id: StudyId, name: &str, ) -> Result<Option<PgAssetReadModel>, PgMetaError>

pub fn list_asset_versions( &mut self, asset_id: AssetId, ) -> Result<Vec<PgAssetVersionReadModel>, PgMetaError>

pub fn get_asset_version( &mut self, version_id: VersionId, ) -> Result<Option<PgAssetVersionReadModel>, PgMetaError>

pub fn list_asset_version_duo_restrictions( &mut self, version_id: VersionId, ) -> Result<Vec<PgAssetVersionDuoRestrictionReadModel>, PgMetaError>

pub fn list_datasets_for_asset( &mut self, asset_id: AssetId, ) -> Result<Vec<PgDatasetReadModel>, PgMetaError>

pub fn get_dataset( &mut self, dataset_id: VersionId, ) -> Result<Option<PgDatasetReadModel>, PgMetaError>

pub fn get_dataset_version_withdrawn_at( &mut self, dataset_id: VersionId, ) -> Result<Option<DateTime<Utc>>, PgMetaError>

Returns the authoritative withdrawal timestamp for one Dataset version.

pub fn list_datafiles_for_asset( &mut self, asset_id: AssetId, ) -> Result<Vec<PgDataFileReadModel>, PgMetaError>

pub fn get_datafile( &mut self, datafile_id: VersionId, ) -> Result<Option<PgDataFileReadModel>, PgMetaError>

pub fn list_value_types( &mut self, ) -> Result<Vec<PgValueTypeReadModel>, PgMetaError>

pub fn list_vocabularies_for_domain( &mut self, domain_id: DomainId, ) -> Result<Vec<PgVocabularyReadModel>, PgMetaError>

pub fn get_vocabulary( &mut self, vocabulary_id: VocabularyId, ) -> Result<Option<PgVocabularyReadModel>, PgMetaError>

pub fn list_vocabulary_items( &mut self, vocabulary_id: VocabularyId, ) -> Result<Vec<PgVocabularyItemReadModel>, PgMetaError>

pub fn get_vocabulary_item( &mut self, vocabulary_item_id: VocabularyItemId, ) -> Result<Option<PgVocabularyItemReadModel>, PgMetaError>

pub fn list_vocabulary_mappings( &mut self, ) -> Result<Vec<PgVocabularyMappingReadModel>, PgMetaError>

pub fn list_vocabulary_mappings_for_vocabulary( &mut self, vocabulary_id: VocabularyId, ) -> Result<Vec<PgVocabularyMappingWithItemsReadModel>, PgMetaError>

pub fn list_variables_for_domain( &mut self, domain_id: DomainId, ) -> Result<Vec<PgVariableReadModel>, PgMetaError>

pub fn get_variable( &mut self, variable_id: VariableId, ) -> Result<Option<PgVariableReadModel>, PgMetaError>

pub fn list_variable_mappings_provisional( &mut self, ) -> Result<Vec<PgVariableMappingReadModel>, PgMetaError>

Provisional read path for a future public.variable_mapping table. Callers should first verify that the target schema actually contains this table.

pub fn list_dataset_variables( &mut self, dataset_id: VersionId, ) -> Result<Vec<PgDatasetVariableReadModel>, PgMetaError>

pub fn list_dataset_variables_for_variable( &mut self, variable_id: VariableId, ) -> Result<Vec<PgDatasetVariableReadModel>, PgMetaError>

pub fn list_entities_for_domain( &mut self, domain_id: DomainId, ) -> Result<Vec<PgEntityReadModel>, PgMetaError>

pub fn list_entity_relations_for_domain( &mut self, domain_id: DomainId, ) -> Result<Vec<PgEntityRelationReadModel>, PgMetaError>

pub fn list_entity_instances_for_entity( &mut self, entity_id: EntityId, ) -> Result<Vec<PgEntityInstanceReadModel>, PgMetaError>

pub fn get_entity_instance( &mut self, instance_id: i64, ) -> Result<Option<PgEntityInstanceReadModel>, PgMetaError>

pub fn get_entity_instance_by_uuid( &mut self, uuid: Uuid, ) -> Result<Option<PgEntityInstanceReadModel>, PgMetaError>

pub fn get_study_entity_instance( &mut self, study_id: StudyId, entity_id: EntityId, external_id: &str, ) -> Result<Option<PgStudyEntityInstanceReadModel>, PgMetaError>

pub fn list_study_entity_instances( &mut self, study_id: StudyId, ) -> Result<Vec<PgStudyEntityInstanceReadModel>, PgMetaError>

pub fn list_relation_instances_for_relation( &mut self, entity_relation_id: EntityRelationId, ) -> Result<Vec<PgRelationInstanceReadModel>, PgMetaError>

pub fn get_relation_instance( &mut self, relation_instance_id: i64, ) -> Result<Option<PgRelationInstanceReadModel>, PgMetaError>

pub fn get_relation_instance_by_uuid( &mut self, uuid: Uuid, ) -> Result<Option<PgRelationInstanceReadModel>, PgMetaError>

pub fn get_study_relation_instance( &mut self, study_id: StudyId, entity_relation_id: EntityRelationId, external_id: &str, ) -> Result<Option<PgStudyRelationInstanceReadModel>, PgMetaError>

pub fn list_study_relation_instances( &mut self, study_id: StudyId, ) -> Result<Vec<PgStudyRelationInstanceReadModel>, PgMetaError>

pub fn list_asset_version_entities( &mut self, version_id: VersionId, ) -> Result<Vec<PgAssetVersionEntityReadModel>, PgMetaError>

pub fn list_asset_version_entities_for_instance( &mut self, entity_instance_id: i64, ) -> Result<Vec<PgAssetVersionEntityReadModel>, PgMetaError>

pub fn list_dataset_version_entities( &mut self, version_id: VersionId, ) -> Result<Vec<PgDatasetVersionEntityReadModel>, PgMetaError>

pub fn list_dataset_version_entities_for_instance( &mut self, entity_instance_id: i64, ) -> Result<Vec<PgDatasetVersionEntityReadModel>, PgMetaError>

pub fn list_asset_version_relation_instances( &mut self, version_id: VersionId, ) -> Result<Vec<PgAssetVersionRelationInstanceReadModel>, PgMetaError>

pub fn list_asset_version_relation_instances_for_instance( &mut self, relation_instance_id: i64, ) -> Result<Vec<PgAssetVersionRelationInstanceReadModel>, PgMetaError>

pub fn list_dataset_version_relation_instances( &mut self, version_id: VersionId, ) -> Result<Vec<PgDatasetVersionRelationInstanceReadModel>, PgMetaError>

pub fn list_dataset_version_relation_instances_for_instance( &mut self, relation_instance_id: i64, ) -> Result<Vec<PgDatasetVersionRelationInstanceReadModel>, PgMetaError>

pub fn list_transformations( &mut self, ) -> Result<Vec<PgTransformationReadModel>, PgMetaError>

pub fn get_transformation( &mut self, transformation_id: TransformationId, ) -> Result<Option<PgTransformationReadModel>, PgMetaError>

pub fn list_transformation_inputs( &mut self, transformation_id: TransformationId, ) -> Result<Vec<PgTransformationInputReadModel>, PgMetaError>

pub fn list_transformation_inputs_for_version( &mut self, version_id: VersionId, ) -> Result<Vec<PgTransformationInputReadModel>, PgMetaError>

pub fn list_transformation_outputs( &mut self, transformation_id: TransformationId, ) -> Result<Vec<PgTransformationOutputReadModel>, PgMetaError>

pub fn list_transformation_outputs_for_version( &mut self, version_id: VersionId, ) -> Result<Vec<PgTransformationOutputReadModel>, PgMetaError>

pub fn list_transformations_producing_version( &mut self, version_id: VersionId, ) -> Result<Vec<PgTransformationReadModel>, PgMetaError>

pub fn list_tags_for_target( &mut self, target: PgTagTarget, ) -> Result<Vec<String>, PgMetaError>

pub fn list_tag_records_for_target( &mut self, target: PgTagTarget, ) -> Result<Vec<PgTagReadModel>, PgMetaError>

pub fn list_study_tag_links( &mut self, study_id: StudyId, ) -> Result<Vec<PgStudyTagReadModel>, PgMetaError>

pub fn list_domain_tag_links( &mut self, domain_id: DomainId, ) -> Result<Vec<PgDomainTagReadModel>, PgMetaError>

pub fn list_variable_tag_links( &mut self, variable_id: VariableId, ) -> Result<Vec<PgVariableTagReadModel>, PgMetaError>

pub fn list_asset_tag_links( &mut self, asset_id: AssetId, ) -> Result<Vec<PgAssetTagReadModel>, PgMetaError>

pub fn list_asset_version_tag_links( &mut self, version_id: VersionId, ) -> Result<Vec<PgAssetVersionTagReadModel>, PgMetaError>

pub fn list_entity_tag_links( &mut self, entity_id: EntityId, ) -> Result<Vec<PgEntityTagReadModel>, PgMetaError>

pub fn list_entity_relation_tag_links( &mut self, entity_relation_id: EntityRelationId, ) -> Result<Vec<PgEntityRelationTagReadModel>, PgMetaError>

pub fn list_tags(&mut self) -> Result<Vec<PgTagReadModel>, PgMetaError>

impl PgMetadataConnection

pub fn create_study( &mut self, input: PgCreateStudy, ) -> Result<StudyId, PgMetaError>

pub fn create_domain( &mut self, input: PgCreateDomain, ) -> Result<DomainId, PgMetaError>

pub fn link_study_domain( &mut self, study_id: StudyId, domain_id: DomainId, ) -> Result<(), PgMetaError>

pub fn grant_study_access( &mut self, study_id: StudyId, user_id: &str, ) -> Result<(), PgMetaError>

pub fn add_study_delegate_custodian( &mut self, study_id: StudyId, user_id: &str, ) -> Result<(), PgMetaError>

pub fn transfer_study_primary_custodianship( &mut self, study_id: StudyId, user_id: &str, ) -> Result<(), PgMetaError>

pub fn remove_study_delegate_custodian( &mut self, study_id: StudyId, user_id: &str, ) -> Result<(), PgMetaError>

pub fn revoke_study_access( &mut self, study_id: StudyId, user_id: &str, ) -> Result<(), PgMetaError>

pub fn grant_study_access_with_metadata( &mut self, study_id: StudyId, user_id: &str, date_granted: Option<DateTime<Utc>>, granted_by: Option<&str>, ) -> Result<(), PgMetaError>

pub fn add_study_custodian( &mut self, study_id: StudyId, user_id: &str, is_primary: bool, ) -> Result<(), PgMetaError>

pub fn add_study_custodian_with_metadata( &mut self, study_id: StudyId, user_id: &str, is_primary: bool, date_granted: Option<DateTime<Utc>>, granted_by: Option<&str>, ) -> Result<(), PgMetaError>

pub fn create_vocabulary( &mut self, input: PgCreateVocabulary, ) -> Result<VocabularyId, PgMetaError>

pub fn create_vocabulary_item( &mut self, input: PgCreateVocabularyItem, ) -> Result<VocabularyItemId, PgMetaError>

pub fn create_vocabulary_mapping( &mut self, input: PgCreateVocabularyMapping, ) -> Result<i64, PgMetaError>

pub fn create_variable( &mut self, input: PgCreateVariable, ) -> Result<VariableId, PgMetaError>

pub fn update_variable( &mut self, input: PgCreateVariable, ) -> Result<(), PgMetaError>

pub fn update_vocabulary( &mut self, input: PgCreateVocabulary, ) -> Result<(), PgMetaError>

pub fn update_vocabulary_item( &mut self, input: PgCreateVocabularyItem, ) -> Result<(), PgMetaError>

pub fn link_dataset_variable( &mut self, dataset_id: VersionId, variable_id: VariableId, row_role: KeyRole, ) -> Result<(), PgMetaError>

pub fn create_transformation( &mut self, input: PgCreateTransformation, ) -> Result<TransformationId, PgMetaError>

pub fn delete_transformation( &mut self, transformation_id: TransformationId, ) -> Result<bool, PgMetaError>

pub fn create_asset( &mut self, input: PgCreateAsset, ) -> Result<AssetId, PgMetaError>

pub fn create_asset_version( &mut self, input: PgCreateAssetVersion, ) -> Result<VersionId, PgMetaError>

pub fn create_dataset( &mut self, dataset_id: VersionId, ) -> Result<(), PgMetaError>

pub fn create_datafile( &mut self, input: PgCreateDataFile, ) -> Result<(), PgMetaError>

pub fn create_dataset_version( &mut self, asset: PgCreateAsset, version: PgCreateAssetVersion, ) -> Result<VersionId, PgMetaError>

pub fn create_datafile_version( &mut self, asset: PgCreateAsset, version: PgCreateAssetVersion, datafile: PgCreateDataFile, ) -> Result<VersionId, PgMetaError>

pub fn create_duo_code( &mut self, input: PgCreateDuoCode, ) -> Result<(), PgMetaError>

pub fn add_study_duo_restriction( &mut self, study_id: StudyId, duo_id: &str, qualifiers: PgDuoQualifiers, ) -> Result<i64, PgMetaError>

pub fn create_study_duo_restriction( &mut self, input: PgCreateStudyDuoRestriction, ) -> Result<i64, PgMetaError>

pub fn add_asset_version_duo_restriction( &mut self, version_id: VersionId, duo_id: &str, qualifiers: PgDuoQualifiers, ) -> Result<i64, PgMetaError>

pub fn create_asset_version_duo_restriction( &mut self, input: PgCreateAssetVersionDuoRestriction, ) -> Result<i64, PgMetaError>

pub fn create_entity( &mut self, input: PgCreateEntity, ) -> Result<EntityId, PgMetaError>

pub fn create_entity_relation( &mut self, input: PgCreateEntityRelation, ) -> Result<EntityRelationId, PgMetaError>

pub fn create_entity_instance_in_study( &mut self, input: PgCreateEntityInstanceInStudy, ) -> Result<i64, PgMetaError>

pub fn create_relation_instance_in_study( &mut self, input: PgCreateRelationInstanceInStudy, ) -> Result<i64, PgMetaError>

pub fn save_entity_instance( &mut self, input: PgWriteEntityInstance, ) -> Result<i64, PgMetaError>

pub fn save_study_entity_instance( &mut self, input: PgWriteStudyEntityInstance, ) -> Result<(), PgMetaError>

pub fn save_relation_instance( &mut self, input: PgWriteRelationInstance, ) -> Result<i64, PgMetaError>

pub fn save_study_relation_instance( &mut self, input: PgWriteStudyRelationInstance, ) -> Result<(), PgMetaError>

pub fn link_asset_version_entity( &mut self, version_id: VersionId, entity_instance_id: i64, transformation_id: TransformationId, ) -> Result<(), PgMetaError>

pub fn add_dataset_version_entity( &mut self, version_id: VersionId, entity_instance_id: i64, entity_variable_id: VariableId, transformation_id: TransformationId, ) -> Result<(), PgMetaError>

pub fn link_dataset_version_entities( &mut self, links: &[(VersionId, i64, VariableId, TransformationId)], ) -> Result<(), PgMetaError>

pub fn link_asset_version_relation_instance( &mut self, version_id: VersionId, relation_instance_id: i64, transformation_id: TransformationId, ) -> Result<(), PgMetaError>

pub fn add_dataset_version_relation( &mut self, version_id: VersionId, relation_instance_id: i64, subject_variable_id: VariableId, object_variable_id: VariableId, relation_variable_id: Option<VariableId>, transformation_id: TransformationId, ) -> Result<(), PgMetaError>

pub fn link_dataset_version_relation_instances( &mut self, links: &[(VersionId, i64, VariableId, VariableId, Option<VariableId>, TransformationId)], ) -> Result<(), PgMetaError>

pub fn link_transformation_input( &mut self, transformation_id: TransformationId, version_id: VersionId, ) -> Result<(), PgMetaError>

pub fn link_transformation_output( &mut self, transformation_id: TransformationId, version_id: VersionId, ) -> Result<(), PgMetaError>

pub fn upsert_tag(&mut self, name: &str) -> Result<i64, PgMetaError>

pub fn attach_tag( &mut self, target: PgWriteTagTarget, tag_id: i64, ) -> Result<(), PgMetaError>

pub fn detach_tag( &mut self, target: PgWriteTagTarget, tag_id: i64, ) -> Result<(), PgMetaError>

pub fn delete_tag_if_unused(&mut self, tag_id: i64) -> Result<bool, PgMetaError>

Trait Implementations

impl Debug for PgMetadataConnection

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

Formats the value using the given formatter.

impl MetadataExecutor for PgMetadataConnection

type Row = Row

Row representation returned by the concrete executor.

fn query_one( &mut self, operation: &'static str, statement: &str, params: MetadataParameters<'_>, ) -> Result<Self::Row, PgMetaError>

Runs a query expected to return exactly one row.

fn query_optional( &mut self, operation: &'static str, statement: &str, params: MetadataParameters<'_>, ) -> Result<Option<Self::Row>, PgMetaError>

Runs a query expected to return zero or one row.

fn query_many( &mut self, operation: &'static str, statement: &str, params: MetadataParameters<'_>, ) -> Result<Vec<Self::Row>, PgMetaError>

Runs a query that can return many rows.

fn execute_command( &mut self, operation: &'static str, statement: &str, params: MetadataParameters<'_>, ) -> Result<u64, PgMetaError>

Executes a metadata write command.

fn with_transaction<T>( &mut self, operation: &'static str, f: impl FnOnce(&mut dyn MetadataTransaction<Row = Self::Row>) -> Result<T, PgMetaError>, ) -> Result<T, PgMetaError>

Runs caller-supplied work inside a metadata transaction.

impl RequesterStudyAccessRequestPort for PgMetadataConnection

fn list_requester_study_access_requests( &mut self, scope: &ApplicationRequesterStudyAccessRequests, ) -> Result<Vec<ApplicationRequesterStudyAccessRequest>, RequesterStudyAccessRequestPortError>

fn get_requester_study_access_request( &mut self, scope: &ApplicationRequesterStudyAccessRequests, request_id: Uuid, ) -> Result<Option<ApplicationRequesterStudyAccessRequest>, RequesterStudyAccessRequestPortError>

fn withdraw_requester_study_access_request( &mut self, scope: &ApplicationRequesterStudyAccessRequests, request_id: Uuid, ) -> Result<RequesterStudyAccessRequestWithdrawalOutcome, RequesterStudyAccessRequestPortError>

impl StudyAccessRequestMetadataExecutor for PgMetadataConnection

fn submit_study_access_request( &mut self, submission: &AccessRequestSubmission, ) -> Result<AccessRequestSubmissionOutcome, PgMetaError>

Submits a pending access request after checking the selected Study and an existing pending request for the same requester.

fn list_requester_study_access_requests( &mut self, scope: &RequesterStudyAccessRequestScope, ) -> Result<Vec<RequesterStudyAccessRequest>, PgMetaError>

Lists access requests owned by a requester in the selected datastore.

fn get_requester_study_access_request( &mut self, scope: &RequesterStudyAccessRequestScope, request_id: AccessRequestId, ) -> Result<Option<RequesterStudyAccessRequest>, PgMetaError>

Finds an access request owned by a requester in the selected datastore.

fn withdraw_requester_study_access_request( &mut self, scope: &RequesterStudyAccessRequestScope, request_id: AccessRequestId, ) -> Result<AccessRequestWithdrawalOutcome, PgMetaError>

Atomically withdraws a pending access request owned by a requester in the selected datastore.

fn list_custodian_study_access_requests( &mut self, datastore_id: AccessRequestDatastoreId, status: CustodianStudyAccessRequestStatusFilter, ) -> Result<Vec<CustodianStudyAccessRequest>, PgMetaError>

Lists access requests in one supported status visible to the current custodian actor.

fn reject_custodian_study_access_request( &mut self, rejection: &CustodianStudyAccessRequestRejection, ) -> Result<AccessRequestCustodianDecisionOutcome, PgMetaError>

Rejects a pending request when the current database actor custodians its Study.

fn inspect_custodian_study_access_request( &mut self, scope: &CustodianStudyAccessRequestScope, ) -> Result<AccessRequestCustodianInspection, PgMetaError>

Inspects a request before a caller provisions workflow entry for its requester and attempts a governed approval.

fn approve_custodian_study_access_request( &mut self, approval: &CustodianStudyAccessRequestApproval, ) -> Result<AccessRequestCustodianApprovalOutcome, PgMetaError>

Grants the preflighted requester access to the request’s Study and records an audited approval in one governed database statement.

impl StudyAccessRequestSubmissionPort for PgMetadataConnection

fn submit_study_access_request( &mut self, submission: &ApplicationAccessRequestSubmission, ) -> Result<ApplicationAccessRequestSubmissionOutcome, StudyAccessRequestSubmissionPortError>