Changeset View
Changeset View
Standalone View
Standalone View
swh/provenance/postgresql/archive.py
| from typing import Any, Dict, List | from typing import Any, Dict, Iterable, List | ||||
| from methodtools import lru_cache | from methodtools import lru_cache | ||||
| import psycopg2 | import psycopg2 | ||||
| class ArchivePostgreSQL: | class ArchivePostgreSQL: | ||||
| def __init__(self, conn: psycopg2.extensions.connection): | def __init__(self, conn: psycopg2.extensions.connection): | ||||
| self.conn = conn | self.conn = conn | ||||
| ▲ Show 20 Lines • Show All 52 Lines • ▼ Show 20 Lines | def iter_origins(self): | ||||
| raise NotImplementedError | raise NotImplementedError | ||||
| def iter_origin_visits(self, origin: str): | def iter_origin_visits(self, origin: str): | ||||
| raise NotImplementedError | raise NotImplementedError | ||||
| def iter_origin_visit_statuses(self, origin: str, visit: int): | def iter_origin_visit_statuses(self, origin: str, visit: int): | ||||
| raise NotImplementedError | raise NotImplementedError | ||||
| def release_get(self, ids: List[bytes]): | def release_get(self, ids: Iterable[bytes]): | ||||
| raise NotImplementedError | raise NotImplementedError | ||||
| def revision_get(self, ids: List[bytes]): | def revision_get(self, ids: Iterable[bytes]): | ||||
| raise NotImplementedError | raise NotImplementedError | ||||
| def snapshot_get_all_branches(self, snapshot: bytes): | def snapshot_get_all_branches(self, snapshot: bytes): | ||||
| raise NotImplementedError | raise NotImplementedError | ||||