oio.content package

Submodules

oio.content.content module

class oio.content.content.Chunk(chunk)

Bases: object

checksum

data

ec

host

id

metapos

pos

raw()

size

subpos

url

class oio.content.content.ChunksHelper(chunks, raw_chunk=True)

Bases: object

all()

exclude(id=None, pos=None, metapos=None, subpos=None, host=None)

filter(id=None, pos=None, metapos=None, subpos=None, host=None)

one()

raw()

class oio.content.content.Content(conf, container_id, metadata, chunks, storage_method, account, container_name, blob_client=None, container_client=None, logger=None)

Bases: object

create(stream, **kwargs)

delete(**kwargs)

fetch()

mime_type

move_chunk(chunk_id)

move_linked_chunk(chunk_id, from_url)

policy

properties

rebuild_chunk(chunk_id, allow_same_rawx=False, chunk_pos=None)

oio.content.ec module

class oio.content.ec.ECContent(conf, container_id, metadata, chunks, storage_method, account, container_name, blob_client=None, container_client=None, logger=None)

Bases: oio.content.content.Content

create(stream, **kwargs)

fetch()

rebuild_chunk(chunk_id, allow_same_rawx=False, chunk_pos=None)

oio.content.factory module

class oio.content.factory.ContentFactory(conf, container_client=None, logger=None, **kwargs)

Bases: object

DEFAULT_DATASEC = ('plain', {'distance': '0', 'nb_copy': '1'})

change_policy(container_id, content_id, new_policy)

copy(origin, policy=None)

get(container_id, content_id, account=None, container_name=None)

get_by_path_and_version(container_id, path, version, account=None, container_name=None)

new(container_id, path, size, policy, account=None, container_name=None, **kwargs)

oio.content.plain module

class oio.content.plain.PlainContent(conf, container_id, metadata, chunks, storage_method, account, container_name, blob_client=None, container_client=None, logger=None)

Bases: oio.content.content.Content

create(stream, **kwargs)

fetch()

rebuild_chunk(chunk_id, allow_same_rawx=False, chunk_pos=None)

Module contents