Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
39 commits
Select commit Hold shift + click to select a range
8652645
Implement script commands for jedis cluster
phufool Apr 2, 2014
8634830
Address review comments
phufool Apr 2, 2014
add2778
Merge pull request #1 from phufool/cluster-scripting-commands
venkates Apr 2, 2014
6d9d7ad
Fixed cluster scripting commands build test
phufool Apr 2, 2014
b55b79f
Merge pull request #2 from phufool/cluster-scripting-commands
phufool Apr 2, 2014
d729bec
Add binary jedis commands
phufool Apr 2, 2014
737b5f9
JedisCluster extends BinaryJedisCluster. BinaryJedisCluster implement…
phufool Apr 3, 2014
167a782
Implement cluster binary scripting commands. Add tests
phufool Apr 3, 2014
e062f9f
-Pass keyCount to runScript method
phufool Apr 8, 2014
4003ce2
Merge pull request #3 from phufool/cluster-scripting-commands
phufool Apr 8, 2014
81c8308
- Changed runScript() to run()
phufool Apr 8, 2014
3c1d799
Merge pull request #4 from phufool/cluster-scripting-commands
phufool Apr 8, 2014
3824459
Merged scripting commands
phufool Apr 8, 2014
1e64d51
Remove BasicCommand implementation from JedisCluster
HeartSaVioR Apr 13, 2014
68113d6
- Removed runBinaryScript
phufool Apr 8, 2014
3bb2371
Merge pull request #5 from phufool/binary_jedis_commands_for_cluster
phufool Apr 14, 2014
91a2d11
- Removed runBinaryScript
phufool Apr 8, 2014
143faa6
Merge pull request #8 from phufool/master
phufool Apr 14, 2014
ef528ed
- removed BasicCommands
phufool Apr 16, 2014
cef8520
Merge pull request #9 from phufool/master
phufool Apr 16, 2014
a764ad1
- Removed test case using deprecated ping method
phufool Apr 17, 2014
79d27ef
Merge pull request #10 from phufool/master
phufool Apr 17, 2014
737112a
Merge pull request #617 from HeartSaVioR/remove-basiccommand-from-jed…
HeartSaVioR Jul 6, 2014
5939d5b
Merge branch 'master' of https://github.com/xadrnd/jedis into cluster…
HeartSaVioR Jul 6, 2014
5af952a
Merge branch 'master' into cluster-revised
HeartSaVioR Jul 6, 2014
3b31ae7
Merge branch 'master' into cluster-revised
HeartSaVioR Aug 4, 2014
0bb786f
Supports Multi Key operation to JedisCluster
HeartSaVioR Aug 5, 2014
0f76459
Fix JedisCluster's *scan to use key argument
HeartSaVioR Aug 5, 2014
53e7dc2
Merge branch 'master' into cluster-revised
HeartSaVioR Sep 27, 2014
4a9b82a
Merge branch 'cluster-revised' into cluster-support-multi-key-new
HeartSaVioR Sep 27, 2014
61a7065
Merge branch 'master' into cluster-revised
HeartSaVioR Dec 15, 2014
9b6959c
Let echo to run arbitary node, not throwing exception
HeartSaVioR Mar 5, 2015
80d2827
fix BinaryJedisCluster.move() to dispatch node properly
HeartSaVioR Mar 5, 2015
be3c771
Merge branch 'master' into cluster-revised
HeartSaVioR Apr 20, 2015
18308d1
Respect formatting
HeartSaVioR Apr 20, 2015
d584951
Merge branch 'cluster-revised' into cluster-support-multi-key-new
HeartSaVioR Apr 20, 2015
04e94e6
Merge pull request #687 from HeartSaVioR/cluster-support-multi-key-new
HeartSaVioR Apr 20, 2015
02a7acf
Introduce new interfaces for (Binary)JedisCluster
HeartSaVioR Apr 20, 2015
bfc9629
default timeout value seems not set properly (I've missed it)
HeartSaVioR Apr 21, 2015
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1,595 changes: 1,595 additions & 0 deletions src/main/java/redis/clients/jedis/BinaryJedisCluster.java

Large diffs are not rendered by default.

228 changes: 228 additions & 0 deletions src/main/java/redis/clients/jedis/BinaryJedisClusterCommands.java
Original file line number Diff line number Diff line change
@@ -0,0 +1,228 @@
package redis.clients.jedis;

import java.util.Collection;
import java.util.List;
import java.util.Map;
import java.util.Set;

public interface BinaryJedisClusterCommands {
String set(byte[] key, byte[] value);

String set(byte[] key, byte[] value, byte[] nxxx, byte[] expx, long time);

byte[] get(byte[] key);

Boolean exists(byte[] key);

Long persist(byte[] key);

String type(byte[] key);

Long expire(byte[] key, int seconds);

Long pexpire(byte[] key, final long milliseconds);

Long expireAt(byte[] key, long unixTime);

Long pexpireAt(byte[] key, long millisecondsTimestamp);

Long ttl(byte[] key);

Boolean setbit(byte[] key, long offset, boolean value);

Boolean setbit(byte[] key, long offset, byte[] value);

Boolean getbit(byte[] key, long offset);

Long setrange(byte[] key, long offset, byte[] value);

byte[] getrange(byte[] key, long startOffset, long endOffset);

byte[] getSet(byte[] key, byte[] value);

Long setnx(byte[] key, byte[] value);

String setex(byte[] key, int seconds, byte[] value);

Long decrBy(byte[] key, long integer);

Long decr(byte[] key);

Long incrBy(byte[] key, long integer);

Double incrByFloat(byte[] key, double value);

Long incr(byte[] key);

Long append(byte[] key, byte[] value);

byte[] substr(byte[] key, int start, int end);

Long hset(byte[] key, byte[] field, byte[] value);

byte[] hget(byte[] key, byte[] field);

Long hsetnx(byte[] key, byte[] field, byte[] value);

String hmset(byte[] key, Map<byte[], byte[]> hash);

List<byte[]> hmget(byte[] key, byte[]... fields);

Long hincrBy(byte[] key, byte[] field, long value);

Double hincrByFloat(byte[] key, byte[] field, double value);

Boolean hexists(byte[] key, byte[] field);

Long hdel(byte[] key, byte[]... field);

Long hlen(byte[] key);

Set<byte[]> hkeys(byte[] key);

Collection<byte[]> hvals(byte[] key);

Map<byte[], byte[]> hgetAll(byte[] key);

Long rpush(byte[] key, byte[]... args);

Long lpush(byte[] key, byte[]... args);

Long llen(byte[] key);

List<byte[]> lrange(byte[] key, long start, long end);

String ltrim(byte[] key, long start, long end);

byte[] lindex(byte[] key, long index);

String lset(byte[] key, long index, byte[] value);

Long lrem(byte[] key, long count, byte[] value);

byte[] lpop(byte[] key);

byte[] rpop(byte[] key);

Long sadd(byte[] key, byte[]... member);

Set<byte[]> smembers(byte[] key);

Long srem(byte[] key, byte[]... member);

byte[] spop(byte[] key);

Set<byte[]> spop(byte[] key, long count);

Long scard(byte[] key);

Boolean sismember(byte[] key, byte[] member);

byte[] srandmember(byte[] key);

List<byte[]> srandmember(final byte[] key, final int count);

Long strlen(byte[] key);

Long zadd(byte[] key, double score, byte[] member);

Long zadd(byte[] key, Map<byte[], Double> scoreMembers);

Set<byte[]> zrange(byte[] key, long start, long end);

Long zrem(byte[] key, byte[]... member);

Double zincrby(byte[] key, double score, byte[] member);

Long zrank(byte[] key, byte[] member);

Long zrevrank(byte[] key, byte[] member);

Set<byte[]> zrevrange(byte[] key, long start, long end);

Set<Tuple> zrangeWithScores(byte[] key, long start, long end);

Set<Tuple> zrevrangeWithScores(byte[] key, long start, long end);

Long zcard(byte[] key);

Double zscore(byte[] key, byte[] member);

List<byte[]> sort(byte[] key);

List<byte[]> sort(byte[] key, SortingParams sortingParameters);

Long zcount(byte[] key, double min, double max);

Long zcount(byte[] key, byte[] min, byte[] max);

Set<byte[]> zrangeByScore(byte[] key, double min, double max);

Set<byte[]> zrangeByScore(byte[] key, byte[] min, byte[] max);

Set<byte[]> zrevrangeByScore(byte[] key, double max, double min);

Set<byte[]> zrangeByScore(byte[] key, double min, double max, int offset, int count);

Set<byte[]> zrevrangeByScore(byte[] key, byte[] max, byte[] min);

Set<byte[]> zrangeByScore(byte[] key, byte[] min, byte[] max, int offset, int count);

Set<byte[]> zrevrangeByScore(byte[] key, double max, double min, int offset, int count);

Set<Tuple> zrangeByScoreWithScores(byte[] key, double min, double max);

Set<Tuple> zrevrangeByScoreWithScores(byte[] key, double max, double min);

Set<Tuple> zrangeByScoreWithScores(byte[] key, double min, double max, int offset, int count);

Set<byte[]> zrevrangeByScore(byte[] key, byte[] max, byte[] min, int offset, int count);

Set<Tuple> zrangeByScoreWithScores(byte[] key, byte[] min, byte[] max);

Set<Tuple> zrevrangeByScoreWithScores(byte[] key, byte[] max, byte[] min);

Set<Tuple> zrangeByScoreWithScores(byte[] key, byte[] min, byte[] max, int offset, int count);

Set<Tuple> zrevrangeByScoreWithScores(byte[] key, double max, double min, int offset, int count);

Set<Tuple> zrevrangeByScoreWithScores(byte[] key, byte[] max, byte[] min, int offset, int count);

Long zremrangeByRank(byte[] key, long start, long end);

Long zremrangeByScore(byte[] key, double start, double end);

Long zremrangeByScore(byte[] key, byte[] start, byte[] end);

Long zlexcount(final byte[] key, final byte[] min, final byte[] max);

Set<byte[]> zrangeByLex(final byte[] key, final byte[] min, final byte[] max);

Set<byte[]> zrangeByLex(final byte[] key, final byte[] min, final byte[] max, int offset,
int count);

Set<byte[]> zrevrangeByLex(final byte[] key, final byte[] max, final byte[] min);

Set<byte[]> zrevrangeByLex(final byte[] key, final byte[] max, final byte[] min, int offset,
int count);

Long zremrangeByLex(final byte[] key, final byte[] min, final byte[] max);

Long linsert(byte[] key, Client.LIST_POSITION where, byte[] pivot, byte[] value);

Long lpushx(byte[] key, byte[]... arg);

Long rpushx(byte[] key, byte[]... arg);

Long del(byte[] key);

byte[] echo(byte[] arg);

Long bitcount(final byte[] key);

Long bitcount(final byte[] key, long start, long end);

Long pfadd(final byte[] key, final byte[]... elements);

long pfcount(final byte[] key);
}
Loading