redis.clients.jedis
Class BinaryShardedJedis

java.lang.Object
  extended by redis.clients.util.Sharded<Jedis,JedisShardInfo>
      extended by redis.clients.jedis.BinaryShardedJedis
All Implemented Interfaces:
BinaryJedisCommands
Direct Known Subclasses:
ShardedJedis

public class BinaryShardedJedis
extends Sharded<Jedis,JedisShardInfo>
implements BinaryJedisCommands


Field Summary
 
Fields inherited from class redis.clients.util.Sharded
DEFAULT_KEY_TAG_PATTERN, DEFAULT_WEIGHT
 
Constructor Summary
BinaryShardedJedis(List<JedisShardInfo> shards)
           
BinaryShardedJedis(List<JedisShardInfo> shards, Hashing algo)
           
BinaryShardedJedis(List<JedisShardInfo> shards, Hashing algo, Pattern keyTagPattern)
           
BinaryShardedJedis(List<JedisShardInfo> shards, Pattern keyTagPattern)
           
 
Method Summary
 Long append(byte[] key, byte[] value)
           
protected  Jedis create(JedisShardInfo shard)
           
 Long decr(byte[] key)
           
 Long decrBy(byte[] key, long integer)
           
 void disconnect()
           
 Boolean exists(byte[] key)
           
 Long expire(byte[] key, int seconds)
           
 Long expireAt(byte[] key, long unixTime)
           
 byte[] get(byte[] key)
           
 byte[] getSet(byte[] key, byte[] value)
           
 Long hdel(byte[] key, byte[]... fields)
           
 Boolean hexists(byte[] key, byte[] field)
           
 byte[] hget(byte[] key, byte[] field)
           
 Map<byte[],byte[]> hgetAll(byte[] key)
           
 Long hincrBy(byte[] key, byte[] field, long value)
           
 Set<byte[]> hkeys(byte[] key)
           
 Long hlen(byte[] key)
           
 List<byte[]> hmget(byte[] key, byte[]... fields)
           
 String hmset(byte[] key, Map<byte[],byte[]> hash)
           
 Long hset(byte[] key, byte[] field, byte[] value)
           
 Long hsetnx(byte[] key, byte[] field, byte[] value)
           
 Collection<byte[]> hvals(byte[] key)
           
 Long incr(byte[] key)
           
 Long incrBy(byte[] key, long integer)
           
 byte[] lindex(byte[] key, int index)
           
 Long linsert(byte[] key, BinaryClient.LIST_POSITION where, byte[] pivot, byte[] value)
           
 Long llen(byte[] key)
           
 byte[] lpop(byte[] key)
           
 Long lpush(byte[] key, byte[]... strings)
           
 Long lpushx(byte[] key, byte[] string)
           
 List<byte[]> lrange(byte[] key, int start, int end)
           
 Long lrem(byte[] key, int count, byte[] value)
           
 String lset(byte[] key, int index, byte[] value)
           
 String ltrim(byte[] key, int start, int end)
           
 byte[] objectEncoding(byte[] key)
           
 Long objectIdletime(byte[] key)
           
 Long objectRefcount(byte[] key)
           
 ShardedJedisPipeline pipelined()
           
 List<Object> pipelined(ShardedJedisPipeline shardedJedisPipeline)
          Deprecated. 
 byte[] rpop(byte[] key)
           
 Long rpush(byte[] key, byte[]... strings)
           
 Long rpushx(byte[] key, byte[] string)
           
 Long sadd(byte[] key, byte[]... members)
           
 Long scard(byte[] key)
           
 String set(byte[] key, byte[] value)
           
 String setex(byte[] key, int seconds, byte[] value)
           
 Long setnx(byte[] key, byte[] value)
           
 Boolean sismember(byte[] key, byte[] member)
           
 Set<byte[]> smembers(byte[] key)
           
 List<byte[]> sort(byte[] key)
           
 List<byte[]> sort(byte[] key, SortingParams sortingParameters)
           
 byte[] spop(byte[] key)
           
 byte[] srandmember(byte[] key)
           
 Long srem(byte[] key, byte[]... members)
           
 byte[] substr(byte[] key, int start, int end)
           
 Long ttl(byte[] key)
           
 String type(byte[] key)
           
 Long zadd(byte[] key, double score, byte[] member)
           
 Long zadd(byte[] key, Map<Double,byte[]> scoreMembers)
           
 Long zcard(byte[] key)
           
 Long zcount(byte[] key, byte[] min, byte[] max)
           
 Long zcount(byte[] key, double min, double max)
           
 Double zincrby(byte[] key, double score, byte[] member)
           
 Set<byte[]> zrange(byte[] key, int start, int end)
           
 Set<byte[]> zrangeByScore(byte[] key, double min, double max)
           
 Set<byte[]> zrangeByScore(byte[] key, double min, double max, int offset, int count)
           
 Set<Tuple> zrangeByScoreWithScores(byte[] key, byte[] min, byte[] max)
           
 Set<Tuple> zrangeByScoreWithScores(byte[] key, byte[] min, byte[] max, int offset, int count)
           
 Set<Tuple> zrangeByScoreWithScores(byte[] key, double min, double max)
           
 Set<Tuple> zrangeByScoreWithScores(byte[] key, double min, double max, int offset, int count)
           
 Set<Tuple> zrangeWithScores(byte[] key, int start, int end)
           
 Long zrank(byte[] key, byte[] member)
           
 Long zrem(byte[] key, byte[]... members)
           
 Long zremrangeByRank(byte[] key, int start, int end)
           
 Long zremrangeByScore(byte[] key, byte[] start, byte[] end)
           
 Long zremrangeByScore(byte[] key, double start, double end)
           
 Set<byte[]> zrevrange(byte[] key, int start, int end)
           
 Set<byte[]> zrevrangeByScore(byte[] key, byte[] max, byte[] min)
           
 Set<byte[]> zrevrangeByScore(byte[] key, byte[] max, byte[] min, int offset, int count)
           
 Set<byte[]> zrevrangeByScore(byte[] key, double max, double min)
           
 Set<byte[]> zrevrangeByScore(byte[] key, double max, double min, int offset, int count)
           
 Set<Tuple> zrevrangeByScoreWithScores(byte[] key, byte[] max, byte[] min)
           
 Set<Tuple> zrevrangeByScoreWithScores(byte[] key, byte[] max, byte[] min, int offset, int count)
           
 Set<Tuple> zrevrangeByScoreWithScores(byte[] key, double max, double min)
           
 Set<Tuple> zrevrangeByScoreWithScores(byte[] key, double max, double min, int offset, int count)
           
 Set<Tuple> zrevrangeWithScores(byte[] key, int start, int end)
           
 Long zrevrank(byte[] key, byte[] member)
           
 Double zscore(byte[] key, byte[] member)
           
 
Methods inherited from class redis.clients.util.Sharded
getAllShardInfo, getAllShards, getKeyTag, getShard, getShard, getShardInfo, getShardInfo
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

BinaryShardedJedis

public BinaryShardedJedis(List<JedisShardInfo> shards)

BinaryShardedJedis

public BinaryShardedJedis(List<JedisShardInfo> shards,
                          Hashing algo)

BinaryShardedJedis

public BinaryShardedJedis(List<JedisShardInfo> shards,
                          Pattern keyTagPattern)

BinaryShardedJedis

public BinaryShardedJedis(List<JedisShardInfo> shards,
                          Hashing algo,
                          Pattern keyTagPattern)
Method Detail

disconnect

public void disconnect()
                throws IOException
Throws:
IOException

create

protected Jedis create(JedisShardInfo shard)

set

public String set(byte[] key,
                  byte[] value)
Specified by:
set in interface BinaryJedisCommands

get

public byte[] get(byte[] key)
Specified by:
get in interface BinaryJedisCommands

exists

public Boolean exists(byte[] key)
Specified by:
exists in interface BinaryJedisCommands

type

public String type(byte[] key)
Specified by:
type in interface BinaryJedisCommands

expire

public Long expire(byte[] key,
                   int seconds)
Specified by:
expire in interface BinaryJedisCommands

expireAt

public Long expireAt(byte[] key,
                     long unixTime)
Specified by:
expireAt in interface BinaryJedisCommands

ttl

public Long ttl(byte[] key)
Specified by:
ttl in interface BinaryJedisCommands

getSet

public byte[] getSet(byte[] key,
                     byte[] value)
Specified by:
getSet in interface BinaryJedisCommands

setnx

public Long setnx(byte[] key,
                  byte[] value)
Specified by:
setnx in interface BinaryJedisCommands

setex

public String setex(byte[] key,
                    int seconds,
                    byte[] value)
Specified by:
setex in interface BinaryJedisCommands

decrBy

public Long decrBy(byte[] key,
                   long integer)
Specified by:
decrBy in interface BinaryJedisCommands

decr

public Long decr(byte[] key)
Specified by:
decr in interface BinaryJedisCommands

incrBy

public Long incrBy(byte[] key,
                   long integer)
Specified by:
incrBy in interface BinaryJedisCommands

incr

public Long incr(byte[] key)
Specified by:
incr in interface BinaryJedisCommands

append

public Long append(byte[] key,
                   byte[] value)
Specified by:
append in interface BinaryJedisCommands

substr

public byte[] substr(byte[] key,
                     int start,
                     int end)
Specified by:
substr in interface BinaryJedisCommands

hset

public Long hset(byte[] key,
                 byte[] field,
                 byte[] value)
Specified by:
hset in interface BinaryJedisCommands

hget

public byte[] hget(byte[] key,
                   byte[] field)
Specified by:
hget in interface BinaryJedisCommands

hsetnx

public Long hsetnx(byte[] key,
                   byte[] field,
                   byte[] value)
Specified by:
hsetnx in interface BinaryJedisCommands

hmset

public String hmset(byte[] key,
                    Map<byte[],byte[]> hash)
Specified by:
hmset in interface BinaryJedisCommands

hmget

public List<byte[]> hmget(byte[] key,
                          byte[]... fields)
Specified by:
hmget in interface BinaryJedisCommands

hincrBy

public Long hincrBy(byte[] key,
                    byte[] field,
                    long value)
Specified by:
hincrBy in interface BinaryJedisCommands

hexists

public Boolean hexists(byte[] key,
                       byte[] field)
Specified by:
hexists in interface BinaryJedisCommands

hdel

public Long hdel(byte[] key,
                 byte[]... fields)
Specified by:
hdel in interface BinaryJedisCommands

hlen

public Long hlen(byte[] key)
Specified by:
hlen in interface BinaryJedisCommands

hkeys

public Set<byte[]> hkeys(byte[] key)
Specified by:
hkeys in interface BinaryJedisCommands

hvals

public Collection<byte[]> hvals(byte[] key)
Specified by:
hvals in interface BinaryJedisCommands

hgetAll

public Map<byte[],byte[]> hgetAll(byte[] key)
Specified by:
hgetAll in interface BinaryJedisCommands

rpush

public Long rpush(byte[] key,
                  byte[]... strings)
Specified by:
rpush in interface BinaryJedisCommands

lpush

public Long lpush(byte[] key,
                  byte[]... strings)
Specified by:
lpush in interface BinaryJedisCommands

lpushx

public Long lpushx(byte[] key,
                   byte[] string)
Specified by:
lpushx in interface BinaryJedisCommands

rpushx

public Long rpushx(byte[] key,
                   byte[] string)
Specified by:
rpushx in interface BinaryJedisCommands

llen

public Long llen(byte[] key)
Specified by:
llen in interface BinaryJedisCommands

lrange

public List<byte[]> lrange(byte[] key,
                           int start,
                           int end)
Specified by:
lrange in interface BinaryJedisCommands

ltrim

public String ltrim(byte[] key,
                    int start,
                    int end)
Specified by:
ltrim in interface BinaryJedisCommands

lindex

public byte[] lindex(byte[] key,
                     int index)
Specified by:
lindex in interface BinaryJedisCommands

lset

public String lset(byte[] key,
                   int index,
                   byte[] value)
Specified by:
lset in interface BinaryJedisCommands

lrem

public Long lrem(byte[] key,
                 int count,
                 byte[] value)
Specified by:
lrem in interface BinaryJedisCommands

lpop

public byte[] lpop(byte[] key)
Specified by:
lpop in interface BinaryJedisCommands

rpop

public byte[] rpop(byte[] key)
Specified by:
rpop in interface BinaryJedisCommands

sadd

public Long sadd(byte[] key,
                 byte[]... members)
Specified by:
sadd in interface BinaryJedisCommands

smembers

public Set<byte[]> smembers(byte[] key)
Specified by:
smembers in interface BinaryJedisCommands

srem

public Long srem(byte[] key,
                 byte[]... members)
Specified by:
srem in interface BinaryJedisCommands

spop

public byte[] spop(byte[] key)
Specified by:
spop in interface BinaryJedisCommands

scard

public Long scard(byte[] key)
Specified by:
scard in interface BinaryJedisCommands

sismember

public Boolean sismember(byte[] key,
                         byte[] member)
Specified by:
sismember in interface BinaryJedisCommands

srandmember

public byte[] srandmember(byte[] key)
Specified by:
srandmember in interface BinaryJedisCommands

zadd

public Long zadd(byte[] key,
                 double score,
                 byte[] member)
Specified by:
zadd in interface BinaryJedisCommands

zadd

public Long zadd(byte[] key,
                 Map<Double,byte[]> scoreMembers)
Specified by:
zadd in interface BinaryJedisCommands

zrange

public Set<byte[]> zrange(byte[] key,
                          int start,
                          int end)
Specified by:
zrange in interface BinaryJedisCommands

zrem

public Long zrem(byte[] key,
                 byte[]... members)
Specified by:
zrem in interface BinaryJedisCommands

zincrby

public Double zincrby(byte[] key,
                      double score,
                      byte[] member)
Specified by:
zincrby in interface BinaryJedisCommands

zrank

public Long zrank(byte[] key,
                  byte[] member)
Specified by:
zrank in interface BinaryJedisCommands

zrevrank

public Long zrevrank(byte[] key,
                     byte[] member)
Specified by:
zrevrank in interface BinaryJedisCommands

zrevrange

public Set<byte[]> zrevrange(byte[] key,
                             int start,
                             int end)
Specified by:
zrevrange in interface BinaryJedisCommands

zrangeWithScores

public Set<Tuple> zrangeWithScores(byte[] key,
                                   int start,
                                   int end)
Specified by:
zrangeWithScores in interface BinaryJedisCommands

zrevrangeWithScores

public Set<Tuple> zrevrangeWithScores(byte[] key,
                                      int start,
                                      int end)
Specified by:
zrevrangeWithScores in interface BinaryJedisCommands

zcard

public Long zcard(byte[] key)
Specified by:
zcard in interface BinaryJedisCommands

zscore

public Double zscore(byte[] key,
                     byte[] member)
Specified by:
zscore in interface BinaryJedisCommands

sort

public List<byte[]> sort(byte[] key)
Specified by:
sort in interface BinaryJedisCommands

sort

public List<byte[]> sort(byte[] key,
                         SortingParams sortingParameters)
Specified by:
sort in interface BinaryJedisCommands

zcount

public Long zcount(byte[] key,
                   double min,
                   double max)
Specified by:
zcount in interface BinaryJedisCommands

zcount

public Long zcount(byte[] key,
                   byte[] min,
                   byte[] max)
Specified by:
zcount in interface BinaryJedisCommands

zrangeByScore

public Set<byte[]> zrangeByScore(byte[] key,
                                 double min,
                                 double max)
Specified by:
zrangeByScore in interface BinaryJedisCommands

zrangeByScore

public Set<byte[]> zrangeByScore(byte[] key,
                                 double min,
                                 double max,
                                 int offset,
                                 int count)
Specified by:
zrangeByScore in interface BinaryJedisCommands

zrangeByScoreWithScores

public Set<Tuple> zrangeByScoreWithScores(byte[] key,
                                          double min,
                                          double max)
Specified by:
zrangeByScoreWithScores in interface BinaryJedisCommands

zrangeByScoreWithScores

public Set<Tuple> zrangeByScoreWithScores(byte[] key,
                                          double min,
                                          double max,
                                          int offset,
                                          int count)
Specified by:
zrangeByScoreWithScores in interface BinaryJedisCommands

zrangeByScoreWithScores

public Set<Tuple> zrangeByScoreWithScores(byte[] key,
                                          byte[] min,
                                          byte[] max)
Specified by:
zrangeByScoreWithScores in interface BinaryJedisCommands

zrangeByScoreWithScores

public Set<Tuple> zrangeByScoreWithScores(byte[] key,
                                          byte[] min,
                                          byte[] max,
                                          int offset,
                                          int count)
Specified by:
zrangeByScoreWithScores in interface BinaryJedisCommands

zrevrangeByScore

public Set<byte[]> zrevrangeByScore(byte[] key,
                                    double max,
                                    double min)
Specified by:
zrevrangeByScore in interface BinaryJedisCommands

zrevrangeByScore

public Set<byte[]> zrevrangeByScore(byte[] key,
                                    double max,
                                    double min,
                                    int offset,
                                    int count)
Specified by:
zrevrangeByScore in interface BinaryJedisCommands

zrevrangeByScoreWithScores

public Set<Tuple> zrevrangeByScoreWithScores(byte[] key,
                                             double max,
                                             double min)
Specified by:
zrevrangeByScoreWithScores in interface BinaryJedisCommands

zrevrangeByScoreWithScores

public Set<Tuple> zrevrangeByScoreWithScores(byte[] key,
                                             double max,
                                             double min,
                                             int offset,
                                             int count)
Specified by:
zrevrangeByScoreWithScores in interface BinaryJedisCommands

zrevrangeByScore

public Set<byte[]> zrevrangeByScore(byte[] key,
                                    byte[] max,
                                    byte[] min)
Specified by:
zrevrangeByScore in interface BinaryJedisCommands

zrevrangeByScore

public Set<byte[]> zrevrangeByScore(byte[] key,
                                    byte[] max,
                                    byte[] min,
                                    int offset,
                                    int count)
Specified by:
zrevrangeByScore in interface BinaryJedisCommands

zrevrangeByScoreWithScores

public Set<Tuple> zrevrangeByScoreWithScores(byte[] key,
                                             byte[] max,
                                             byte[] min)
Specified by:
zrevrangeByScoreWithScores in interface BinaryJedisCommands

zrevrangeByScoreWithScores

public Set<Tuple> zrevrangeByScoreWithScores(byte[] key,
                                             byte[] max,
                                             byte[] min,
                                             int offset,
                                             int count)
Specified by:
zrevrangeByScoreWithScores in interface BinaryJedisCommands

zremrangeByRank

public Long zremrangeByRank(byte[] key,
                            int start,
                            int end)
Specified by:
zremrangeByRank in interface BinaryJedisCommands

zremrangeByScore

public Long zremrangeByScore(byte[] key,
                             double start,
                             double end)
Specified by:
zremrangeByScore in interface BinaryJedisCommands

zremrangeByScore

public Long zremrangeByScore(byte[] key,
                             byte[] start,
                             byte[] end)
Specified by:
zremrangeByScore in interface BinaryJedisCommands

linsert

public Long linsert(byte[] key,
                    BinaryClient.LIST_POSITION where,
                    byte[] pivot,
                    byte[] value)
Specified by:
linsert in interface BinaryJedisCommands

pipelined

@Deprecated
public List<Object> pipelined(ShardedJedisPipeline shardedJedisPipeline)
Deprecated. 


pipelined

public ShardedJedisPipeline pipelined()

objectRefcount

public Long objectRefcount(byte[] key)
Specified by:
objectRefcount in interface BinaryJedisCommands

objectEncoding

public byte[] objectEncoding(byte[] key)
Specified by:
objectEncoding in interface BinaryJedisCommands

objectIdletime

public Long objectIdletime(byte[] key)
Specified by:
objectIdletime in interface BinaryJedisCommands


Copyright © 2012. All Rights Reserved.