Add zaddIncr, xpendingSummary methods to PipelineBase (#2420)

redis · Mar 11, 2021 · 5e99d53 · 5e99d53
1 parent f404976
commit 5e99d53
Show file tree

Hide file tree

Showing 3 changed files with 33 additions and 0 deletions.
diff --git a/src/main/java/redis/clients/jedis/PipelineBase.java b/src/main/java/redis/clients/jedis/PipelineBase.java
@@ -1006,6 +1006,18 @@ public Response<Long> zadd(final byte[] key, final Map<byte[], Double> scoreMemb
     return getResponse(BuilderFactory.LONG);
   }
 
+  @Override
+  public Response<Double> zaddIncr(String key, double score, String member, ZAddParams params) {
+    getClient(key).zaddIncr(key, score, member, params);
+    return getResponse(BuilderFactory.DOUBLE);
+  }
+
+  @Override
+  public Response<Double> zaddIncr(byte[] key, double score, byte[] member, ZAddParams params) {
+    getClient(key).zaddIncr(key, score, member, params);
+    return getResponse(BuilderFactory.DOUBLE);
+  }
+
   @Override
   public Response<Long> zcard(final String key) {
     getClient(key).zcard(key);
@@ -2146,6 +2158,18 @@ public Response<List<Object>> xpendingBinary(byte[] key, byte[] groupname, byte[
     return getResponse(BuilderFactory.OBJECT_LIST);
   }
 
+  @Override
+  public Response<StreamPendingSummary> xpendingSummary(String key, String groupname) {
+    getClient(key).xpendingSummary(key, groupname);
+    return getResponse(BuilderFactory.STREAM_PENDING_SUMMARY);
+  }
+
+  @Override
+  public Response<Object> xpendingSummary(byte[] key, byte[] groupname) {
+    getClient(key).xpendingSummary(key, groupname);
+    return getResponse(BuilderFactory.OBJECT);
+  }
+
   @Override
   public Response<Long> xdel(String key, StreamEntryID... ids) {
     getClient(key).xdel(key, ids);

diff --git a/src/main/java/redis/clients/jedis/commands/BinaryRedisPipeline.java b/src/main/java/redis/clients/jedis/commands/BinaryRedisPipeline.java
@@ -199,6 +199,8 @@ default Response<String> setex(byte[] key, int seconds, byte[] value) {
 
   Response<Long> zadd(byte[] key, Map<byte[], Double> scoreMembers, ZAddParams params);
 
+  Response<Double> zaddIncr(byte[] key, double score, byte[] member, ZAddParams params);
+
   Response<Long> zcard(byte[] key);
 
   Response<Long> zcount(byte[] key, double min, double max);
@@ -389,6 +391,8 @@ Response<List<GeoRadiusResponse>> georadiusByMemberReadonly(byte[] key, byte[] m
 
   Response<List<Object>> xpendingBinary(byte[] key, byte[] groupname, byte[] start, byte[] end, int count, byte[] consumername);
 
+  Response<Object> xpendingSummary(byte[] key, byte[] groupname);
+
   Response<Long> xdel(byte[] key, byte[]... ids);
 
   Response<Long> xtrim(byte[] key, long maxLen, boolean approximateLength);

diff --git a/src/main/java/redis/clients/jedis/commands/RedisPipeline.java b/src/main/java/redis/clients/jedis/commands/RedisPipeline.java
@@ -10,6 +10,7 @@
 import redis.clients.jedis.Response;
 import redis.clients.jedis.SortingParams;
 import redis.clients.jedis.StreamEntry;
+import redis.clients.jedis.StreamPendingSummary;
 import redis.clients.jedis.Tuple;
 import redis.clients.jedis.params.GeoRadiusParam;
 import redis.clients.jedis.params.GetExParams;
@@ -199,6 +200,8 @@ default Response<String> setex(String key, int seconds, String value) {
 
   Response<Long> zadd(String key, Map<String, Double> scoreMembers, ZAddParams params);
 
+  Response<Double> zaddIncr(String key, double score, String member, ZAddParams params);
+
   Response<Long> zcard(String key);
 
   Response<Long> zcount(String key, double min, double max);
@@ -380,6 +383,8 @@ Response<List<GeoRadiusResponse>> georadiusByMemberReadonly(String key, String m
   Response<List<StreamPendingEntry>> xpending(String key, String groupname,
       StreamEntryID start, StreamEntryID end, int count, String consumername);
 
+  Response<StreamPendingSummary> xpendingSummary(String key, String groupname);
+
   Response<Long> xdel( String key, StreamEntryID... ids);
 
   Response<Long> xtrim( String key, long maxLen, boolean approximateLength);