Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/postgresql/storage.py
| Show First 20 Lines • Show All 45 Lines • ▼ Show 20 Lines | from swh.model.model import ( | ||||
| SHA1_SIZE, | SHA1_SIZE, | ||||
| MetadataAuthority, | MetadataAuthority, | ||||
| MetadataAuthorityType, | MetadataAuthorityType, | ||||
| MetadataFetcher, | MetadataFetcher, | ||||
| MetadataTargetType, | MetadataTargetType, | ||||
| RawExtrinsicMetadata, | RawExtrinsicMetadata, | ||||
| ) | ) | ||||
| from swh.model.hashutil import DEFAULT_ALGORITHMS, hash_to_bytes, hash_to_hex | from swh.model.hashutil import DEFAULT_ALGORITHMS, hash_to_bytes, hash_to_hex | ||||
| from swh.storage.algos import diff | |||||
| from swh.storage.exc import StorageArgumentException, StorageDBError, HashCollision | from swh.storage.exc import StorageArgumentException, StorageDBError, HashCollision | ||||
| from swh.storage.interface import ( | from swh.storage.interface import ( | ||||
| ListOrder, | ListOrder, | ||||
| PagedResult, | PagedResult, | ||||
| PartialBranches, | PartialBranches, | ||||
| VISIT_STATUSES, | VISIT_STATUSES, | ||||
| ) | ) | ||||
| from swh.storage.metrics import timed, send_metric, process_metrics | from swh.storage.metrics import timed, send_metric, process_metrics | ||||
| ▲ Show 20 Lines • Show All 1,334 Lines • ▼ Show 20 Lines | |||||
| def metadata_authority_get( | def metadata_authority_get( | ||||
| self, type: MetadataAuthorityType, url: str, db=None, cur=None | self, type: MetadataAuthorityType, url: str, db=None, cur=None | ||||
| ) -> Optional[MetadataAuthority]: | ) -> Optional[MetadataAuthority]: | ||||
| row = db.metadata_authority_get(type.value, url, cur=cur) | row = db.metadata_authority_get(type.value, url, cur=cur) | ||||
| if not row: | if not row: | ||||
| return None | return None | ||||
| return MetadataAuthority.from_dict(dict(zip(db.metadata_authority_cols, row))) | return MetadataAuthority.from_dict(dict(zip(db.metadata_authority_cols, row))) | ||||
| @timed | |||||
| def diff_directories(self, from_dir, to_dir, track_renaming=False): | |||||
| return diff.diff_directories(self, from_dir, to_dir, track_renaming) | |||||
| @timed | |||||
| def diff_revisions(self, from_rev, to_rev, track_renaming=False): | |||||
| return diff.diff_revisions(self, from_rev, to_rev, track_renaming) | |||||
| @timed | |||||
| def diff_revision(self, revision, track_renaming=False): | |||||
| return diff.diff_revision(self, revision, track_renaming) | |||||
| def clear_buffers(self, object_types: Optional[List[str]] = None) -> None: | def clear_buffers(self, object_types: Optional[List[str]] = None) -> None: | ||||
| """Do nothing | """Do nothing | ||||
| """ | """ | ||||
| return None | return None | ||||
| def flush(self, object_types: Optional[List[str]] = None) -> Dict: | def flush(self, object_types: Optional[List[str]] = None) -> Dict: | ||||
| return {} | return {} | ||||
| Show All 14 Lines | |||||