add config resetstat

This commit is contained in:
Jonathan Leibiusky
2010-12-20 11:21:11 -03:00
parent 3f79d80396
commit f43ca04bd9
6 changed files with 56 additions and 2 deletions

View File

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

View File

@@ -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.

View File

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

View File

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

View File

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

View File

@@ -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() {