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