Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/api/client.py
| Show First 20 Lines • Show All 191 Lines • ▼ Show 20 Lines | class RemoteStorage(RPCClient): | ||||
| def origin_visit_get_latest(self, origin, allowed_statuses=None, | def origin_visit_get_latest(self, origin, allowed_statuses=None, | ||||
| require_snapshot=False): | require_snapshot=False): | ||||
| return self.post( | return self.post( | ||||
| 'origin/visit/get_latest', | 'origin/visit/get_latest', | ||||
| {'origin': origin, 'allowed_statuses': allowed_statuses, | {'origin': origin, 'allowed_statuses': allowed_statuses, | ||||
| 'require_snapshot': require_snapshot}) | 'require_snapshot': require_snapshot}) | ||||
| def fetch_history_start(self, origin_id): | |||||
| return self.post('fetch_history/start', {'origin_id': origin_id}) | |||||
| def fetch_history_end(self, fetch_history_id, data): | |||||
| return self.post('fetch_history/end', | |||||
| {'fetch_history_id': fetch_history_id, | |||||
| 'data': data}) | |||||
| def fetch_history_get(self, fetch_history_id): | |||||
| return self.get('fetch_history', {'id': fetch_history_id}) | |||||
| def stat_counters(self): | def stat_counters(self): | ||||
| return self.get('stat/counters') | return self.get('stat/counters') | ||||
| def refresh_stat_counters(self): | def refresh_stat_counters(self): | ||||
| return self.get('stat/refresh') | return self.get('stat/refresh') | ||||
| def directory_entry_get_by_path(self, directory, paths): | def directory_entry_get_by_path(self, directory, paths): | ||||
| return self.post('directory/path', dict(directory=directory, | return self.post('directory/path', dict(directory=directory, | ||||
| ▲ Show 20 Lines • Show All 50 Lines • Show Last 20 Lines | |||||