Java 类redis.clients.jedis.params.sortedset.ZIncrByParams 实例源码

项目：JRediClients 文件：Jedis.java

@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);
}

项目：JRediClients 文件：BinaryJedis.java

@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);
}

项目：JRediClients 文件：JedisCluster.java

@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);
}

项目：JRediClients 文件：BinaryJedisCluster.java

@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);
}

项目：JRediClients 文件：SortedSetCommandsTest.java

@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));
}

项目：java-redis-client 文件：TracingJedisCluster.java

@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();
  }
}

项目：java-redis-client 文件：TracingJedisCluster.java

@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();
  }
}

项目：java-redis-client 文件：TracingJedis.java

@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();
  }
}

项目：java-redis-client 文件：TracingJedis.java

@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();
  }
}

项目：cachecloud 文件：Jedis.java

@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);
}

项目：cachecloud 文件：BinaryJedis.java

@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);
}

项目：cachecloud 文件：JedisCluster.java

@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);
}

项目：cachecloud 文件：BinaryJedisCluster.java

@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);
}

项目：cachecloud 文件：SortedSetCommandsTest.java

@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));
}

项目：Jedis 文件：Jedis.java

@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);
}

项目：Jedis 文件：BinaryJedis.java

@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);
}

项目：Jedis 文件：JedisCluster.java

@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);
}

项目：Jedis 文件：BinaryJedisCluster.java

@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);
}

项目：Jedis 文件：SortedSetCommandsTest.java

@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));
}

项目：JRediClients 文件：ShardedJedis.java

@Override
public Double zincrby(String key, double score, String member, ZIncrByParams params) {
    Jedis j = getShard(key);
    return j.zincrby(key, score, member, params);
}

项目：JRediClients 文件：BinaryClient.java

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));
}

项目：JRediClients 文件：BinaryShardedJedis.java

@Override
public Double zincrby(byte[] key, double score, byte[] member, ZIncrByParams params) {
    Jedis j = getShard(key);
    return j.zincrby(key, score, member, params);
}

项目：JRediClients 文件：Client.java

@Override
public void zincrby(String key, double score, String member, ZIncrByParams params) {
    zincrby(SafeEncoder.encode(key), score, SafeEncoder.encode(member), params);
}

项目：JRediClients 文件：PipelineBase.java

@Override
public Response<Double> zincrby(String key, double score, String member, ZIncrByParams params) {
    getClient(key).zincrby(key, score, member, params);
    return getResponse(BuilderFactory.DOUBLE);
}

项目：JRediClients 文件：PipelineBase.java

@Override
public Response<Double> zincrby(byte[] key, double score, byte[] member, ZIncrByParams params) {
    getClient(key).zincrby(key, score, member);
    return getResponse(BuilderFactory.DOUBLE);
}

项目：gedis 文件：IJedisImpl.java

@Override
public Double zincrby(String key, double score, String member, ZIncrByParams params) {
    return invoke(jedis -> jedis.zincrby(key, score, member, params), GedisInstanceType.WRITE);
}

项目：leopard 文件：RedisHashImpl.java

@Override
public Double zincrby(String arg0, double arg1, String arg2, ZIncrByParams arg3) {
    // TODO Auto-generated method stub
    return null;
}

项目：leopard 文件：RedisImpl.java

@Override
public Double zincrby(String arg0, double arg1, String arg2, ZIncrByParams arg3) {
    // TODO Auto-generated method stub
    return null;
}

项目：leopard 文件：RedisWrapper.java

@Override
public Double zincrby(String arg0, double arg1, String arg2, ZIncrByParams arg3) {
    // TODO Auto-generated method stub
    return null;
}

项目：leopard 文件：RedisAllImpl.java

@Override
public Double zincrby(String arg0, double arg1, String arg2, ZIncrByParams arg3) {
    // TODO Auto-generated method stub
    return null;
}

项目：leopard 文件：RedisMemoryImpl.java

@Override
public Double zincrby(String arg0, double arg1, String arg2, ZIncrByParams arg3) {
    // TODO Auto-generated method stub
    return null;
}

项目：cachecloud 文件：ShardedJedis.java

@Override
public Double zincrby(String key, double score, String member, ZIncrByParams params) {
  Jedis j = getShard(key);
  return j.zincrby(key, score, member, params);
}

项目：cachecloud 文件：BinaryClient.java

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));
}

项目：cachecloud 文件：BinaryShardedJedis.java

@Override
public Double zincrby(byte[] key, double score, byte[] member, ZIncrByParams params) {
  Jedis j = getShard(key);
  return j.zincrby(key, score, member, params);
}

项目：cachecloud 文件：Client.java

@Override
public void zincrby(String key, double score, String member, ZIncrByParams params) {
  zincrby(SafeEncoder.encode(key), score, SafeEncoder.encode(member), params);
}

项目：cachecloud 文件：PipelineBase.java

@Override
public Response<Double> zincrby(String key, double score, String member, ZIncrByParams params) {
  getClient(key).zincrby(key, score, member, params);
  return getResponse(BuilderFactory.DOUBLE);
}

项目：cachecloud 文件：PipelineBase.java

@Override
public Response<Double> zincrby(byte[] key, double score, byte[] member, ZIncrByParams params) {
  getClient(key).zincrby(key, score, member);
  return getResponse(BuilderFactory.DOUBLE);
}

项目：hesperides 文件：JedisMock.java

@Override
public Double zincrby(String key, double score, String member, ZIncrByParams params) {
    //return null;
    throw new UnsupportedOperationException("Not implemented.");
}

项目：Jedis 文件：Commands.java

void zincrby(final String key, final double score, final String member,
final ZIncrByParams params);

项目：Jedis 文件：ShardedJedis.java

@Override
public Double zincrby(String key, double score, String member, ZIncrByParams params) {
  Jedis j = getShard(key);
  return j.zincrby(key, score, member, params);
}