Changeset View
Changeset View
Standalone View
Standalone View
swh/objstorage/api/client.py
Show All 39 Lines | def get(self, obj_id): | ||||
return self.post('content/get', {'obj_id': obj_id}) | return self.post('content/get', {'obj_id': obj_id}) | ||||
def get_batch(self, obj_ids): | def get_batch(self, obj_ids): | ||||
return self.post('content/get/batch', {'obj_ids': obj_ids}) | return self.post('content/get/batch', {'obj_ids': obj_ids}) | ||||
def check(self, obj_id): | def check(self, obj_id): | ||||
return self.post('content/check', {'obj_id': obj_id}) | return self.post('content/check', {'obj_id': obj_id}) | ||||
def delete(self, obj_id): | |||||
return self.post('content/delete', {'obj_id': obj_id}) | |||||
# Management methods | # Management methods | ||||
def get_random(self, batch_size): | def get_random(self, batch_size): | ||||
return self.post('content/get/random', {'batch_size': batch_size}) | return self.post('content/get/random', {'batch_size': batch_size}) | ||||
# Streaming methods | # Streaming methods | ||||
def add_stream(self, content_iter, obj_id, check_presence=True): | def add_stream(self, content_iter, obj_id, check_presence=True): | ||||
Show All 9 Lines |