本文整理了Java中redis.clients.jedis.Pipeline.lpush()
方法的一些代码示例,展示了Pipeline.lpush()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Pipeline.lpush()
方法的具体详情如下:
包路径:redis.clients.jedis.Pipeline
类名称:Pipeline
方法名:lpush
暂无
代码示例来源:origin: spring-projects/spring-data-redis
@Override
public Long lPush(byte[] key, byte[]... values) {
Assert.notNull(key, "Key must not be null!");
Assert.notNull(values, "Values must not be null!");
Assert.noNullElements(values, "Values must not contain null elements!");
try {
if (isPipelined()) {
pipeline(connection.newJedisResult(connection.getRequiredPipeline().lpush(key, values)));
return null;
}
if (isQueueing()) {
transaction(connection.newJedisResult(connection.getRequiredTransaction().lpush(key, values)));
return null;
}
return connection.getJedis().lpush(key, values);
} catch (Exception ex) {
throw convertJedisAccessException(ex);
}
}
代码示例来源:origin: com.netflix.dyno/dyno-jedis
@Override
Response<Long> execute(Pipeline jedisPipeline) throws DynoException {
return jedisPipeline.lpush(key, string);
}
代码示例来源:origin: dqeasycloud/easy-cloud
@Override
public Object doInRedis(RedisConnection connection) throws DataAccessException {
Jedis jedis = (Jedis) connection.getNativeConnection();
jedis.pipelined().lpush("", "");
return null;
}
};
代码示例来源:origin: com.netflix.spinnaker.kork/kork-jedis
@Override
public Response<Long> lpush(String key, String... string) {
String command = "lpush";
return instrumented(command, payloadSize(string), () -> delegated.lpush(key, string));
}
代码示例来源:origin: com.netflix.spinnaker.kork/kork-jedis
@Override
public Response<Long> lpush(byte[] key, byte[]... string) {
String command = "lpush";
return instrumented(command, payloadSize(string), () -> delegated.lpush(key, string));
}
代码示例来源:origin: org.apache.beam/beam-sdks-java-io-redis
private void writeUsingListCommand(
KV<String, String> record, Method method, Long expireTime) {
String key = record.getKey();
String value = record.getValue();
if (Method.LPUSH == method) {
pipeline.lpush(key, value);
} else if (Method.RPUSH == method) {
pipeline.rpush(key, value);
}
setExpireTimeWhenRequired(key, expireTime);
}
代码示例来源:origin: com.github.biezhi/unique-support-redis
@Override
Long execute() {
Pipeline pipeline = jedis.getShard(key).pipelined();
Response<Long> result = pipeline.lpush(key, value);
// 修剪列表元素, 如果 size - 1 比 end 下标还要大,Redis将 size 的值设置为 end 。
pipeline.ltrim(key, 0, size - 1);
pipeline.sync();
return result.get();
}
}.getResult();
代码示例来源:origin: apache/servicemix-bundles
@Override
public Long lPush(byte[] key, byte[]... values) {
Assert.notNull(key, "Key must not be null!");
Assert.notNull(values, "Values must not be null!");
Assert.noNullElements(values, "Values must not contain null elements!");
try {
if (isPipelined()) {
pipeline(connection.newJedisResult(connection.getRequiredPipeline().lpush(key, values)));
return null;
}
if (isQueueing()) {
transaction(connection.newJedisResult(connection.getRequiredTransaction().lpush(key, values)));
return null;
}
return connection.getJedis().lpush(key, values);
} catch (Exception ex) {
throw convertJedisAccessException(ex);
}
}
代码示例来源:origin: org.springframework.data/spring-data-redis
@Override
public Long lPush(byte[] key, byte[]... values) {
Assert.notNull(key, "Key must not be null!");
Assert.notNull(values, "Values must not be null!");
Assert.noNullElements(values, "Values must not contain null elements!");
try {
if (isPipelined()) {
pipeline(connection.newJedisResult(connection.getRequiredPipeline().lpush(key, values)));
return null;
}
if (isQueueing()) {
transaction(connection.newJedisResult(connection.getRequiredTransaction().lpush(key, values)));
return null;
}
return connection.getJedis().lpush(key, values);
} catch (Exception ex) {
throw convertJedisAccessException(ex);
}
}
代码示例来源:origin: gojektech/feast
private Response<?> writeRecord(RedisMutation mutation) {
switch (mutation.getMethod()) {
case APPEND:
return pipeline.append(mutation.getKey(), mutation.getValue());
case SET:
return pipeline.set(mutation.getKey(), mutation.getValue());
case LPUSH:
return pipeline.lpush(mutation.getKey(), mutation.getValue());
case RPUSH:
return pipeline.rpush(mutation.getKey(), mutation.getValue());
case SADD:
return pipeline.sadd(mutation.getKey(), mutation.getValue());
case ZADD:
return pipeline.zadd(mutation.getKey(), mutation.getScore(), mutation.getValue());
default:
throw new UnsupportedOperationException(
String.format("Not implemented writing records for %s", mutation.getMethod()));
}
}
内容来源于网络,如有侵权,请联系作者删除!