diff --git a/src/main/java/redis/clients/jedis/JedisCluster.java b/src/main/java/redis/clients/jedis/JedisCluster.java index 4e0dd25..256ae34 100644 --- a/src/main/java/redis/clients/jedis/JedisCluster.java +++ b/src/main/java/redis/clients/jedis/JedisCluster.java @@ -293,6 +293,17 @@ public class JedisCluster implements JedisCommands, BasicCommands, Closeable { }.run(key); } + @Override + public Double incrByFloat(final String key, final double value) { + return new JedisClusterCommand(connectionHandler, timeout, + maxRedirections) { + @Override + public Double execute(Jedis connection) { + return connection.incrByFloat(key, value); + } + }.run(key); + } + @Override public Long incr(final String key) { return new JedisClusterCommand(connectionHandler, timeout, diff --git a/src/main/java/redis/clients/jedis/JedisCommands.java b/src/main/java/redis/clients/jedis/JedisCommands.java index cd79f24..b69b97e 100644 --- a/src/main/java/redis/clients/jedis/JedisCommands.java +++ b/src/main/java/redis/clients/jedis/JedisCommands.java @@ -48,6 +48,8 @@ public interface JedisCommands { Long incrBy(String key, long integer); + Double incrByFloat(String key, double value); + Long incr(String key); Long append(String key, String value);