redis.clients.jedis.JedisCommands.sadd()方法的使用及代码示例

x33g5p2x  于2022-01-21 转载在 其他  
字(3.0k)|赞(0)|评价(0)|浏览(176)

本文整理了Java中redis.clients.jedis.JedisCommands.sadd()方法的一些代码示例,展示了JedisCommands.sadd()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。JedisCommands.sadd()方法的具体详情如下:
包路径:redis.clients.jedis.JedisCommands
类名称:JedisCommands
方法名:sadd

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

相关文章

微信公众号

最新文章

更多