Skip to content

Commit

Permalink
Align Pipelined commands with UnifiedJedis (#3787)
Browse files Browse the repository at this point in the history
* Align Pipelined commands with UnifiedJedis

Add some Pipelined commands that are available in UnifiedJedis but are
missing the pipelined version.

* Pipeline does not need scriptKill

Co-authored-by: M Sazzadul Hoque <7600764+sazzad16@users.noreply.github.com>

* Undo script commands changes

---------

Co-authored-by: Gabriel Erzse <gabriel.erzse@redis.com>
Co-authored-by: M Sazzadul Hoque <7600764+sazzad16@users.noreply.github.com>
  • Loading branch information
3 people committed May 20, 2024
1 parent 2489a84 commit eb81c51
Show file tree
Hide file tree
Showing 3 changed files with 21 additions and 0 deletions.
15 changes: 15 additions & 0 deletions src/main/java/redis/clients/jedis/PipeliningBase.java
Original file line number Diff line number Diff line change
Expand Up @@ -3879,6 +3879,16 @@ public Response<String> tsDeleteRule(String sourceKey, String destKey) {
public Response<List<String>> tsQueryIndex(String... filters) {
return appendCommand(commandObjects.tsQueryIndex(filters));
}

@Override
public Response<TSInfo> tsInfo(String key) {
return appendCommand(commandObjects.tsInfo(key));
}

@Override
public Response<TSInfo> tsInfoDebug(String key) {
return appendCommand(commandObjects.tsInfoDebug(key));
}
// RedisTimeSeries commands

// RedisBloom commands
Expand Down Expand Up @@ -3987,6 +3997,11 @@ public Response<Boolean> cfExists(String key, String item) {
return appendCommand(commandObjects.cfExists(key, item));
}

@Override
public Response<List<Boolean>> cfMExists(String key, String... items) {
return appendCommand(commandObjects.cfMExists(key, items));
}

@Override
public Response<Boolean> cfDel(String key, String item) {
return appendCommand(commandObjects.cfDel(key, item));
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -26,6 +26,8 @@ public interface CuckooFilterPipelineCommands {

Response<Boolean> cfExists(String key, String item);

Response<List<Boolean>> cfMExists(String key, String... items);

Response<Boolean> cfDel(String key, String item);

Response<Long> cfCount(String key, String item);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -59,4 +59,8 @@ public interface RedisTimeSeriesPipelineCommands {
Response<String> tsDeleteRule(String sourceKey, String destKey);

Response<List<String>> tsQueryIndex(String... filters);

Response<TSInfo> tsInfo(String key);

Response<TSInfo> tsInfoDebug(String key);
}

0 comments on commit eb81c51

Please sign in to comment.