From 5e99d53a97099b772e09ee2e086b301368193126 Mon Sep 17 00:00:00 2001
From: dengliming <liming.d.pro@gmail.com>
Date: Thu, 11 Mar 2021 23:55:54 +0800
Subject: [PATCH] Add zaddIncr, xpendingSummary methods to PipelineBase (#2420)

---
 .../redis/clients/jedis/PipelineBase.java     | 24 +++++++++++++++++++
 .../jedis/commands/BinaryRedisPipeline.java   |  4 ++++
 .../clients/jedis/commands/RedisPipeline.java |  5 ++++
 3 files changed, 33 insertions(+)

diff --git a/src/main/java/redis/clients/jedis/PipelineBase.java b/src/main/java/redis/clients/jedis/PipelineBase.java
index 0fedd2b4d7..a47ffaca7c 100644
--- 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
index 4615d92764..ae02efb863 100644
--- 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
index e10d86cf11..e3422b51f4 100644
--- 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);