oio.rdir package


oio.rdir.client module

class oio.rdir.client.RdirClient(conf, **kwargs)[source]

Bases: oio.api.base.HttpApi

Client class for rdir services.

admin_clear(volume, clear_all=False, before_incident=False, repair=False, **kwargs)[source]
admin_incident_get(volume, **kwargs)[source]
admin_incident_set(volume, date, **kwargs)[source]
admin_lock(volume, who, **kwargs)[source]
admin_show(volume, **kwargs)[source]
admin_unlock(volume, **kwargs)[source]
chunk_delete(volume_id, container_id, content_id, chunk_id, **kwargs)[source]

Unreference a chunk from the reverse directory

chunk_fetch(volume, limit=100, rebuild=False, container_id=None, max_attempts=3, **kwargs)[source]

Fetch the list of chunks belonging to the specified volume.

  • volume (str) – the volume to get chunks from
  • limit (int) – maximum number of results to return
  • rebuild (bool) –
  • container_id (str) – get only chunks belonging to the specified container
chunk_push(volume_id, container_id, content_id, chunk_id, headers=None, **data)[source]

Reference a chunk in the reverse directory

create(volume_id, **kwargs)[source]

Create the database for volume_id on the appropriate rdir

status(volume, **kwargs)[source]
class oio.rdir.client.RdirDispatcher(conf, **kwargs)[source]

Bases: object

assign_all_rawx(max_per_rdir=None, **kwargs)[source]

Find a rdir service for all rawx that don’t have one already.

Parameters:max_per_rdir (int) – maximum number or rawx services that an rdir can be linked to

Module contents