oio.blob package
Submodules
oio.blob.auditor module
-
class
oio.blob.auditor.
BlobAuditor
(conf, **kwargs)[source] Bases:
oio.common.daemon.Daemon
-
run
(*args, **kwargs)[source]
-
oio.blob.cache module
oio.blob.client module
-
class
oio.blob.client.
BlobClient
(conf=None, connection_pool=None, perfdata=None, **kwargs)[source] Bases:
object
A low-level client to rawx services.
-
chunk_copy
(*args, **kwargs)[source]
-
chunk_delete
(*args, **kwargs)[source]
-
chunk_delete_many
(**kwargs)[source] Return type: list of either urllib3.response.HTTPResponse or urllib3.exceptions.HTTPError, with an extra “chunk” attribute.
-
chunk_get
(*args, **kwargs)[source]
-
chunk_head
(*args, **kwargs)[source]
-
chunk_link
(*args, **kwargs)[source]
-
chunk_put
(*args, **kwargs)[source]
-
resolve_url
(url)[source]
-
-
oio.blob.client.
extract_headers_meta
(headers)[source]
-
oio.blob.client.
update_rawx_perfdata
(func)[source]
oio.blob.converter module
-
class
oio.blob.converter.
BlobConverter
(conf, logger=None, **kwargs)[source] Bases:
object
-
cid_from_name
(account, container)[source]
-
content_id_from_name
(cid, path, version, search=False)[source]
-
convert_chunk
(fd, chunk_id)[source]
-
converter_pass
(input_file=None)[source]
-
decode_fullpath
(fullpath)[source]
-
decode_old_fullpath
(old_fullpath)[source]
-
encode_fullpath
(chunk_inode, chunk_id, account, container, path, version, content_id)[source]
-
get_chunk_id_and_fullpath
(chunk_inode, chunk_pos, container_id, path, version, chunk_id=None, account=None, container=None, content_id=None)[source]
-
name_from_cid
(cid)[source]
-
paths_gen
(input_file=None)[source]
-
safe_convert_chunk
(path, fd=None, chunk_id=None)[source]
-
save_xattr
(chunk_id, xattr)[source]
-
-
class
oio.blob.converter.
CacheDict
(size=262144)[source] Bases:
collections.OrderedDict
oio.blob.indexer module
-
class
oio.blob.indexer.
BlobIndexer
(conf, **kwargs)[source] Bases:
oio.common.daemon.Daemon
-
index_pass
()[source]
-
run
(*args, **kwargs)[source]
-
update_index
(path, chunk_id)[source]
-
-
oio.blob.indexer.
random
() → x in the interval [0, 1).
oio.blob.mover module
-
class
oio.blob.mover.
BlobMover
(conf, **kwargs)[source] Bases:
oio.common.daemon.Daemon
-
run
(*args, **kwargs)[source]
-
oio.blob.registrator module
-
class
oio.blob.registrator.
BlobRegistratorWorker
(conf, logger, volume)[source] Bases:
object
-
pass_with_lock
()[source]
-
pass_without_lock
()[source]
-
-
oio.blob.registrator.
lock_volume
(*args, **kwds)[source]
-
oio.blob.registrator.
meta2bean
(volid, meta)[source]
oio.blob.utils module
-
oio.blob.utils.
check_volume
(volume_path)[source] Check if volume_path points to a rawx directory.
Returns: the namespace name and the service ID Raises: oio.common.exceptions.OioException – when the specified path does not belong to a rawx service or misses some attributes.
-
oio.blob.utils.
read_chunk_metadata
(fd, chunk_id, check_chunk_id=True)[source]