The zaqar.storage.mongodb.queues module

Implements the MongoDB storage controller for queues.

Field Mappings:

In order to reduce the disk / memory space used, field names will be, most of the time, the first letter of their long name.

class QueueController(*args, **kwargs)

Bases: zaqar.storage.base.Queue

Implements queue resource operations using MongoDB.

Queues are scoped by project, which is prefixed to the queue name.

Queues:

    Name            Field
    ---------------------
    name         ->   p_q
    msg counter  ->     c
    metadata     ->     m

Message Counter:

    Name          Field
    -------------------
    value        ->   v
    modified ts  ->   t

get_metadata(*args, **kwargs)

set_metadata(*args, **kwargs)