swh.objstorage.backends.winery.objstorage module#

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

Bases: ObjStorage

PRIMARY_HASH: Literal['sha256'] = 'sha256'#
uninit()[source]#
get(obj_id: bytes | CompositeObjId) bytes[source]#
check_config(*, check_write: bool) bool[source]#
add(content: bytes, obj_id: bytes | CompositeObjId, check_presence: bool = True) None[source]#
check(obj_id: bytes | CompositeObjId) None[source]#
delete(obj_id: 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: 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: bytes | CompositeObjId, check_presence: bool = True) None[source]#
check(obj_id: bytes | CompositeObjId) None[source]#
pack()[source]#