swh.objstorage.backends.winery package

Subpackages:

• swh.objstorage.backends.winery.pools package
  • swh.objstorage.backends.winery.pools.rbd module
    • RBDPool
  • swh.objstorage.backends.winery.pools.shard module
    • ShardBackedPool
  • ImageReader
    • ImageReader.lookup()
    • ImageReader.close()
  • ImageWriter
    • ImageWriter.write()
  • Pool
    • Pool.pool_name
    • Pool.image_exists()
    • Pool.image_mapped()
    • Pool.image_list()
    • Pool.image_path()
    • Pool.image_create()
    • Pool.image_map()
    • Pool.image_unmap()
    • Pool.image_remap_ro()
    • Pool.image_import()
    • Pool.image_open()
    • Pool.delete_object()
    • Pool.open_writer()
  • FileBackedPool
    • FileBackedPool.image_exists()
    • FileBackedPool.image_list()
    • FileBackedPool.image_path()
    • FileBackedPool.image_create()
    • FileBackedPool.image_map()
    • FileBackedPool.image_unmap()
    • FileBackedPool.image_unmap_all()
    • FileBackedPool.image_import()
  • pool_from_settings()
• swh.objstorage.backends.winery.sql package

Submodules:

• swh.objstorage.backends.winery.cli module
  • install_signal_handlers()
  • Duration
    • Duration.name
    • Duration.DEFAULT_PATTERN
    • Duration.convert()
  • shards_by_locker()
• swh.objstorage.backends.winery.database module
  • Database
    • Database.pool
    • Database.list_shard_tables()
• swh.objstorage.backends.winery.gunicorn module
  • worker_exit()
  • worker_int()
  • shutdown_storage_backend()
  • ThrottledAccessLog
    • ThrottledAccessLog.filter()
• swh.objstorage.backends.winery.housekeeping module
  • AbortOperation
  • never_stop()
  • stop_after_shards()
  • shard_packer()
  • pack()
  • rw_shard_cleaner()
  • cleanup_rw_shard()
  • deleted_objects_cleaner()
  • import_ro_shards()
• swh.objstorage.backends.winery.objstorage module
  • get_datastore()
  • WineryObjStorage
    • WineryObjStorage.primary_hash
    • WineryObjStorage.name
    • WineryObjStorage.get()
    • WineryObjStorage.check_config()
    • WineryObjStorage.add()
    • WineryObjStorage.add_batch()
    • WineryObjStorage.delete()
    • WineryObjStorage.on_shutdown()
  • LRUDict
  • WineryReader
    • WineryReader.list_signatures()
    • WineryReader.roshard()
    • WineryReader.rwshard()
    • WineryReader.get()
    • WineryReader.on_shutdown()
  • WineryWriter
    • WineryWriter.release_shard()
    • WineryWriter.shard
    • WineryWriter.add()
    • WineryWriter.add_batch()
    • WineryWriter.delete()
    • WineryWriter.check()
    • WineryWriter.pack()
    • WineryWriter.on_shutdown()
• swh.objstorage.backends.winery.roshard module
  • ShardNotMapped
  • record_shard_mapped()
  • 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
  • ShardObjectsCount
    • ShardObjectsCount.count
    • ShardObjectsCount.volume
  • 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.add_batch()
    • RWShard.get()
    • RWShard.delete()
    • RWShard.all()
    • RWShard.count()
• swh.objstorage.backends.winery.settings module
  • Packer
    • Packer.create_images
    • Packer.pack_immediately
    • Packer.clean_immediately
  • packer_settings_with_defaults()
  • Shards
    • Shards.max_size
    • Shards.rw_idle_timeout
  • shards_settings_with_defaults()
  • ShardsPool
    • ShardsPool.type
    • ShardsPool.pool_name
  • RbdShardsPool
    • RbdShardsPool.use_sudo
    • RbdShardsPool.map_options
    • RbdShardsPool.data_pool_name
    • RbdShardsPool.image_features_unsupported
    • RbdShardsPool.type
    • RbdShardsPool.pool_name
  • rbd_shards_pool_settings_with_defaults()
  • DirectoryShardsPool
    • DirectoryShardsPool.base_directory
    • DirectoryShardsPool.type
    • DirectoryShardsPool.pool_name
  • directory_shards_pool_settings_with_defaults()
  • Database
    • Database.db
    • Database.application_name
  • database_settings_with_defaults()
  • Winery
    • Winery.database
    • Winery.shards
    • Winery.shards_pools
    • Winery.shards_active_pool
    • Winery.packer
    • Winery.readers_cache_size
  • populate_default_settings()
• 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.get_shard_pool()
    • SharedBase.list_shards()
    • SharedBase.list_open_shards()
    • SharedBase.list_stale_shards()
    • SharedBase.count_objects()
    • SharedBase.record_shard_mapped()
    • SharedBase.contains()
    • SharedBase.get()
    • SharedBase.record_new_obj_ids()
    • SharedBase.list_signatures()
    • SharedBase.delete()
    • SharedBase.deleted_objects()
    • SharedBase.clean_deleted_object()
• swh.objstorage.backends.winery.sleep module
  • sleep_exponential()

Module contents: