Synnefo

PITHOS_BACKEND_DB_CONNECTION     sqlite:////tmp/pithos-backend.db                  SQLAlchemy database connection string

PITHOS_BACKEND_BLOCK_MODULE      pithos.backends.lib.hashfiler

PITHOS_BACKEND_BLOCK_PATH        /tmp/pithos-data/                                 Map and block storage path

PITHOS_BACKEND_QUEUE_MODULE      None                                              Use ``pithos.backends.lib.rabbitmq`` to enable

PITHOS_BACKEND_QUEUE_CONNECTION  None                                              Format like ``rabbitmq://guest:guest@localhost:5672/pithos``

PITHOS_BACKEND_QUOTA             50 GB (50 * 1024 ** 3)                            Default user quota

class Store(object):

    """Store.

    """

    def __init__(self, **params):

        path = params['path']

        if path and not os.path.exists(path):

            os.makedirs(path)

DEFAULT_DB_CONNECTION = 'sqlite:///backend.db'

DEFAULT_BLOCK_MODULE = 'pithos.backends.lib.hashfiler'

DEFAULT_BLOCK_PATH = 'data/'

#DEFAULT_QUEUE_MODULE = 'pithos.backends.lib.rabbitmq'

#DEFAULT_QUEUE_CONNECTION = 'rabbitmq://guest:guest@localhost:5672/pithos'

    """

    def __init__(self, db_module=None, db_connection=None,

                 queue_module=None, queue_connection=None):

        db_module = db_module or DEFAULT_DB_MODULE

        db_connection = db_connection or DEFAULT_DB_CONNECTION

        block_module = block_module or DEFAULT_BLOCK_MODULE

        block_path = block_path or DEFAULT_BLOCK_PATH

        #queue_module = queue_module or DEFAULT_QUEUE_MODULE

        #queue_connection = queue_connection or DEFAULT_QUEUE_CONNECTION

        self.block_module = load_module(block_module)

        params = {'path': block_path,

                  'block_size': self.block_size,

        self.store = self.block_module.Store(**params)

        if queue_module and queue_connection: