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 |