/
RedisClient.java
436 lines (227 loc) · 9.28 KB
/
RedisClient.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
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
package io.quarkus.redis.client;
import java.util.List;
import io.quarkus.redis.datasource.RedisDataSource;
import io.vertx.redis.client.Response;
/**
* A synchronous Redis client offering blocking Redis commands.
* The commands have a default timeout of 10 seconds which can be configured
* via {@code quarkus.redis.timeout} configuration knob.
*
* For more information about how each individual command visit
* the <a href="https://redis.io/commands">Redis Commands Page</a>
*
* @deprecated Use {@link io.vertx.mutiny.redis.client.RedisAPI} or
* {@link RedisDataSource} instead.
*/
@Deprecated
public interface RedisClient {
void close();
Response append(String arg0, String arg1);
Response asking();
Response auth(List<String> args);
Response bgrewriteaof();
Response bgsave(List<String> args);
Response bitcount(List<String> args);
Response bitfield(List<String> args);
Response bitop(List<String> args);
Response bitpos(List<String> args);
Response blpop(List<String> args);
Response brpop(List<String> args);
Response brpoplpush(String arg0, String arg1, String arg2);
Response bzpopmax(List<String> args);
Response bzpopmin(List<String> args);
Response client(List<String> args);
Response cluster(List<String> args);
Response command(List<String> args);
Response config(List<String> args);
Response dbsize();
Response debug(List<String> args);
Response decr(String arg0);
Response decrby(String arg0, String arg1);
Response del(List<String> args);
Response discard();
Response dump(String arg0);
Response echo(String arg0);
Response eval(List<String> args);
Response evalsha(List<String> args);
Response exec();
Response exists(List<String> args);
Response expire(String arg0, String arg1);
Response expireat(String arg0, String arg1);
Response flushall(List<String> args);
Response flushdb(List<String> args);
Response geoadd(List<String> args);
Response geodist(List<String> args);
Response geohash(List<String> args);
Response geopos(List<String> args);
Response georadius(List<String> args);
Response georadiusRo(List<String> args);
Response georadiusbymember(List<String> args);
Response georadiusbymemberRo(List<String> args);
Response get(String arg0);
Response getbit(String arg0, String arg1);
Response getrange(String arg0, String arg1, String arg2);
Response getset(String arg0, String arg1);
Response hdel(List<String> args);
Response hexists(String arg0, String arg1);
Response hget(String arg0, String arg1);
Response hgetall(String arg0);
Response hincrby(String arg0, String arg1, String arg2);
Response hincrbyfloat(String arg0, String arg1, String arg2);
Response hkeys(String arg0);
Response hlen(String arg0);
Response hmget(List<String> args);
Response hmset(List<String> args);
@Deprecated
Response host(List<String> args);
Response hscan(List<String> args);
Response hset(List<String> args);
Response hsetnx(String arg0, String arg1, String arg2);
Response hstrlen(String arg0, String arg1);
Response hvals(String arg0);
Response incr(String arg0);
Response incrby(String arg0, String arg1);
Response incrbyfloat(String arg0, String arg1);
Response info(List<String> args);
Response keys(String arg0);
Response lastsave();
Response latency(List<String> args);
Response lindex(String arg0, String arg1);
Response linsert(String arg0, String arg1, String arg2, String arg3);
Response llen(String arg0);
Response lolwut(List<String> args);
Response lpop(String arg0);
Response lpop(List<String> args);
Response lpush(List<String> args);
Response lpushx(List<String> args);
Response lrange(String arg0, String arg1, String arg2);
Response lrem(String arg0, String arg1, String arg2);
Response lset(String arg0, String arg1, String arg2);
Response ltrim(String arg0, String arg1, String arg2);
Response memory(List<String> args);
Response mget(List<String> args);
Response migrate(List<String> args);
Response module(List<String> args);
Response monitor();
Response move(String arg0, String arg1);
Response mset(List<String> args);
Response msetnx(List<String> args);
Response multi();
Response object(List<String> args);
Response persist(String arg0);
Response pexpire(String arg0, String arg1);
Response pexpireat(String arg0, String arg1);
Response pfadd(List<String> args);
Response pfcount(List<String> args);
@Deprecated
Response pfdebug(List<String> args);
Response pfdebug(String command, String key);
Response pfmerge(List<String> args);
Response pfselftest();
Response ping(List<String> args);
@Deprecated
Response post(List<String> args);
Response psetex(String arg0, String arg1, String arg2);
Response psubscribe(List<String> args);
Response psync(String arg0, String arg1);
Response psync(List<String> args);
Response pttl(String arg0);
Response publish(String arg0, String arg1);
Response pubsub(List<String> args);
Response punsubscribe(List<String> args);
Response randomkey();
Response readonly();
Response readwrite();
Response rename(String arg0, String arg1);
Response renamenx(String arg0, String arg1);
Response replconf(List<String> args);
Response replicaof(String arg0, String arg1);
Response restore(List<String> args);
Response restoreAsking(List<String> args);
Response role();
Response rpop(String arg0);
Response rpop(List<String> args);
Response rpoplpush(String arg0, String arg1);
Response rpush(List<String> args);
Response rpushx(List<String> args);
Response sadd(List<String> args);
Response save();
Response scan(List<String> args);
Response scard(String arg0);
Response script(List<String> args);
Response sdiff(List<String> args);
Response sdiffstore(List<String> args);
Response select(String arg0);
Response set(List<String> args);
Response setbit(String arg0, String arg1, String arg2);
Response setex(String arg0, String arg1, String arg2);
Response setnx(String arg0, String arg1);
Response setrange(String arg0, String arg1, String arg2);
Response shutdown(List<String> args);
Response sinter(List<String> args);
Response sinterstore(List<String> args);
Response sismember(String arg0, String arg1);
Response slaveof(String arg0, String arg1);
Response slowlog(List<String> args);
Response smembers(String arg0);
Response smove(String arg0, String arg1, String arg2);
Response sort(List<String> args);
Response spop(List<String> args);
Response srandmember(List<String> args);
Response srem(List<String> args);
Response sscan(List<String> args);
Response strlen(String arg0);
Response subscribe(List<String> args);
Response substr(String arg0, String arg1, String arg2);
Response sunion(List<String> args);
Response sunionstore(List<String> args);
Response swapdb(String arg0, String arg1);
Response sync();
Response time();
Response touch(List<String> args);
Response ttl(String arg0);
Response type(String arg0);
Response unlink(List<String> args);
Response unsubscribe(List<String> args);
Response unwatch();
Response wait(String arg0, String arg1);
Response watch(List<String> args);
Response xack(List<String> args);
Response xadd(List<String> args);
Response xclaim(List<String> args);
Response xdel(List<String> args);
Response xgroup(List<String> args);
Response xinfo(List<String> args);
Response xlen(String arg0);
Response xpending(List<String> args);
Response xrange(List<String> args);
Response xread(List<String> args);
Response xreadgroup(List<String> args);
Response xrevrange(List<String> args);
Response xsetid(String arg0, String arg1);
Response xtrim(List<String> args);
Response zadd(List<String> args);
Response zcard(String arg0);
Response zcount(String arg0, String arg1, String arg2);
Response zincrby(String arg0, String arg1, String arg2);
Response zinterstore(List<String> args);
Response zlexcount(String arg0, String arg1, String arg2);
Response zpopmax(List<String> args);
Response zpopmin(List<String> args);
Response zrange(List<String> args);
Response zrangebylex(List<String> args);
Response zrangebyscore(List<String> args);
Response zrank(String arg0, String arg1);
Response zrem(List<String> args);
Response zremrangebylex(String arg0, String arg1, String arg2);
Response zremrangebyrank(String arg0, String arg1, String arg2);
Response zremrangebyscore(String arg0, String arg1, String arg2);
Response zrevrange(List<String> args);
Response zrevrangebylex(List<String> args);
Response zrevrangebyscore(List<String> args);
Response zrevrank(String arg0, String arg1);
Response zscan(List<String> args);
Response zscore(String arg0, String arg1);
Response zunion(List<String> args);
Response zunionstore(List<String> args);
}