Changeset View
Changeset View
Standalone View
Standalone View
swh/archiver/storage.py
| Show All 26 Lines | def __init__(self, dbconn): | ||||
| if isinstance(dbconn, psycopg2.extensions.connection): | if isinstance(dbconn, psycopg2.extensions.connection): | ||||
| self._db = ArchiverDb(dbconn) | self._db = ArchiverDb(dbconn) | ||||
| else: | else: | ||||
| self._db = ArchiverDb.connect(dbconn) | self._db = ArchiverDb.connect(dbconn) | ||||
| def get_db(self): | def get_db(self): | ||||
| return self._db | return self._db | ||||
| def put_db(self, db): | |||||
| pass | |||||
| @db_transaction_generator() | @db_transaction_generator() | ||||
| def archive_ls(self, db=None, cur=None): | def archive_ls(self, db=None, cur=None): | ||||
| """ Get all the archives registered on the server. | """ Get all the archives registered on the server. | ||||
| Yields: | Yields: | ||||
| a tuple (server_id, server_url) for each archive server. | a tuple (server_id, server_url) for each archive server. | ||||
| """ | """ | ||||
| yield from db.archive_ls(cur) | yield from db.archive_ls(cur) | ||||
| ▲ Show 20 Lines • Show All 312 Lines • Show Last 20 Lines | |||||