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