swh.objstorage.backends.winery.objstorage module#

class swh.objstorage.backends.winery.objstorage.WineryObjStorage(**kwargs)[source]#

Bases: ObjStorage

uninit()[source]#
get(obj_id: Union[bytes, CompositeObjId]) → bytes[source]#
check_config(*, check_write)[source]#
add(content: bytes, obj_id: Union[bytes, CompositeObjId], check_presence: bool = True) → None[source]#
check(obj_id: Union[bytes, CompositeObjId]) → None[source]#
delete(obj_id: Union[bytes, CompositeObjId])[source]#
class swh.objstorage.backends.winery.objstorage.WineryBase(**kwargs)[source]#

Bases: object

init()[source]#
uninit()[source]#
class swh.objstorage.backends.winery.objstorage.WineryReader(**kwargs)[source]#

Bases: WineryBase

roshard(name)[source]#
get(obj_id: Union[bytes, CompositeObjId]) → bytes[source]#
swh.objstorage.backends.winery.objstorage.pack(shard, **kwargs)[source]#
class swh.objstorage.backends.winery.objstorage.Packer(shard, **kwargs)[source]#

Bases: object

init()[source]#
uninit()[source]#
run()[source]#
class swh.objstorage.backends.winery.objstorage.WineryWriter(**kwargs)[source]#

Bases: WineryReader

init()[source]#
uninit()[source]#
add(content: bytes, obj_id: Union[bytes, CompositeObjId], check_presence: bool = True) → None[source]#
check(obj_id: Union[bytes, CompositeObjId]) → None[source]#
pack()[source]#