add save and lastsave to pipeline
This commit is contained in:
@@ -168,8 +168,9 @@ public interface Commands {
|
|||||||
public void sort(final String key, final String dstkey);
|
public void sort(final String key, final String dstkey);
|
||||||
|
|
||||||
public void brpop(final String[] args);
|
public void brpop(final String[] args);
|
||||||
|
|
||||||
public void brpoplpush(final String source, final String destination, final int timeout);
|
public void brpoplpush(final String source, final String destination,
|
||||||
|
final int timeout);
|
||||||
|
|
||||||
public void zcount(final String key, final double min, final double max);
|
public void zcount(final String key, final double min, final double max);
|
||||||
|
|
||||||
@@ -220,9 +221,13 @@ public interface Commands {
|
|||||||
|
|
||||||
public void bgsave();
|
public void bgsave();
|
||||||
|
|
||||||
|
public void lastsave();
|
||||||
|
|
||||||
|
public void save();
|
||||||
|
|
||||||
public void configSet(final String parameter, final String value);
|
public void configSet(final String parameter, final String value);
|
||||||
|
|
||||||
public void configGet(final String pattern);
|
public void configGet(final String pattern);
|
||||||
|
|
||||||
public void configResetStat();
|
public void configResetStat();
|
||||||
}
|
}
|
||||||
@@ -430,4 +430,12 @@ public class Pipeline implements Commands {
|
|||||||
public void configResetStat() {
|
public void configResetStat() {
|
||||||
client.configResetStat();
|
client.configResetStat();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public void save() {
|
||||||
|
client.save();
|
||||||
|
}
|
||||||
|
|
||||||
|
public void lastsave() {
|
||||||
|
client.lastsave();
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -426,5 +426,13 @@ public abstract class PipelineBlock implements Commands {
|
|||||||
client.configResetStat();
|
client.configResetStat();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public void save() {
|
||||||
|
client.save();
|
||||||
|
}
|
||||||
|
|
||||||
|
public void lastsave() {
|
||||||
|
client.lastsave();
|
||||||
|
}
|
||||||
|
|
||||||
public abstract void execute();
|
public abstract void execute();
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user