zaqar  10.0.0
About: OpenStack Zaqar is a multi-tenant cloud messaging and notification service for web and mobile developers.
The "Ussuri" series (latest release).
  Fossies Dox: zaqar-10.0.0.tar.gz  ("unofficial" and yet experimental doxygen-generated source code documentation)  

utils.py File Reference

Go to the source code of this file.

Classes

class  zaqar.storage.redis.utils.QueueListCursor
 
class  zaqar.storage.redis.utils.SubscriptionListCursor
 
class  zaqar.storage.redis.utils.FlavorListCursor
 
class  zaqar.storage.redis.utils.PoolsListCursor
 

Namespaces

 zaqar.storage.redis.utils
 

Functions

def zaqar.storage.redis.utils.descope_queue_name (scoped_name)
 
def zaqar.storage.redis.utils.normalize_none_str (string_or_none)
 
def zaqar.storage.redis.utils.scope_queue_name (queue=None, project=None)
 
def zaqar.storage.redis.utils.scope_message_ids_set (queue=None, project=None, message_suffix='')
 
def zaqar.storage.redis.utils.descope_message_ids_set (msgset_key)
 
def zaqar.storage.redis.utils.scope_subscription_ids_set (queue=None, project=None, subscription_suffix='')
 
def zaqar.storage.redis.utils.descope_subscription_ids_set (subset_key)
 
def zaqar.storage.redis.utils.msgset_key (queue, project=None)
 
def zaqar.storage.redis.utils.subset_key (queue, project=None)
 
def zaqar.storage.redis.utils.raises_conn_error (func)
 
def zaqar.storage.redis.utils.retries_on_connection_error (func)
 
def zaqar.storage.redis.utils.msg_claimed_filter (message, now)
 
def zaqar.storage.redis.utils.msg_delayed_filter (message, now)
 
def zaqar.storage.redis.utils.msg_echo_filter (message, client_uuid)
 
def zaqar.storage.redis.utils.msg_expired_filter (message, now)
 
def zaqar.storage.redis.utils.scope_flavors_ids_set (flavors_suffix='')
 
def zaqar.storage.redis.utils.scope_project_flavors_ids_set (project=None, flavors_suffix='')
 
def zaqar.storage.redis.utils.scope_name_flavors_ids_set (name=None, flavors_suffix='')
 
def zaqar.storage.redis.utils.flavor_set_key ()
 
def zaqar.storage.redis.utils.flavor_project_subset_key (project=None)
 
def zaqar.storage.redis.utils.flavor_name_hash_key (name=None)
 
def zaqar.storage.redis.utils.scope_pools_ids_set (pools_suffix='')
 
def zaqar.storage.redis.utils.scope_flavor_pools_ids_set (flavor=None, pools_suffix='')
 
def zaqar.storage.redis.utils.scope_name_pools_ids_set (name=None, pools_suffix='')
 
def zaqar.storage.redis.utils.pools_set_key ()
 
def zaqar.storage.redis.utils.pools_subset_key (flavor=None)
 
def zaqar.storage.redis.utils.pools_name_hash_key (name=None)
 

Variables

 zaqar.storage.redis.utils.LOG = logging.getLogger(__name__)
 
string zaqar.storage.redis.utils.MESSAGE_IDS_SUFFIX = 'messages'
 
string zaqar.storage.redis.utils.SUBSCRIPTION_IDS_SUFFIX = 'subscriptions'
 
string zaqar.storage.redis.utils.FLAVORS_IDS_SUFFIX = 'flavors'
 
string zaqar.storage.redis.utils.POOLS_IDS_SUFFIX = 'pools'
 
def zaqar.storage.redis.utils.scope_pool_catalogue = scope_queue_name
 
def zaqar.storage.redis.utils.scope_queue_catalogue = scope_message_ids_set
 
def zaqar.storage.redis.utils.scope_queue_index = scope_message_ids_set