本文整理了Java中redis.clients.jedis.JedisCommands.sadd()
方法的一些代码示例,展示了JedisCommands.sadd()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。JedisCommands.sadd()
方法的具体详情如下:
包路径:redis.clients.jedis.JedisCommands
类名称:JedisCommands
方法名:sadd
暂无
代码示例来源:origin: Netflix/conductor
public Long sadd(String key, String value) {
logger.trace("sadd {} {}", key, value);
Long retVal = dynoClient.sadd(key, value);
return retVal;
}
代码示例来源:origin: mpusher/mpush
/**
* @param key
* @param value
*/
public void sAdd(String key, String value) {
call(jedis -> jedis.sadd(key, value));
}
代码示例来源:origin: apache/storm
jedisCommand.sadd(key, value);
break;
代码示例来源:origin: com.netflix.conductor/conductor-redis-persistence
public Long sadd(String key, String value) {
logger.trace("sadd {} {}", key, value);
Long retVal = dynoClient.sadd(key, value);
return retVal;
}
代码示例来源:origin: com.github.mpusher/mpush-cache
/**
* @param key
* @param value
*/
public void sAdd(String key, String value) {
call(jedis -> jedis.sadd(key, value));
}
代码示例来源:origin: com.netflix.spinnaker.clouddriver/clouddriver-core
public void set(String id, JedisTask task) {
String taskId = "task:" + task.getId();
Map<String, String> data = new HashMap<>();
data.put("id", task.getId());
data.put("startTimeMs", Long.toString(task.getStartTimeMs()));
data.put("ownerId", task.getOwnerId());
retry(() -> redisClientDelegate.withCommandsClient(client -> {
client.hmset(taskId, data);
client.expire(taskId, TASK_TTL);
client.sadd(RUNNING_TASK_KEY, id);
}), format("Writing task %s", id));
}
代码示例来源:origin: com.netflix.spinnaker.orca/orca-redis
@Override
public void updateStatus(ExecutionType type, @Nonnull String id, @Nonnull ExecutionStatus status) {
ImmutablePair<String, RedisClientDelegate> pair = fetchKey(id);
RedisClientDelegate delegate = pair.getRight();
String key = pair.getLeft();
delegate.withCommandsClient(c -> {
Map<String, String> data = new HashMap<>();
data.put("status", status.name());
if (status == ExecutionStatus.RUNNING) {
data.put("canceled", "false");
data.put("startTime", String.valueOf(currentTimeMillis()));
} else if (status.isComplete() && c.hget(key, "startTime") != null) {
data.put("endTime", String.valueOf(currentTimeMillis()));
}
if (status == BUFFERED) {
c.sadd(allBufferedExecutionsKey(type), id);
} else {
c.srem(allBufferedExecutionsKey(type), id);
}
c.hmset(key, data);
});
}
代码示例来源:origin: vakinge/jeesuite-libs
public long add(String... strs) {
try {
long result = getJedisCommands(groupName).sadd(key,strs);
//设置超时时间
if(result > 0)setExpireIfNot(expireTime);
return result;
} finally{
getJedisProvider(groupName).release();
}
}
代码示例来源:origin: com.netflix.spinnaker.orca/orca-redis
c.sadd(alljobsKey(execution.getType()), execution.getId());
c.sadd(appKey(execution.getType(), execution.getApplication()), execution.getId());
c.sadd(allBufferedExecutionsKey(execution.getType()), execution.getId());
} else {
c.srem(allBufferedExecutionsKey(execution.getType()), execution.getId());
内容来源于网络,如有侵权,请联系作者删除!