swh.objstorage namespace

Subpackages:

• swh.objstorage.api namespace
  • swh.objstorage.api.client module
    • RemoteObjStorage
  • swh.objstorage.api.server module
    • timed()
    • timed_context()
    • get_objstorage()
    • ObjStorageServerApp
    • argument_error_handler()
    • permission_error_handler()
    • my_error_handler()
    • index()
    • load_and_check_config()
    • validate_config()
    • make_app_from_configfile()
• swh.objstorage.backends package
  • swh.objstorage.backends.seaweedfs package
    • swh.objstorage.backends.seaweedfs.http module
    • swh.objstorage.backends.seaweedfs.objstorage module
  • swh.objstorage.backends.winery package
    • swh.objstorage.backends.winery.sql package
    • swh.objstorage.backends.winery.database module
    • swh.objstorage.backends.winery.gunicorn module
    • swh.objstorage.backends.winery.objstorage module
    • swh.objstorage.backends.winery.roshard module
    • swh.objstorage.backends.winery.rwshard module
    • swh.objstorage.backends.winery.settings module
    • swh.objstorage.backends.winery.sharedbase module
    • swh.objstorage.backends.winery.sleep module
    • swh.objstorage.backends.winery.throttler module
    • WineryObjStorage
    • get_datastore()
  • swh.objstorage.backends.azure module
    • get_container_url()
    • AzureCloudObjStorage
    • PrefixedAzureCloudObjStorage
  • swh.objstorage.backends.http module
    • HTTPReadOnlyObjStorage
  • swh.objstorage.backends.in_memory module
    • InMemoryObjStorage
  • swh.objstorage.backends.libcloud module
    • patch_libcloud_s3_urlencode()
    • CloudObjStorage
    • AwsCloudObjStorage
    • OpenStackCloudObjStorage
  • swh.objstorage.backends.noop module
    • NoopObjStorage
  • swh.objstorage.backends.pathslicing module
    • is_valid_filename()
    • PathSlicer
    • PathSlicingObjStorage
• swh.objstorage.proxies namespace
  • swh.objstorage.proxies.readonly module
    • ReadOnlyProxyObjStorage
• swh.objstorage.replayer package
  • swh.objstorage.replayer.cli module
    • main()
  • swh.objstorage.replayer.replay module
    • LengthMismatch
    • HashMismatch
    • format_obj_id()
    • hex_obj_id()
    • logger_debug_obj_id()
    • is_hash_in_bytearray()
    • ReplayError
    • log_replay_retry()
    • log_replay_error()
    • retry_error_callback()
    • retry_log_if_success
    • get_object()
    • check_hashes()
    • put_object()
    • copy_object()
    • obj_in_objstorage()
    • ContentReplayer

Submodules:

• swh.objstorage.cli module
  • main()
• swh.objstorage.constants module
  • VALID_HEXCHARS
  • ID_HEXDIGEST_LENGTH_BY_ALGO
  • is_valid_hexdigest()
• swh.objstorage.exc module
  • Error
  • ObjNotFoundError
  • ObjCorruptedError
  • NoBackendsLeftError
  • ObjStorageAPIError
  • ReadOnlyObjStorageError
  • ReadOnlyObjStorage
  • NonIterableObjStorageError
  • NonIterableObjStorage
• swh.objstorage.factory module
  • get_objstorage()
  • ObjStorage
    • ObjStorage.add_batch()
    • ObjStorage.check()
    • ObjStorage.compress()
    • ObjStorage.compression
    • ObjStorage.decompress()
    • ObjStorage.delete()
    • ObjStorage.download_url()
    • ObjStorage.get()
    • ObjStorage.get_batch()
    • ObjStorage.name
    • ObjStorage.primary_hash
    • ObjStorage.restore()
• swh.objstorage.interface module
  • objid_from_dict()
  • ObjStorageInterface
    • ObjStorageInterface.name
    • ObjStorageInterface.primary_hash
    • ObjStorageInterface.check_config()
    • ObjStorageInterface.add()
    • ObjStorageInterface.add_batch()
    • ObjStorageInterface.restore()
    • ObjStorageInterface.get()
    • ObjStorageInterface.get_batch()
    • ObjStorageInterface.download_url()
    • ObjStorageInterface.check()
    • ObjStorageInterface.delete()
• swh.objstorage.multiplexer module
  • ObjStorageThread
    • ObjStorageThread.run()
    • ObjStorageThread.queue_command()
    • ObjStorageThread.queue_result()
    • ObjStorageThread.get_result_from_mailbox()
    • ObjStorageThread.collect_results()
  • MultiplexerObjStorage
    • MultiplexerObjStorage.name
    • MultiplexerObjStorage.reset_active_readers()
    • MultiplexerObjStorage.disable_backend()
    • MultiplexerObjStorage.enable_backend()
    • MultiplexerObjStorage.wrap_call()
    • MultiplexerObjStorage.get_read_threads()
    • MultiplexerObjStorage.get_write_threads()
    • MultiplexerObjStorage.check_config()
    • MultiplexerObjStorage.add()
    • MultiplexerObjStorage.add_batch()
    • MultiplexerObjStorage.restore()
    • MultiplexerObjStorage.get()
    • MultiplexerObjStorage.check()
    • MultiplexerObjStorage.delete()
• swh.objstorage.objstorage module
  • timed()
  • objid_to_default_hex()
  • objid_for_content()
  • NullCompressor
    • NullCompressor.compress()
    • NullCompressor.flush()
  • NullDecompressor
    • NullDecompressor.decompress()
    • NullDecompressor.unused_data
  • ObjStorage
    • ObjStorage.compression
    • ObjStorage.primary_hash
    • ObjStorage.name
    • ObjStorage.map_contents
    • ObjStorage.add_batch()
    • ObjStorage.restore()
    • ObjStorage.get_batch()
    • ObjStorage.delete()
    • ObjStorage.download_url()
    • ObjStorage.get()
    • ObjStorage.check()
    • ObjStorage.compress()
    • ObjStorage.decompress()
• swh.objstorage.pytest_plugin module
  • swh_objstorage_config()
  • swh_objstorage()
  • statsd()
• swh.objstorage.utils module
  • call_async()
  • format_obj_id()