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)