swh.objstorage.factory module#
- swh.objstorage.factory.get_objstorage(cls: str, **kwargs) ObjStorageInterface [source]#
Create an ObjStorage using the given implementation class.
- Parameters:
cls – objstorage class unique key contained in the _STORAGE_CLASSES dict.
kwargs – arguments for the required class of objstorage that must match exactly the one in the __init__ method of the class.
- Returns:
subclass of ObjStorage that match the given storage_class argument.
- Raises:
ValueError – if the given storage class is not a valid objstorage key.
- class swh.objstorage.factory.ObjStorage(*, allow_delete=False, **kwargs)[source]#
Bases:
object
- add_batch(contents: Union[Mapping[bytes, bytes], Iterable[Tuple[Union[bytes, CompositeObjId], bytes]]], check_presence: bool = True) Dict [source]#
- abstract delete(obj_id: Union[bytes, CompositeObjId])[source]#
- list_content(last_obj_id: Optional[Union[bytes, CompositeObjId]] = None, limit: Optional[int] = 10000) Iterator[CompositeObjId] [source]#