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
¶
-