diff --git a/src/main/java/redis/clients/jedis/BinaryClient.java b/src/main/java/redis/clients/jedis/BinaryClient.java index c6cd7be..9fcf38e 100644 --- a/src/main/java/redis/clients/jedis/BinaryClient.java +++ b/src/main/java/redis/clients/jedis/BinaryClient.java @@ -632,4 +632,8 @@ public class BinaryClient extends Connection { final int timeout) { sendCommand(BRPOPLPUSH, source, destination, toByteArray(timeout)); } + + public void configResetStat() { + sendCommand(CONFIG, Keyword.RESETSTAT.name()); + } } \ No newline at end of file diff --git a/src/main/java/redis/clients/jedis/BinaryJedis.java b/src/main/java/redis/clients/jedis/BinaryJedis.java index 8ad564f..0913b1f 100644 --- a/src/main/java/redis/clients/jedis/BinaryJedis.java +++ b/src/main/java/redis/clients/jedis/BinaryJedis.java @@ -2780,6 +2780,16 @@ public class BinaryJedis implements BinaryJedisCommands { return client.getMultiBulkReply(); } + /** + * Reset the stats returned by INFO + * + * @return + */ + public String configResetStat() { + client.configResetStat(); + return client.getStatusCodeReply(); + } + /** * Alter the configuration of a running Redis server. Not all the * configuration parameters are supported. diff --git a/src/main/java/redis/clients/jedis/Commands.java b/src/main/java/redis/clients/jedis/Commands.java index 5e27ac3..fbad342 100644 --- a/src/main/java/redis/clients/jedis/Commands.java +++ b/src/main/java/redis/clients/jedis/Commands.java @@ -168,6 +168,8 @@ public interface Commands { public void sort(final String key, final String dstkey); public void brpop(final String[] args); + + public void brpoplpush(final String source, final String destination, final int timeout); public void zcount(final String key, final double min, final double max); @@ -215,6 +217,12 @@ public interface Commands { final String pivot, final String value); public void bgrewriteaof(); - + public void bgsave(); + + public void configSet(final String parameter, final String value); + + public void configGet(final String pattern); + + public void configResetStat(); } \ No newline at end of file diff --git a/src/main/java/redis/clients/jedis/Pipeline.java b/src/main/java/redis/clients/jedis/Pipeline.java index d89a5bc..176c874 100644 --- a/src/main/java/redis/clients/jedis/Pipeline.java +++ b/src/main/java/redis/clients/jedis/Pipeline.java @@ -414,4 +414,20 @@ public class Pipeline implements Commands { public void bgsave() { client.bgsave(); } + + public void configGet(String pattern) { + client.configGet(pattern); + } + + public void configSet(String parameter, String value) { + client.configSet(parameter, value); + } + + public void brpoplpush(String source, String destination, int timeout) { + client.brpoplpush(source, destination, timeout); + } + + public void configResetStat() { + client.configResetStat(); + } } diff --git a/src/main/java/redis/clients/jedis/PipelineBlock.java b/src/main/java/redis/clients/jedis/PipelineBlock.java index 8a50830..e4b65c9 100644 --- a/src/main/java/redis/clients/jedis/PipelineBlock.java +++ b/src/main/java/redis/clients/jedis/PipelineBlock.java @@ -410,5 +410,21 @@ public abstract class PipelineBlock implements Commands { client.bgsave(); } + public void configGet(String pattern) { + client.configGet(pattern); + } + + public void configSet(String parameter, String value) { + client.configSet(parameter, value); + } + + public void brpoplpush(String source, String destination, int timeout) { + client.brpoplpush(source, destination, timeout); + } + + public void configResetStat() { + client.configResetStat(); + } + public abstract void execute(); } diff --git a/src/main/java/redis/clients/jedis/Protocol.java b/src/main/java/redis/clients/jedis/Protocol.java index d493057..4d95fac 100644 --- a/src/main/java/redis/clients/jedis/Protocol.java +++ b/src/main/java/redis/clients/jedis/Protocol.java @@ -144,7 +144,7 @@ public final class Protocol { } public static enum Keyword { - AGGREGATE, ALPHA, ASC, BY, DESC, GET, LIMIT, MESSAGE, NO, NOSORT, PMESSAGE, PSUBSCRIBE, PUNSUBSCRIBE, OK, ONE, QUEUED, SET, STORE, SUBSCRIBE, UNSUBSCRIBE, WEIGHTS, WITHSCORES; + AGGREGATE, ALPHA, ASC, BY, DESC, GET, LIMIT, MESSAGE, NO, NOSORT, PMESSAGE, PSUBSCRIBE, PUNSUBSCRIBE, OK, ONE, QUEUED, SET, STORE, SUBSCRIBE, UNSUBSCRIBE, WEIGHTS, WITHSCORES, RESETSTAT; public final byte[] raw; Keyword() {