diff --git a/cyclone/redis/api.py b/cyclone/redis/api.py index 216b2474bb..80ead3b34c 100644 --- a/cyclone/redis/api.py +++ b/cyclone/redis/api.py @@ -82,7 +82,7 @@ def disconnect(self): for conn in self.__ring.nodes: yield conn.disconnect() defer.returnValue(True) - + def __makering(self, results): connections = map(operator.itemgetter(1), results) self.__ring = HashRing(connections) @@ -105,22 +105,23 @@ def __wrap(self, method, *args, **kwargs): #print "node for '%s' is: %s" % (key, node) f = getattr(node, method) return f(*args, **kwargs) - + def __getattr__(self, method): if method in [ "get", "set", "getset", + "setnx", "setex", "incr", "decr", "exists", "delete", "get_type", "rename", "expire", "ttl", "push", "llen", "lrange", "ltrim", "lindex", "pop", "lset", - "lrem", "sadd", "srem", - "sismember", "smembers", + "lrem", "sadd", "srem", + "sismember", "smembers", "zadd", "zrem", "zincr", "zrange", "zrevrange", "zrangebyscore", - "zremrangebyscore", "zcard", "zscore", - "hget", "hset", "hdel", "hincrby", "hlen", - "hkeys", "hvals", "hgetall", "hexists", "hmget", "hmset", + "zremrangebyscore", "zcard", "zscore", + "hget", "hset", "hdel", "hincrby", "hlen", + "hkeys", "hvals", "hgetall", "hexists", "hmget", "hmset", "publish", ]: return functools.partial(self.__wrap, method)