@Override public Double zincrby(String key, double score, String member, ZIncrByParams params) { checkIsInMultiOrPipeline(key); client.zincrby(key, score, member, params); String newscore = client.getBulkReply(); // with nx / xx options it could return null now if (newscore == null) return null; return Double.valueOf(newscore); }
@Override public Double zincrby(byte[] key, double score, byte[] member, ZIncrByParams params) { checkIsInMultiOrPipeline(key); client.zincrby(key, score, member, params); String newscore = client.getBulkReply(); // with nx / xx options it could return null now if (newscore == null) return null; return Double.valueOf(newscore); }
@Override public Double zincrby(final String key, final double score, final String member, final ZIncrByParams params) { return new JedisClusterCommand<Double>(connectionHandler, maxAttempts) { @Override public Double execute(Jedis connection) { return connection.zincrby(key, score, member, params); } }.run(key); }
@Override public Double zincrby(final byte[] key, final double score, final byte[] member, final ZIncrByParams params) { return new JedisClusterCommand<Double>(connectionHandler, maxAttempts) { @Override public Double execute(Jedis connection) { return connection.zincrby(key, score, member, params); } }.runBinary(key); }
@Test public void zincrbyWithParams() { jedis.del("foo"); // xx: never add new member Double score = jedis.zincrby("foo", 2d, "a", ZIncrByParams.zIncrByParams().xx()); assertNull(score); jedis.zadd("foo", 2d, "a"); // nx: never update current member score = jedis.zincrby("foo", 1d, "a", ZIncrByParams.zIncrByParams().nx()); assertNull(score); assertEquals(Double.valueOf(2d), jedis.zscore("foo", "a")); // Binary jedis.del(bfoo); // xx: never add new member score = jedis.zincrby(bfoo, 2d, ba, ZIncrByParams.zIncrByParams().xx()); assertNull(score); jedis.zadd(bfoo, 2d, ba); // nx: never update current member score = jedis.zincrby(bfoo, 1d, ba, ZIncrByParams.zIncrByParams().nx()); assertNull(score); assertEquals(Double.valueOf(2d), jedis.zscore(bfoo, ba)); }
@Override public Double zincrby(String key, double score, String member, ZIncrByParams params) { Span span = helper.buildSpan("zincrby", key); span.setTag("score", score); span.setTag("member", member); span.setTag("params", TracingHelper.toString(params.getByteParams())); try { return super.zincrby(key, score, member, params); } catch (Exception e) { onError(e, span); throw e; } finally { span.finish(); } }
@Override public Double zincrby(byte[] key, double score, byte[] member, ZIncrByParams params) { Span span = helper.buildSpan("zincrby", key); span.setTag("member", Arrays.toString(member)); span.setTag("score", score); span.setTag("params", TracingHelper.toString(params.getByteParams())); try { return super.zincrby(key, score, member, params); } catch (Exception e) { onError(e, span); throw e; } finally { span.finish(); } }
@Override public Double zincrby(String key, double score, String member, ZIncrByParams params) { checkIsInMultiOrPipeline(); client.zincrby(key, score, member, params); String newscore = client.getBulkReply(); // with nx / xx options it could return null now if (newscore == null) return null; return Double.valueOf(newscore); }
@Override public Double zincrby(byte[] key, double score, byte[] member, ZIncrByParams params) { checkIsInMultiOrPipeline(); client.zincrby(key, score, member, params); String newscore = client.getBulkReply(); // with nx / xx options it could return null now if (newscore == null) return null; return Double.valueOf(newscore); }
@Override public Double zincrby(final String key, final double score, final String member, final ZIncrByParams params) { return new JedisClusterCommand<Double>(connectionHandler, maxRedirections) { @Override public Double execute(Jedis connection) { return connection.zincrby(key, score, member, params); } }.run(key); }
@Override public Double zincrby(final byte[] key, final double score, final byte[] member, final ZIncrByParams params) { return new JedisClusterCommand<Double>(connectionHandler, maxRedirections) { @Override public Double execute(Jedis connection) { return connection.zincrby(key, score, member, params); } }.runBinary(key); }
@Override public Double zincrby(String key, double score, String member, ZIncrByParams params) { Jedis j = getShard(key); return j.zincrby(key, score, member, params); }
public void zincrby(final byte[] key, final double score, final byte[] member, final ZIncrByParams params) { // Note that it actually calls ZADD with INCR option, so it requires Redis 3.0.2 // or upper. sendCommand(ZADD, params.getByteParams(key, toByteArray(score), member)); }
@Override public Double zincrby(byte[] key, double score, byte[] member, ZIncrByParams params) { Jedis j = getShard(key); return j.zincrby(key, score, member, params); }
@Override public void zincrby(String key, double score, String member, ZIncrByParams params) { zincrby(SafeEncoder.encode(key), score, SafeEncoder.encode(member), params); }
@Override public Response<Double> zincrby(String key, double score, String member, ZIncrByParams params) { getClient(key).zincrby(key, score, member, params); return getResponse(BuilderFactory.DOUBLE); }
@Override public Response<Double> zincrby(byte[] key, double score, byte[] member, ZIncrByParams params) { getClient(key).zincrby(key, score, member); return getResponse(BuilderFactory.DOUBLE); }
@Override public Double zincrby(String key, double score, String member, ZIncrByParams params) { return invoke(jedis -> jedis.zincrby(key, score, member, params), GedisInstanceType.WRITE); }
@Override public Double zincrby(String arg0, double arg1, String arg2, ZIncrByParams arg3) { // TODO Auto-generated method stub return null; }
public void zincrby(final byte[] key, final double score, final byte[] member, final ZIncrByParams params) { // Note that it actually calls ZADD with INCR option, so it requires Redis 3.0.2 or upper. sendCommand(ZADD, params.getByteParams(key, toByteArray(score), member)); }
@Override public Double zincrby(String key, double score, String member, ZIncrByParams params) { //return null; throw new UnsupportedOperationException("Not implemented."); }
void zincrby(final String key, final double score, final String member, final ZIncrByParams params);