swh.objstorage.backends.winery package

Subpackages:

• swh.objstorage.backends.winery.sql package

Submodules:

• swh.objstorage.backends.winery.database module
  • Database
    • Database.pool
    • Database.list_shard_tables()
• swh.objstorage.backends.winery.gunicorn module
  • worker_int()
• swh.objstorage.backends.winery.objstorage module
  • WineryObjStorage
    • WineryObjStorage.PRIMARY_HASH
    • WineryObjStorage.get()
    • WineryObjStorage.check_config()
    • WineryObjStorage.add()
    • WineryObjStorage.delete()
    • WineryObjStorage.on_shutdown()
  • WineryBase
    • WineryBase.on_shutdown()
  • WineryReader
    • WineryReader.roshard()
    • WineryReader.rwshard()
    • WineryReader.get()
  • pack()
  • cleanup_rw_shard()
  • WineryWriter
    • WineryWriter.release_shard()
    • WineryWriter.shard
    • WineryWriter.add()
    • WineryWriter.delete()
    • WineryWriter.check()
    • WineryWriter.pack()
    • WineryWriter.on_shutdown()
  • never_stop()
  • stop_after_shards()
  • shard_packer()
  • rw_shard_cleaner()
  • deleted_objects_cleaner()
• swh.objstorage.backends.winery.roshard module
  • ShardNotMapped
  • Pool
    • Pool.POOL_CONFIG
    • Pool.from_kwargs()
    • Pool.run()
    • Pool.rbd()
    • Pool.image_exists()
    • Pool.image_mapped()
    • Pool.image_list()
    • Pool.image_path()
    • Pool.image_create()
    • Pool.image_map()
    • Pool.image_remap_ro()
    • Pool.image_unmap()
    • Pool.manage_images()
  • ROShard
    • ROShard.open()
    • ROShard.get()
    • ROShard.close()
    • ROShard.delete()
  • ROShardCreator
    • ROShardCreator.zero_image_if_needed()
    • ROShardCreator.add()
• swh.objstorage.backends.winery.rwshard module
  • IdleHandler
    • IdleHandler.quiesce()
    • IdleHandler.reset()
    • IdleHandler.quiesce_then_reset()
    • IdleHandler.join()
    • IdleHandler.run()
  • ShardIdleTimeoutCallback
  • RWShard
    • RWShard.disable_idle_handler()
    • RWShard.name
    • RWShard.table_name
    • RWShard.is_full()
    • RWShard.create()
    • RWShard.drop()
    • RWShard.total_size()
    • RWShard.add()
    • RWShard.get()
    • RWShard.delete()
    • RWShard.all()
    • RWShard.count()
• swh.objstorage.backends.winery.sharedbase module
  • ShardState
    • ShardState.STANDBY
    • ShardState.WRITING
    • ShardState.FULL
    • ShardState.PACKING
    • ShardState.PACKED
    • ShardState.CLEANING
    • ShardState.READONLY
    • ShardState.locked
    • ShardState.image_available
    • ShardState.readonly
  • SignatureState
    • SignatureState.INFLIGHT
    • SignatureState.PRESENT
    • SignatureState.DELETED
  • TemporaryShardLocker
  • SharedBase
    • SharedBase.current_version
    • SharedBase.locked_shard
    • SharedBase.locked_shard_id
    • SharedBase.set_locked_shard()
    • SharedBase.lock_one_shard()
    • SharedBase.maybe_lock_one_shard()
    • SharedBase.set_shard_state()
    • SharedBase.create_shard()
    • SharedBase.shard_packing_starts()
    • SharedBase.shard_packing_ends()
    • SharedBase.get_shard_info()
    • SharedBase.get_shard_state()
    • SharedBase.list_shards()
    • SharedBase.count_objects()
    • SharedBase.record_shard_mapped()
    • SharedBase.contains()
    • SharedBase.get()
    • SharedBase.record_new_obj_id()
    • SharedBase.delete()
    • SharedBase.deleted_objects()
    • SharedBase.clean_deleted_object()
• swh.objstorage.backends.winery.sleep module
  • sleep_exponential()
• swh.objstorage.backends.winery.stats module
  • Stats
    • Stats.stats_active
    • Stats.stats_filename
    • Stats.stats_read()
    • Stats.stats_write()
• swh.objstorage.backends.winery.throttler module
  • LeakyBucket
    • LeakyBucket.reset()
    • LeakyBucket.add()
  • BandwidthCalculator
    • BandwidthCalculator.add()
    • BandwidthCalculator.get()
  • IOThrottler
    • IOThrottler.init_db()
    • IOThrottler.download_info()
    • IOThrottler.upload_info()
    • IOThrottler.add()
    • IOThrottler.sync()
    • IOThrottler.maybe_sync()
  • Throttler
    • Throttler.throttle_get()
    • Throttler.throttle_add()

Module contents:

swh.objstorage.backends.winery.get_datastore(cls, db)