Synnefo » Pithos

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: