The zaqar.storage.mongodb.driver module

Mongodb storage driver implementation.

class ControlDriver(conf, cache)

Bases: zaqar.storage.base.ControlDriverBase

catalogue_controller
close()
connection

MongoDB client connection instance.

database
flavors_controller
pools_controller
queue_controller
queues_database

Database dedicated to the “queues” collection.

The queues collection is separated out into its own database to avoid writer lock contention with the messages collections.

class DataDriver(conf, cache, control_driver)

Bases: zaqar.storage.base.DataDriverBase

BASE_CAPABILITIES = (<Capabilities.FIFO: 1>, <Capabilities.CLAIMS: 2>, <Capabilities.DURABILITY: 3>, <Capabilities.AOD: 4>, <Capabilities.HIGH_THROUGHPUT: 5>)
capabilities
claim_controller
close()
connection

MongoDB client connection instance.

is_alive()
message_controller
message_databases

List of message databases, ordered by partition number.

subscription_controller
subscriptions_database

Database dedicated to the “subscription” collection.

class FIFODataDriver(conf, cache, control_driver)

Bases: zaqar.storage.mongodb.driver.DataDriver

BASE_CAPABILITIES = (<Capabilities.DURABILITY: 3>, <Capabilities.CLAIMS: 2>, <Capabilities.AOD: 4>, <Capabilities.HIGH_THROUGHPUT: 5>)
message_controller