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.mongodb.utils.HookedCursor
 

Namespaces

 zaqar.storage.mongodb.utils
 

Functions

def zaqar.storage.mongodb.utils.cached_gen (iterable)
 
def zaqar.storage.mongodb.utils.calculate_backoff (attempt, max_attempts, max_sleep, max_jitter=0)
 
def zaqar.storage.mongodb.utils.to_oid (obj)
 
def zaqar.storage.mongodb.utils.oid_ts (oid)
 
def zaqar.storage.mongodb.utils.stat_message (message, now)
 
def zaqar.storage.mongodb.utils.normalize_none_str (string_or_none)
 
def zaqar.storage.mongodb.utils.scope_queue_name (queue=None, project=None)
 
def zaqar.storage.mongodb.utils.descope_queue_name (scoped_name)
 
def zaqar.storage.mongodb.utils.parse_scoped_project_queue (scoped_name)
 
def zaqar.storage.mongodb.utils.scoped_query (queue, project, name=None, kfilter={}, key_value=PROJ_QUEUE_KEY)
 
def zaqar.storage.mongodb.utils.get_partition (num_partitions, queue, project=None)
 
def zaqar.storage.mongodb.utils.raises_conn_error (func)
 
def zaqar.storage.mongodb.utils.retries_on_autoreconnect (func)
 

Variables

 zaqar.storage.mongodb.utils.EPOCH = datetime.datetime.utcfromtimestamp(0).replace(tzinfo=tz_util.utc)
 
string zaqar.storage.mongodb.utils.PROJ_QUEUE_KEY = 'p_q'
 
string zaqar.storage.mongodb.utils.PROJ_TOPIC_KEY = 'p_t'
 
 zaqar.storage.mongodb.utils.LOG = logging.getLogger(__name__)