oio.rebuilder package

Submodules

oio.rebuilder.blob_rebuilder module

class oio.rebuilder.blob_rebuilder.Beanstalkd(addr, tube, logger, **kwargs)[source]

Bases: object

close()[source]
class oio.rebuilder.blob_rebuilder.BeanstalkdListener(addr, tube, logger, **kwargs)[source]

Bases: oio.rebuilder.blob_rebuilder.Beanstalkd

fetch_event(on_event, timeout=None, **kwargs)[source]
fetch_events(on_event, **kwargs)[source]
class oio.rebuilder.blob_rebuilder.BeanstalkdSender(addr, tube, logger, threshold=512, limit=1024, **kwargs)[source]

Bases: oio.rebuilder.blob_rebuilder.Beanstalkd

event_done()[source]
send_event(event, **kwargs)[source]
class oio.rebuilder.blob_rebuilder.BlobRebuilder(conf, logger, volume, try_chunk_delete=False, beanstalkd_addr=None, **kwargs)[source]

Bases: oio.rebuilder.rebuilder.Rebuilder

rebuilder_pass(**kwargs)[source]
class oio.rebuilder.blob_rebuilder.BlobRebuilderWorker(rebuilder, try_chunk_delete=False, **kwargs)[source]

Bases: oio.rebuilder.rebuilder.RebuilderWorker

chunk_rebuild(container_id, content_id, chunk_id_or_pos, **kwargs)[source]
dryrun_chunk_rebuild(container_id, content_id, chunk_id_or_pos, **kwargs)[source]
update_processed(chunk, bytes_processed, error=None, **kwargs)[source]
class oio.rebuilder.blob_rebuilder.DistributedBlobRebuilder(conf, logger, volume, distributed_addr, **kwargs)[source]

Bases: oio.rebuilder.blob_rebuilder.BlobRebuilder

oio.rebuilder.meta1_rebuilder module

class oio.rebuilder.meta1_rebuilder.Meta1Rebuilder(conf, logger, **kwargs)[source]

Bases: oio.rebuilder.meta_rebuilder.MetaRebuilder

class oio.rebuilder.meta1_rebuilder.Meta1RebuilderWorker(rebuilder, **kwargs)[source]

Bases: oio.rebuilder.meta_rebuilder.MetaRebuilderWorker

oio.rebuilder.meta2_rebuilder module

class oio.rebuilder.meta2_rebuilder.Meta2Rebuilder(conf, logger, **kwargs)[source]

Bases: oio.rebuilder.meta_rebuilder.MetaRebuilder

class oio.rebuilder.meta2_rebuilder.Meta2RebuilderWorker(rebuilder, max_attempts=5, **kwargs)[source]

Bases: oio.rebuilder.meta_rebuilder.MetaRebuilderWorker

oio.rebuilder.meta_rebuilder module

class oio.rebuilder.meta_rebuilder.MetaRebuilder(conf, logger, volume, **kwargs)[source]

Bases: oio.rebuilder.rebuilder.Rebuilder

Abstract class for directory rebuilders.

class oio.rebuilder.meta_rebuilder.MetaRebuilderWorker(rebuilder, type_, max_attempts=5, **kwargs)[source]

Bases: oio.rebuilder.rebuilder.RebuilderWorker

oio.rebuilder.rebuilder module

class oio.rebuilder.rebuilder.Rebuilder(conf, logger, volume, input_file=None, **kwargs)[source]

Bases: object

Base class for rebuilders. Subclass and implement

_create_worker() _fill_queue() _item_to_string() _get_report().
log_report(status, force=False, **kwargs)[source]
rebuilder_pass(**kwargs)[source]
update_processed(item, info, error=None, **kwargs)[source]
update_totals(**kwargs)[source]
class oio.rebuilder.rebuilder.RebuilderWorker(rebuilder, **kwargs)[source]

Bases: object

Base class for rebuilder workers. Subclass and implement _rebuild_one().

log_report(**kwargs)[source]
rebuilder_pass(num, queue, **kwargs)[source]
update_processed(item, info, error=None, **kwargs)[source]

Module contents