The zaqar.storage.mongodb.subscriptions module

class SubscriptionController(*args, **kwargs)

Bases: zaqar.storage.base.Subscription

Implements subscription resource operations using MongoDB.

Subscriptions are unique by project + queue/topic + subscriber.

Schema:

‘s’: source :: six.text_type ‘u’: subscriber:: six.text_type ‘t’: ttl:: int ‘e’: expires: datetime.datetime ‘o’: options :: dict ‘p’: project :: six.text_type ‘c’: confirmed :: boolean

confirm(*args, **kwargs)

create(*args, **kwargs)

delete(*args, **kwargs)

exists(*args, **kwargs)

get(*args, **kwargs)

get_with_subscriber(*args, **kwargs)

list(*args, **kwargs)

update(*args, **kwargs)