Skip to content

Commit 1eaefd6

Browse files
AvitalFineRedisAvitalFineRedis
authored
RedisModulePipelineCommands (#2680)
1 parent 80f5a57 commit 1eaefd6

7 files changed

+252
-4
lines changed

‎src/main/java/redis/clients/jedis/ClusterPipeline.java

Lines changed: 56 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,16 +3,23 @@
33
import redis.clients.jedis.args.*;
44
import redis.clients.jedis.commands.PipelineBinaryCommands;
55
import redis.clients.jedis.commands.PipelineCommands;
6+
import redis.clients.jedis.commands.RedisModulePipelineCommands;
7+
import redis.clients.jedis.json.Path;
68
import redis.clients.jedis.params.*;
79
import redis.clients.jedis.providers.JedisClusterConnectionProvider;
810
import redis.clients.jedis.resps.*;
11+
import redis.clients.jedis.search.IndexOptions;
12+
import redis.clients.jedis.search.Query;
13+
import redis.clients.jedis.search.Schema;
14+
import redis.clients.jedis.search.SearchResult;
915
import redis.clients.jedis.stream.*;
1016

1117
import java.util.List;
1218
import java.util.Map;
1319
import java.util.Set;
1420

15-
public class ClusterPipeline extends MultiNodePipelineBase implements PipelineCommands, PipelineBinaryCommands {
21+
public class ClusterPipeline extends MultiNodePipelineBase implements PipelineCommands, PipelineBinaryCommands,
22+
RedisModulePipelineCommands {
1623

1724
private final JedisClusterConnectionProvider provider;
1825
private final RedisCommandObjects commandObjects;
@@ -2713,4 +2720,52 @@ public Response<LCSMatchResult> strAlgoLCSKeys(byte[] keyA, byte[] keyB, StrAlgo
27132720
throw new UnsupportedOperationException("Not supported yet.");
27142721
// return appendCommand(provider.getNode(key), commandObjects.strAlgoLCSStrings(keyA, keyB, params));
27152722
}
2723+
2724+
@Override
2725+
public Response<String> jsonSet(String key, Object object) {
2726+
return appendCommand(provider.getNode(key), commandObjects.jsonSet(key, object));
2727+
}
2728+
2729+
@Override
2730+
public Response<String> jsonSet(String key, Path path, Object object) {
2731+
return appendCommand(provider.getNode(key), commandObjects.jsonSet(key, path, object));
2732+
}
2733+
2734+
@Override
2735+
public <T> Response<T> jsonGet(String key, Class<T> clazz) {
2736+
return appendCommand(provider.getNode(key), commandObjects.jsonGet(key, clazz));
2737+
}
2738+
2739+
@Override
2740+
public <T> Response<T> jsonGet(String key, Class<T> clazz, Path... paths) {
2741+
return appendCommand(provider.getNode(key), commandObjects.jsonGet(key, clazz, paths));
2742+
}
2743+
2744+
@Override
2745+
public Response<Long> jsonDel(String key) {
2746+
return appendCommand(provider.getNode(key), commandObjects.jsonDel(key));
2747+
}
2748+
2749+
@Override
2750+
public Response<Long> jsonDel(String key, Path path) {
2751+
return appendCommand(provider.getNode(key), commandObjects.jsonDel(key, path));
2752+
}
2753+
2754+
@Override
2755+
public Response<String> ftCreate(String indexName, IndexOptions indexOptions, Schema schema) {
2756+
throw new UnsupportedOperationException("Not supported yet.");
2757+
//return appendCommand(provider.getNode(key), commandObjects.ftCreate(indexName, indexOptions, schema));
2758+
}
2759+
2760+
@Override
2761+
public Response<SearchResult> ftSearch(String indexName, Query query) {
2762+
throw new UnsupportedOperationException("Not supported yet.");
2763+
//return appendCommand(provider.getNode(key), commandObjects.ftCreate(indexName, query));
2764+
}
2765+
2766+
@Override
2767+
public Response<SearchResult> ftSearch(byte[] indexName, Query query) {
2768+
throw new UnsupportedOperationException("Not supported yet.");
2769+
//return appendCommand(provider.getNode(key), commandObjects.ftCreate(indexName, query));
2770+
}
27162771
}

‎src/main/java/redis/clients/jedis/Pipeline.java

Lines changed: 53 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,15 +3,22 @@
33
import redis.clients.jedis.args.*;
44
import redis.clients.jedis.commands.PipelineBinaryCommands;
55
import redis.clients.jedis.commands.PipelineCommands;
6+
import redis.clients.jedis.commands.RedisModulePipelineCommands;
7+
import redis.clients.jedis.json.Path;
68
import redis.clients.jedis.params.*;
79
import redis.clients.jedis.resps.*;
10+
import redis.clients.jedis.search.IndexOptions;
11+
import redis.clients.jedis.search.Query;
12+
import redis.clients.jedis.search.Schema;
13+
import redis.clients.jedis.search.SearchResult;
814
import redis.clients.jedis.stream.*;
915

1016
import java.util.List;
1117
import java.util.Map;
1218
import java.util.Set;
1319

14-
public class Pipeline extends PipelineBase implements PipelineCommands, PipelineBinaryCommands {
20+
public class Pipeline extends PipelineBase implements PipelineCommands, PipelineBinaryCommands,
21+
RedisModulePipelineCommands {
1522

1623
private final RedisCommandObjects commandObjects;
1724

@@ -2678,4 +2685,49 @@ public Response<Long> bitop(BitOP op, byte[] destKey, byte[]... srcKeys) {
26782685
public Response<LCSMatchResult> strAlgoLCSKeys(byte[] keyA, byte[] keyB, StrAlgoLCSParams params) {
26792686
return appendCommand(commandObjects.strAlgoLCSStrings(keyA, keyB, params));
26802687
}
2688+
2689+
@Override
2690+
public Response<String> jsonSet(String key, Object object) {
2691+
return appendCommand(commandObjects.jsonSet(key, object));
2692+
}
2693+
2694+
@Override
2695+
public Response<String> jsonSet(String key, Path path, Object object) {
2696+
return appendCommand(commandObjects.jsonSet(key, path, object));
2697+
}
2698+
2699+
@Override
2700+
public <T> Response<T> jsonGet(String key, Class<T> clazz) {
2701+
return appendCommand(commandObjects.jsonGet(key, clazz));
2702+
}
2703+
2704+
@Override
2705+
public <T> Response<T> jsonGet(String key, Class<T> clazz, Path... paths) {
2706+
return appendCommand(commandObjects.jsonGet(key, clazz, paths));
2707+
}
2708+
2709+
@Override
2710+
public Response<Long> jsonDel(String key) {
2711+
return appendCommand(commandObjects.jsonDel(key));
2712+
}
2713+
2714+
@Override
2715+
public Response<Long> jsonDel(String key, Path path) {
2716+
return appendCommand(commandObjects.jsonDel(key, path));
2717+
}
2718+
2719+
@Override
2720+
public Response<String> ftCreate(String indexName, IndexOptions indexOptions, Schema schema) {
2721+
return appendCommand(commandObjects.ftCreate(indexName, indexOptions, schema));
2722+
}
2723+
2724+
@Override
2725+
public Response<SearchResult> ftSearch(String indexName, Query query) {
2726+
return appendCommand(commandObjects.ftSearch(indexName, query));
2727+
}
2728+
2729+
@Override
2730+
public Response<SearchResult> ftSearch(byte[] indexName, Query query) {
2731+
return appendCommand(commandObjects.ftSearch(indexName, query));
2732+
}
26812733
}

‎src/main/java/redis/clients/jedis/ReliableTransaction.java

Lines changed: 53 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,15 +3,22 @@
33
import redis.clients.jedis.args.*;
44
import redis.clients.jedis.commands.PipelineBinaryCommands;
55
import redis.clients.jedis.commands.PipelineCommands;
6+
import redis.clients.jedis.commands.RedisModulePipelineCommands;
7+
import redis.clients.jedis.json.Path;
68
import redis.clients.jedis.params.*;
79
import redis.clients.jedis.resps.*;
10+
import redis.clients.jedis.search.IndexOptions;
11+
import redis.clients.jedis.search.Query;
12+
import redis.clients.jedis.search.Schema;
13+
import redis.clients.jedis.search.SearchResult;
814
import redis.clients.jedis.stream.*;
915

1016
import java.util.List;
1117
import java.util.Map;
1218
import java.util.Set;
1319

14-
public class ReliableTransaction extends ReliableTransactionBase implements PipelineCommands, PipelineBinaryCommands {
20+
public class ReliableTransaction extends ReliableTransactionBase implements PipelineCommands,
21+
PipelineBinaryCommands, RedisModulePipelineCommands {
1522

1623
private final RedisCommandObjects commandObjects;
1724

@@ -2678,4 +2685,49 @@ public Response<Long> bitop(BitOP op, byte[] destKey, byte[]... srcKeys) {
26782685
public Response<LCSMatchResult> strAlgoLCSKeys(byte[] keyA, byte[] keyB, StrAlgoLCSParams params) {
26792686
return appendCommand(commandObjects.strAlgoLCSStrings(keyA, keyB, params));
26802687
}
2688+
2689+
@Override
2690+
public Response<String> jsonSet(String key, Object object) {
2691+
return appendCommand(commandObjects.jsonSet(key, object));
2692+
}
2693+
2694+
@Override
2695+
public Response<String> jsonSet(String key, Path path, Object object) {
2696+
return appendCommand(commandObjects.jsonSet(key, path, object));
2697+
}
2698+
2699+
@Override
2700+
public <T> Response<T> jsonGet(String key, Class<T> clazz) {
2701+
return appendCommand(commandObjects.jsonGet(key, clazz));
2702+
}
2703+
2704+
@Override
2705+
public <T> Response<T> jsonGet(String key, Class<T> clazz, Path... paths) {
2706+
return appendCommand(commandObjects.jsonGet(key, clazz, paths));
2707+
}
2708+
2709+
@Override
2710+
public Response<Long> jsonDel(String key) {
2711+
return appendCommand(commandObjects.jsonDel(key));
2712+
}
2713+
2714+
@Override
2715+
public Response<Long> jsonDel(String key, Path path) {
2716+
return appendCommand(commandObjects.jsonDel(key, path));
2717+
}
2718+
2719+
@Override
2720+
public Response<String> ftCreate(String indexName, IndexOptions indexOptions, Schema schema) {
2721+
return appendCommand(commandObjects.ftCreate(indexName, indexOptions, schema));
2722+
}
2723+
2724+
@Override
2725+
public Response<SearchResult> ftSearch(String indexName, Query query) {
2726+
return appendCommand(commandObjects.ftSearch(indexName, query));
2727+
}
2728+
2729+
@Override
2730+
public Response<SearchResult> ftSearch(byte[] indexName, Query query) {
2731+
return appendCommand(commandObjects.ftSearch(indexName, query));
2732+
}
26812733
}

‎src/main/java/redis/clients/jedis/Transaction.java

Lines changed: 53 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,15 +3,22 @@
33
import redis.clients.jedis.args.*;
44
import redis.clients.jedis.commands.PipelineBinaryCommands;
55
import redis.clients.jedis.commands.PipelineCommands;
6+
import redis.clients.jedis.commands.RedisModulePipelineCommands;
7+
import redis.clients.jedis.json.Path;
68
import redis.clients.jedis.params.*;
79
import redis.clients.jedis.resps.*;
10+
import redis.clients.jedis.search.IndexOptions;
11+
import redis.clients.jedis.search.Query;
12+
import redis.clients.jedis.search.Schema;
13+
import redis.clients.jedis.search.SearchResult;
814
import redis.clients.jedis.stream.*;
915

1016
import java.util.List;
1117
import java.util.Map;
1218
import java.util.Set;
1319

14-
public class Transaction extends PipelinedTransactionBase implements PipelineCommands, PipelineBinaryCommands {
20+
public class Transaction extends PipelinedTransactionBase implements PipelineCommands,
21+
PipelineBinaryCommands, RedisModulePipelineCommands {
1522

1623
private final RedisCommandObjects commandObjects;
1724

@@ -2678,4 +2685,49 @@ public Response<Long> bitop(BitOP op, byte[] destKey, byte[]... srcKeys) {
26782685
public Response<LCSMatchResult> strAlgoLCSKeys(byte[] keyA, byte[] keyB, StrAlgoLCSParams params) {
26792686
return appendCommand(commandObjects.strAlgoLCSStrings(keyA, keyB, params));
26802687
}
2688+
2689+
@Override
2690+
public Response<String> jsonSet(String key, Object object) {
2691+
return appendCommand(commandObjects.jsonSet(key, object));
2692+
}
2693+
2694+
@Override
2695+
public Response<String> jsonSet(String key, Path path, Object object) {
2696+
return appendCommand(commandObjects.jsonSet(key, path, object));
2697+
}
2698+
2699+
@Override
2700+
public <T> Response<T> jsonGet(String key, Class<T> clazz) {
2701+
return appendCommand(commandObjects.jsonGet(key, clazz));
2702+
}
2703+
2704+
@Override
2705+
public <T> Response<T> jsonGet(String key, Class<T> clazz, Path... paths) {
2706+
return appendCommand(commandObjects.jsonGet(key, clazz, paths));
2707+
}
2708+
2709+
@Override
2710+
public Response<Long> jsonDel(String key) {
2711+
return appendCommand(commandObjects.jsonDel(key));
2712+
}
2713+
2714+
@Override
2715+
public Response<Long> jsonDel(String key, Path path) {
2716+
return appendCommand(commandObjects.jsonDel(key, path));
2717+
}
2718+
2719+
@Override
2720+
public Response<String> ftCreate(String indexName, IndexOptions indexOptions, Schema schema) {
2721+
return appendCommand(commandObjects.ftCreate(indexName, indexOptions, schema));
2722+
}
2723+
2724+
@Override
2725+
public Response<SearchResult> ftSearch(String indexName, Query query) {
2726+
return appendCommand(commandObjects.ftSearch(indexName, query));
2727+
}
2728+
2729+
@Override
2730+
public Response<SearchResult> ftSearch(byte[] indexName, Query query) {
2731+
return appendCommand(commandObjects.ftSearch(indexName, query));
2732+
}
26812733
}

‎src/main/java/redis/clients/jedis/commands/RedisModulePipelineCommands.java

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
package redis.clients.jedis.commands;
2+
3+
import redis.clients.jedis.json.RedisJsonPipelineCommands;
4+
import redis.clients.jedis.search.RediSearchPipelineCommands;
5+
6+
public interface RedisModulePipelineCommands extends RediSearchPipelineCommands, RedisJsonPipelineCommands {
7+
}

‎src/main/java/redis/clients/jedis/json/RedisJsonPipelineCommands.java

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,18 @@
1+
package redis.clients.jedis.json;
2+
3+
import redis.clients.jedis.Response;
4+
5+
public interface RedisJsonPipelineCommands {
6+
7+
Response<String> jsonSet(String key, Object object);
8+
9+
Response<String> jsonSet(String key, Path path, Object object);
10+
11+
<T> Response<T> jsonGet(String key, Class<T> clazz);
12+
13+
<T> Response<T> jsonGet(String key, Class<T> clazz, Path... paths);
14+
15+
Response<Long> jsonDel(String key);
16+
17+
Response<Long> jsonDel(String key, Path path);
18+
}

‎src/main/java/redis/clients/jedis/search/RediSearchPipelineCommands.java

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
package redis.clients.jedis.search;
2+
3+
import redis.clients.jedis.Response;
4+
5+
public interface RediSearchPipelineCommands {
6+
7+
Response<String> ftCreate(String indexName, IndexOptions indexOptions, Schema schema);
8+
9+
Response<SearchResult> ftSearch(String indexName, Query query);
10+
11+
Response<SearchResult> ftSearch(byte[] indexName, Query query);
12+
}

0 commit comments

Comments
 (0)