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
create(*args, **kwargs)
delete(*args, **kwargs)
exists(*args, **kwargs)
get(*args, **kwargs)
list(*args, **kwargs)
update(*args, **kwargs)

Previous topic

The zaqar.storage.redis.scripting module

Next topic

The zaqar.storage.redis.utils module

Project Source

This Page