redis.clients.jedis
Class BinaryShardedJedis

java.lang.Object
  redis.clients.util.Sharded<Jedis,JedisShardInfo>
      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(java.util.List<JedisShardInfo> shards)

BinaryShardedJedis(java.util.List<JedisShardInfo> shards, Hashing algo)

BinaryShardedJedis(java.util.List<JedisShardInfo> shards, Hashing algo, java.util.regex.Pattern keyTagPattern)

BinaryShardedJedis(java.util.List<JedisShardInfo> shards, java.util.regex.Pattern keyTagPattern)

Method Summary

java.lang.Integer	append(byte[] key, byte[] value)
protected Jedis	create(JedisShardInfo shard)
java.lang.Integer	decr(byte[] key)
java.lang.Integer	decrBy(byte[] key, int integer)
void	disconnect()
java.lang.Integer	exists(byte[] key)
java.lang.Integer	expire(byte[] key, int seconds)
java.lang.Integer	expireAt(byte[] key, long unixTime)
byte[]	get(byte[] key)
byte[]	getSet(byte[] key, byte[] value)
java.lang.Integer	hdel(byte[] key, byte[] field)
java.lang.Integer	hexists(byte[] key, byte[] field)
byte[]	hget(byte[] key, byte[] field)
java.util.Map<byte[],byte[]>	hgetAll(byte[] key)
java.lang.Integer	hincrBy(byte[] key, byte[] field, int value)
java.util.Set<byte[]>	hkeys(byte[] key)
java.lang.Integer	hlen(byte[] key)
java.util.List<byte[]>	hmget(byte[] key, byte[]... fields)
java.lang.String	hmset(byte[] key, java.util.Map<byte[],byte[]> hash)
java.lang.Integer	hset(byte[] key, byte[] field, byte[] value)
java.lang.Integer	hsetnx(byte[] key, byte[] field, byte[] value)
java.util.Collection<byte[]>	hvals(byte[] key)
java.lang.Integer	incr(byte[] key)
java.lang.Integer	incrBy(byte[] key, int integer)
byte[]	lindex(byte[] key, int index)
java.lang.Integer	linsert(byte[] key, BinaryClient.LIST_POSITION where, byte[] pivot, byte[] value)
java.lang.Integer	llen(byte[] key)
byte[]	lpop(byte[] key)
java.lang.Integer	lpush(byte[] key, byte[] string)
java.util.List<byte[]>	lrange(byte[] key, int start, int end)
java.lang.Integer	lrem(byte[] key, int count, byte[] value)
java.lang.String	lset(byte[] key, int index, byte[] value)
java.lang.String	ltrim(byte[] key, int start, int end)
java.util.List<java.lang.Object>	pipelined(ShardedJedisPipeline shardedJedisPipeline)
byte[]	rpop(byte[] key)
java.lang.Integer	rpush(byte[] key, byte[] string)
java.lang.Integer	sadd(byte[] key, byte[] member)
java.lang.Integer	scard(byte[] key)
java.lang.String	set(byte[] key, byte[] value)
java.lang.String	setex(byte[] key, int seconds, byte[] value)
java.lang.Integer	setnx(byte[] key, byte[] value)
java.lang.Integer	sismember(byte[] key, byte[] member)
java.util.Set<byte[]>	smembers(byte[] key)
java.util.List<byte[]>	sort(byte[] key)
java.util.List<byte[]>	sort(byte[] key, SortingParams sortingParameters)
byte[]	spop(byte[] key)
byte[]	srandmember(byte[] key)
java.lang.Integer	srem(byte[] key, byte[] member)
byte[]	substr(byte[] key, int start, int end)
java.lang.Integer	ttl(byte[] key)
java.lang.String	type(byte[] key)
java.lang.Integer	zadd(byte[] key, double score, byte[] member)
java.lang.Integer	zcard(byte[] key)
java.lang.Integer	zcount(byte[] key, double min, double max)
java.lang.Double	zincrby(byte[] key, double score, byte[] member)
java.util.Set<byte[]>	zrange(byte[] key, int start, int end)
java.util.Set<byte[]>	zrangeByScore(byte[] key, double min, double max)
java.util.Set<byte[]>	zrangeByScore(byte[] key, double min, double max, int offset, int count)
java.util.Set<Tuple>	zrangeByScoreWithScores(byte[] key, double min, double max)
java.util.Set<Tuple>	zrangeByScoreWithScores(byte[] key, double min, double max, int offset, int count)
java.util.Set<Tuple>	zrangeWithScores(byte[] key, int start, int end)
java.lang.Integer	zrank(byte[] key, byte[] member)
java.lang.Integer	zrem(byte[] key, byte[] member)
java.lang.Integer	zremrangeByRank(byte[] key, int start, int end)
java.lang.Integer	zremrangeByScore(byte[] key, double start, double end)
java.util.Set<byte[]>	zrevrange(byte[] key, int start, int end)
java.util.Set<Tuple>	zrevrangeWithScores(byte[] key, int start, int end)
java.lang.Integer	zrevrank(byte[] key, byte[] member)
java.lang.Double	zscore(byte[] key, byte[] member)

Methods inherited from class redis.clients.util.Sharded

getAllShards, getKeyTag, getShard, getShard, getShardInfo

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BinaryShardedJedis

public BinaryShardedJedis(java.util.List<JedisShardInfo> shards)

BinaryShardedJedis

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

BinaryShardedJedis

public BinaryShardedJedis(java.util.List<JedisShardInfo> shards,
                          java.util.regex.Pattern keyTagPattern)

BinaryShardedJedis

public BinaryShardedJedis(java.util.List<JedisShardInfo> shards,
                          Hashing algo,
                          java.util.regex.Pattern keyTagPattern)

Method Detail

disconnect

public void disconnect()
                throws java.io.IOException

Throws:

java.io.IOException

create

protected Jedis create(JedisShardInfo shard)

set

public java.lang.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 java.lang.Integer exists(byte[] key)

Specified by:

exists in interface BinaryJedisCommands

type

public java.lang.String type(byte[] key)

Specified by:

type in interface BinaryJedisCommands

expire

public java.lang.Integer expire(byte[] key,
                                int seconds)

Specified by:

expire in interface BinaryJedisCommands

expireAt

public java.lang.Integer expireAt(byte[] key,
                                  long unixTime)

Specified by:

expireAt in interface BinaryJedisCommands

ttl

public java.lang.Integer 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 java.lang.Integer setnx(byte[] key,
                               byte[] value)

Specified by:

setnx in interface BinaryJedisCommands

setex

public java.lang.String setex(byte[] key,
                              int seconds,
                              byte[] value)

Specified by:

setex in interface BinaryJedisCommands

decrBy

public java.lang.Integer decrBy(byte[] key,
                                int integer)

Specified by:

decrBy in interface BinaryJedisCommands

decr

public java.lang.Integer decr(byte[] key)

Specified by:

decr in interface BinaryJedisCommands

incrBy

public java.lang.Integer incrBy(byte[] key,
                                int integer)

Specified by:

incrBy in interface BinaryJedisCommands

incr

public java.lang.Integer incr(byte[] key)

Specified by:

incr in interface BinaryJedisCommands

append

public java.lang.Integer 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 java.lang.Integer 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 java.lang.Integer hsetnx(byte[] key,
                                byte[] field,
                                byte[] value)

Specified by:

hsetnx in interface BinaryJedisCommands

hmset

public java.lang.String hmset(byte[] key,
                              java.util.Map<byte[],byte[]> hash)

Specified by:

hmset in interface BinaryJedisCommands

hmget

public java.util.List<byte[]> hmget(byte[] key,
                                    byte[]... fields)

Specified by:

hmget in interface BinaryJedisCommands

hincrBy

public java.lang.Integer hincrBy(byte[] key,
                                 byte[] field,
                                 int value)

Specified by:

hincrBy in interface BinaryJedisCommands

hexists

public java.lang.Integer hexists(byte[] key,
                                 byte[] field)

Specified by:

hexists in interface BinaryJedisCommands

hdel

public java.lang.Integer hdel(byte[] key,
                              byte[] field)

Specified by:

hdel in interface BinaryJedisCommands

hlen

public java.lang.Integer hlen(byte[] key)

Specified by:

hlen in interface BinaryJedisCommands

hkeys

public java.util.Set<byte[]> hkeys(byte[] key)

Specified by:

hkeys in interface BinaryJedisCommands

hvals

public java.util.Collection<byte[]> hvals(byte[] key)

Specified by:

hvals in interface BinaryJedisCommands

hgetAll

public java.util.Map<byte[],byte[]> hgetAll(byte[] key)

Specified by:

hgetAll in interface BinaryJedisCommands

rpush

public java.lang.Integer rpush(byte[] key,
                               byte[] string)

Specified by:

rpush in interface BinaryJedisCommands

lpush

public java.lang.Integer lpush(byte[] key,
                               byte[] string)

Specified by:

lpush in interface BinaryJedisCommands

llen

public java.lang.Integer llen(byte[] key)

Specified by:

llen in interface BinaryJedisCommands

lrange

public java.util.List<byte[]> lrange(byte[] key,
                                     int start,
                                     int end)

Specified by:

lrange in interface BinaryJedisCommands

ltrim

public java.lang.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 java.lang.String lset(byte[] key,
                             int index,
                             byte[] value)

Specified by:

lset in interface BinaryJedisCommands

lrem

public java.lang.Integer 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 java.lang.Integer sadd(byte[] key,
                              byte[] member)

Specified by:

sadd in interface BinaryJedisCommands

smembers

public java.util.Set<byte[]> smembers(byte[] key)

Specified by:

smembers in interface BinaryJedisCommands

srem

public java.lang.Integer srem(byte[] key,
                              byte[] member)

Specified by:

srem in interface BinaryJedisCommands

spop

public byte[] spop(byte[] key)

Specified by:

spop in interface BinaryJedisCommands

scard

public java.lang.Integer scard(byte[] key)

Specified by:

scard in interface BinaryJedisCommands

sismember

public java.lang.Integer 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 java.lang.Integer zadd(byte[] key,
                              double score,
                              byte[] member)

Specified by:

zadd in interface BinaryJedisCommands

zrange

public java.util.Set<byte[]> zrange(byte[] key,
                                    int start,
                                    int end)

Specified by:

zrange in interface BinaryJedisCommands

zrem

public java.lang.Integer zrem(byte[] key,
                              byte[] member)

Specified by:

zrem in interface BinaryJedisCommands

zincrby

public java.lang.Double zincrby(byte[] key,
                                double score,
                                byte[] member)

Specified by:

zincrby in interface BinaryJedisCommands

zrank

public java.lang.Integer zrank(byte[] key,
                               byte[] member)

Specified by:

zrank in interface BinaryJedisCommands

zrevrank

public java.lang.Integer zrevrank(byte[] key,
                                  byte[] member)

Specified by:

zrevrank in interface BinaryJedisCommands

zrevrange

public java.util.Set<byte[]> zrevrange(byte[] key,
                                       int start,
                                       int end)

Specified by:

zrevrange in interface BinaryJedisCommands

zrangeWithScores

public java.util.Set<Tuple> zrangeWithScores(byte[] key,
                                             int start,
                                             int end)

Specified by:

zrangeWithScores in interface BinaryJedisCommands

zrevrangeWithScores

public java.util.Set<Tuple> zrevrangeWithScores(byte[] key,
                                                int start,
                                                int end)

Specified by:

zrevrangeWithScores in interface BinaryJedisCommands

zcard

public java.lang.Integer zcard(byte[] key)

Specified by:

zcard in interface BinaryJedisCommands

zscore

public java.lang.Double zscore(byte[] key,
                               byte[] member)

Specified by:

zscore in interface BinaryJedisCommands

sort

public java.util.List<byte[]> sort(byte[] key)

Specified by:

sort in interface BinaryJedisCommands

sort

public java.util.List<byte[]> sort(byte[] key,
                                   SortingParams sortingParameters)

Specified by:

sort in interface BinaryJedisCommands

zcount

public java.lang.Integer zcount(byte[] key,
                                double min,
                                double max)

Specified by:

zcount in interface BinaryJedisCommands

zrangeByScore

public java.util.Set<byte[]> zrangeByScore(byte[] key,
                                           double min,
                                           double max)

Specified by:

zrangeByScore in interface BinaryJedisCommands

zrangeByScore

public java.util.Set<byte[]> zrangeByScore(byte[] key,
                                           double min,
                                           double max,
                                           int offset,
                                           int count)

Specified by:

zrangeByScore in interface BinaryJedisCommands

zrangeByScoreWithScores

public java.util.Set<Tuple> zrangeByScoreWithScores(byte[] key,
                                                    double min,
                                                    double max)

Specified by:

zrangeByScoreWithScores in interface BinaryJedisCommands

zrangeByScoreWithScores

public java.util.Set<Tuple> zrangeByScoreWithScores(byte[] key,
                                                    double min,
                                                    double max,
                                                    int offset,
                                                    int count)

Specified by:

zrangeByScoreWithScores in interface BinaryJedisCommands

zremrangeByRank

public java.lang.Integer zremrangeByRank(byte[] key,
                                         int start,
                                         int end)

Specified by:

zremrangeByRank in interface BinaryJedisCommands

zremrangeByScore

public java.lang.Integer zremrangeByScore(byte[] key,
                                          double start,
                                          double end)

Specified by:

zremrangeByScore in interface BinaryJedisCommands

linsert

public java.lang.Integer linsert(byte[] key,
                                 BinaryClient.LIST_POSITION where,
                                 byte[] pivot,
                                 byte[] value)

Specified by:

linsert in interface BinaryJedisCommands

pipelined

public java.util.List<java.lang.Object> pipelined(ShardedJedisPipeline shardedJedisPipeline)