The zaqar.storage.redis.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: int ‘o’: options :: dict ‘p’: project :: six.text_type
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)