py_tasks_melange: comparison thirdparty/google_appengine/google/appengine/api/memcache/__init_

equal deleted inserted replaced

-:27971a13089f
+:2e0b0af889be
 self._make_sync_call('memcache', 'Stats', request, response)
 except apiproxy_errors.Error:
 return None
 if not response.has_stats():
-return None
+return {
+STAT_HITS: 0,
+STAT_MISSES: 0,
+STAT_BYTE_HITS: 0,
+STAT_ITEMS: 0,
+STAT_BYTES: 0,
+STAT_OLDEST_ITEM_AGES: 0,
+}
 stats = response.stats()
 return {
 STAT_HITS: stats.hits(),
 STAT_MISSES: stats.misses(),
 """
 return self._set_multi_with_policy(MemcacheSetRequest.REPLACE, mapping,
 time=time, key_prefix=key_prefix,
 namespace=namespace)
-def incr(self, key, delta=1, namespace=None):
+def incr(self, key, delta=1, namespace=None, initial_value=None):
 """Atomically increments a key's value.
 Internally, the value is a unsigned 64-bit integer.  Memcache
 doesn't check 64-bit overflows.  The value, if too large, will
 wrap around.
-The key must already exist in the cache to be incremented.  To
+Unless an initial_value is specified, the key must already exist
-initialize a counter, set() it to the initial value, as an
+in the cache to be incremented.  To initialize a counter, either
+specify initial_value or set() it to the initial value, as an
 ASCII decimal integer.  Future get()s of the key, post-increment,
 will still be an ASCII decimal value.
 Args:
 key: Key to increment.  See Client's docstring for details.
 delta: Non-negative integer value (int or long) to increment key by,
 defaulting to 1.
 namespace: a string specifying an optional namespace to use in
 the request.
+initial_value: initial value to put in the cache, if it doesn't
+already exist.  The default value, None, will not create a cache
+entry if it doesn't already exist.
 Returns:
 New long integer value, or None if key was not in the cache, could not
 be incremented for any other reason, or a network/RPC/server error
 occurred.
 Raises:
 ValueError: If number is negative.
 TypeError: If delta isn't an int or long.
 """
-return self._incrdecr(key, False, delta, namespace=namespace)
+return self._incrdecr(key, False, delta, namespace=namespace,
+initial_value=initial_value)
-def decr(self, key, delta=1, namespace=None):
+def decr(self, key, delta=1, namespace=None, initial_value=None):
 """Atomically decrements a key's value.
 Internally, the value is a unsigned 64-bit integer.  Memcache
 caps decrementing below zero to zero.
 key: Key to decrement.  See Client's docstring for details.
 delta: Non-negative integer value (int or long) to decrement key by,
 defaulting to 1.
 namespace: a string specifying an optional namespace to use in
 the request.
+initial_value: initial value to put in the cache, if it doesn't
+already exist.  The default value, None, will not create a cache
+entry if it doesn't already exist.
 Returns:
 New long integer value, or None if key wasn't in cache and couldn't
 be decremented, or a network/RPC/server error occurred.
 Raises:
 ValueError: If number is negative.
 TypeError: If delta isn't an int or long.
 """
-return self._incrdecr(key, True, delta, namespace=namespace)
+return self._incrdecr(key, True, delta, namespace=namespace,
+initial_value=initial_value)
-def _incrdecr(self, key, is_negative, delta, namespace=None):
+def _incrdecr(self, key, is_negative, delta, namespace=None,
+initial_value=None):
 """Increment or decrement a key by a provided delta.
 Args:
 key: Key to increment or decrement.
 is_negative: Boolean, if this is a decrement.
 delta: Non-negative integer amount (int or long) to increment
 or decrement by.
 namespace: a string specifying an optional namespace to use in
 the request.
+initial_value: initial value to put in the cache, if it doesn't
+already exist.  The default value, None, will not create a cache
+entry if it doesn't already exist.
 Returns:
 New long integer value, or None on cache miss or network/RPC/server
 error.
 request.set_delta(delta)
 if is_negative:
 request.set_direction(MemcacheIncrementRequest.DECREMENT)
 else:
 request.set_direction(MemcacheIncrementRequest.INCREMENT)
+if initial_value is not None:
+request.set_initial_value(long(initial_value))
 try:
 self._make_sync_call('memcache', 'Increment', request, response)
 except apiproxy_errors.Error:
 return None

changeset 2864	2e0b0af889be
parent 2413	d0b7dac5325c
child 3031	7678f72140e6