in src/dma/collector/query_managers/postgres.py [0:0]
def get_collection_filenames(self) -> dict[str, str]:
if self.db_version is None:
msg = "Database Version was not set. Ensure the initialization step complete successfully."
raise ApplicationError(msg)
major_version = get_db_major_version(self.db_version)
version_prefix = "base" if major_version > 13 else "13" if major_version == 13 else "12"
return {
f"collection_postgres_{version_prefix}_table_details": "postgres_table_details",
f"collection_postgres_{version_prefix}_database_details": "postgres_database_details",
f"collection_postgres_{version_prefix}_replication_slots": "postgres_replication_slots",
"collection_postgres_applications": "postgres_applications",
"collection_postgres_aws_extension_dependency": "postgres_aws_extension_dependency",
"collection_postgres_aws_oracle_exists": "postgres_aws_oracle_exists",
"collection_postgres_bg_writer_stats": "postgres_bg_writer_stats",
"collection_postgres_bg_writer_stats_from_pg17": "postgres_bg_writer_stats_from_pg17",
"collection_postgres_calculated_metrics": "postgres_calculated_metrics",
"collection_postgres_data_types": "postgres_data_types",
"collection_postgres_extensions": "postgres_extensions",
"collection_postgres_index_details": "postgres_index_details",
"collection_postgres_replication_stats": "postgres_replication_stats",
"collection_postgres_schema_details": "postgres_schema_details",
"collection_postgres_schema_objects": "postgres_schema_objects",
"collection_postgres_settings": "postgres_settings",
"collection_postgres_source_details": "postgres_source_details",
"collection_postgres_pglogical_provider_node": "postgres_pglogical_details",
"collection_postgres_tables_with_no_primary_key": "postgres_table_details",
"collection_postgres_tables_with_primary_key_replica_identity": "postgres_table_details",
"collection_postgres_replication_role": "collection_privileges",
}