-
Notifications
You must be signed in to change notification settings - Fork 3.9k
/
MultiKeyCommandsPipeline.java
152 lines (93 loc) · 4.96 KB
/
MultiKeyCommandsPipeline.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
package redis.clients.jedis.commands;
import redis.clients.jedis.BitOP;
import redis.clients.jedis.GeoUnit;
import redis.clients.jedis.Response;
import redis.clients.jedis.SortingParams;
import redis.clients.jedis.StreamEntry;
import redis.clients.jedis.StreamEntryID;
import redis.clients.jedis.Tuple;
import redis.clients.jedis.ZParams;
import redis.clients.jedis.args.*;
import redis.clients.jedis.params.*;
import redis.clients.jedis.resps.*;
import java.util.List;
import java.util.Map;
import java.util.Set;
/**
* Multikey related commands (these are split out because they are non-shardable)
*/
public interface MultiKeyCommandsPipeline {
Response<Boolean> copy(String srcKey, String dstKey, int db, boolean replace);
Response<Boolean> copy(String srcKey, String dstKey, boolean replace);
Response<Long> del(String... keys);
Response<Long> unlink(String... keys);
Response<Long> exists(String... keys);
Response<String> lmove(String srcKey, String dstKey, ListDirection from, ListDirection to);
Response<String> blmove(String srcKey, String dstKey, ListDirection from, ListDirection to,
double timeout);
Response<List<String>> blpop(String... args);
Response<List<String>> blpop(int timeout, String... args);
Response<KeyedListElement> blpop(double timeout, String... args);
Response<List<String>> brpop(String... args);
Response<List<String>> brpop(int timeout, String... args);
Response<KeyedListElement> brpop(double timeout, String... args);
Response<KeyedZSetElement> bzpopmax(double timeout, String... keys);
Response<KeyedZSetElement> bzpopmin(double timeout, String... keys);
Response<Set<String>> keys(String pattern);
Response<List<String>> mget(String... keys);
Response<String> mset(String... keysvalues);
Response<Long> msetnx(String... keysvalues);
Response<String> rename(String oldkey, String newkey);
Response<Long> renamenx(String oldkey, String newkey);
Response<String> rpoplpush(String srckey, String dstkey);
Response<Set<String>> sdiff(String... keys);
Response<Long> sdiffstore(String dstkey, String... keys);
Response<Set<String>> sinter(String... keys);
Response<Long> sinterstore(String dstkey, String... keys);
Response<Long> smove(String srckey, String dstkey, String member);
Response<Long> sort(String key, SortingParams sortingParameters, String dstkey);
Response<Long> sort(String key, String dstkey);
Response<Set<String>> sunion(String... keys);
Response<Long> sunionstore(String dstkey, String... keys);
Response<String> unwatch();
Response<Set<String>> zdiff(String... keys);
Response<Set<Tuple>> zdiffWithScores(String... keys);
Response<Long> zdiffStore(String dstkey, String... keys);
Response<Set<String>> zinter(ZParams params, String... keys);
Response<Set<Tuple>> zinterWithScores(ZParams params, String... keys);
Response<Long> zinterstore(String dstkey, String... sets);
Response<Long> zinterstore(String dstkey, ZParams params, String... sets);
Response<Set<String>> zunion(ZParams params, String... keys);
Response<Set<Tuple>> zunionWithScores(ZParams params, String... keys);
Response<Long> zunionstore(String dstkey, String... sets);
Response<Long> zunionstore(String dstkey, ZParams params, String... sets);
Response<String> brpoplpush(String source, String destination, int timeout);
Response<Long> publish(String channel, String message);
Response<String> randomKey();
Response<Long> bitop(BitOP op, String destKey, String... srcKeys);
Response<String> pfmerge(String destkey, String... sourcekeys);
Response<Long> pfcount(String... keys);
Response<Long> touch(String... keys);
Response<String> migrate(String host, int port, int destinationDB, int timeout,
MigrateParams params, String... keys);
Response<Long> georadiusStore(String key, double longitude, double latitude, double radius,
GeoUnit unit, GeoRadiusParam param, GeoRadiusStoreParam storeParam);
Response<Long> georadiusByMemberStore(String key, String member, double radius, GeoUnit unit,
GeoRadiusParam param, GeoRadiusStoreParam storeParam);
/**
* @deprecated Use {@link #xread(redis.clients.jedis.params.XReadParams, java.util.Map)}.
*/
@Deprecated
Response<List<Map.Entry<String, List<StreamEntry>>>> xread(int count, long block,
Map.Entry<String, StreamEntryID>... streams);
Response<List<Map.Entry<String, List<StreamEntry>>>> xread(XReadParams xReadParams,
Map<String, StreamEntryID> streams);
/**
* @deprecated Use {@link #xreadGroup(java.lang.String, java.lang.String, redis.clients.jedis.params.XReadGroupParams, java.util.Map)}.
*/
@Deprecated
Response<List<Map.Entry<String, List<StreamEntry>>>> xreadGroup(String groupname, String consumer,
int count, long block, boolean noAck, Map.Entry<String, StreamEntryID>... streams);
Response<List<Map.Entry<String, List<StreamEntry>>>> xreadGroup(String groupname, String consumer,
XReadGroupParams xReadGroupParams, Map<String, StreamEntryID> streams);
}