redis.clients.jedis

Class ShardedJedis

java.lang.Object

redis.clients.jedis.util.Sharded<Jedis,JedisShardInfo>

redis.clients.jedis.BinaryShardedJedis

redis.clients.jedis.ShardedJedis

All Implemented Interfaces:

Closeable, AutoCloseable, BinaryJedisCommands, JedisCommands

public class ShardedJedis
extends BinaryShardedJedis
implements JedisCommands, Closeable

Field Summary

Fields

Modifier and Type	Field and Description
protected ShardedJedisPool	dataSource

Fields inherited from class redis.clients.jedis.util.Sharded

DEFAULT_KEY_TAG_PATTERN, DEFAULT_WEIGHT

Constructor Summary

Constructors

Constructor and Description
ShardedJedis(List<JedisShardInfo> shards)
ShardedJedis(List<JedisShardInfo> shards, Hashing algo)
ShardedJedis(List<JedisShardInfo> shards, Hashing algo, Pattern keyTagPattern)
ShardedJedis(List<JedisShardInfo> shards, Pattern keyTagPattern)

Method Summary

Modifier and Type	Method and Description
Long	append(String key, String value)
Long	bitcount(String key)
Long	bitcount(String key, long start, long end)
List<Long>	bitfield(String key, String... arguments) Executes BITFIELD Redis command
List<Long>	bitfieldReadonly(String key, String... arguments)
Long	bitpos(String key, boolean value)
Long	bitpos(String key, boolean value, BitPosParams params)
KeyedListElement	blpop(double timeout, String key)
List<String>	blpop(int timeout, String key)
KeyedListElement	brpop(double timeout, String key)
List<String>	brpop(int timeout, String key)
void	close()
Long	decr(String key)
Long	decrBy(String key, long decrement)
Long	del(String key)
byte[]	dump(String key)
String	echo(String string)
Boolean	exists(String key)
Long	expire(String key, long seconds)
Long	expireAt(String key, long unixTime)
Long	geoadd(String key, double longitude, double latitude, String member)
Long	geoadd(String key, GeoAddParams params, Map<String,GeoCoordinate> memberCoordinateMap)
Long	geoadd(String key, Map<String,GeoCoordinate> memberCoordinateMap)
Double	geodist(String key, String member1, String member2)
Double	geodist(String key, String member1, String member2, GeoUnit unit)
List<String>	geohash(String key, String... members)
List<GeoCoordinate>	geopos(String key, String... members)
List<GeoRadiusResponse>	georadius(String key, double longitude, double latitude, double radius, GeoUnit unit)
List<GeoRadiusResponse>	georadius(String key, double longitude, double latitude, double radius, GeoUnit unit, GeoRadiusParam param)
List<GeoRadiusResponse>	georadiusByMember(String key, String member, double radius, GeoUnit unit)
List<GeoRadiusResponse>	georadiusByMember(String key, String member, double radius, GeoUnit unit, GeoRadiusParam param)
List<GeoRadiusResponse>	georadiusByMemberReadonly(String key, String member, double radius, GeoUnit unit)
List<GeoRadiusResponse>	georadiusByMemberReadonly(String key, String member, double radius, GeoUnit unit, GeoRadiusParam param)
List<GeoRadiusResponse>	georadiusReadonly(String key, double longitude, double latitude, double radius, GeoUnit unit)
List<GeoRadiusResponse>	georadiusReadonly(String key, double longitude, double latitude, double radius, GeoUnit unit, GeoRadiusParam param)
String	get(String key)
Boolean	getbit(String key, long offset)
String	getDel(String key)
String	getEx(String key, GetExParams params)
String	getrange(String key, long startOffset, long endOffset)
String	getSet(String key, String value)
Long	hdel(String key, String... fields)
Boolean	hexists(String key, String field)
String	hget(String key, String field)
Map<String,String>	hgetAll(String key)
Long	hincrBy(String key, String field, long value)
Double	hincrByFloat(String key, String field, double value)
Set<String>	hkeys(String key)
Long	hlen(String key)
List<String>	hmget(String key, String... fields)
String	hmset(String key, Map<String,String> hash)
String	hrandfield(String key)
List<String>	hrandfield(String key, long count)
Map<String,String>	hrandfieldWithValues(String key, long count)
ScanResult<Map.Entry<String,String>>	hscan(String key, String cursor)
ScanResult<Map.Entry<String,String>>	hscan(String key, String cursor, ScanParams params)
Long	hset(String key, Map<String,String> hash)
Long	hset(String key, String field, String value)
Long	hsetnx(String key, String field, String value)
Long	hstrlen(String key, String field) Used for HSTRLEN Redis command
List<String>	hvals(String key)
Long	incr(String key)
Long	incrBy(String key, long increment)
Double	incrByFloat(String key, double increment)
String	lindex(String key, long index)
Long	linsert(String key, ListPosition where, String pivot, String value)
Long	llen(String key)
String	lpop(String key)
List<String>	lpop(String key, int count)
Long	lpos(String key, String element)
Long	lpos(String key, String element, LPosParams params)
List<Long>	lpos(String key, String element, LPosParams params, long count)
Long	lpush(String key, String... strings)
Long	lpushx(String key, String... string)
List<String>	lrange(String key, long start, long stop)
Long	lrem(String key, long count, String value)
String	lset(String key, long index, String value)
String	ltrim(String key, long start, long stop)
Long	move(String key, int dbIndex)
Long	persist(String key)
Long	pexpire(String key, long milliseconds)
Long	pexpireAt(String key, long millisecondsTimestamp)
Long	pfadd(String key, String... elements)
long	pfcount(String key)
String	psetex(String key, long milliseconds, String value)
Long	pttl(String key)
void	resetState()
String	restore(String key, long ttl, byte[] serializedValue)
String	restore(String key, long ttl, byte[] serializedValue, RestoreParams params)
String	restoreReplace(String key, long ttl, byte[] serializedValue)
String	rpop(String key)
List<String>	rpop(String key, int count)
Long	rpush(String key, String... strings)
Long	rpushx(String key, String... string)
Long	sadd(String key, String... members)
Long	scard(String key)
Object	sendBlockingCommand(ProtocolCommand cmd, String... args)
Object	sendCommand(ProtocolCommand cmd, String... args)
String	set(String key, String value)
String	set(String key, String value, SetParams params)
Boolean	setbit(String key, long offset, boolean value)
Boolean	setbit(String key, long offset, String value)
void	setDataSource(ShardedJedisPool shardedJedisPool)
String	setex(String key, long seconds, String value)
Long	setnx(String key, String value)
Long	setrange(String key, long offset, String value)
Boolean	sismember(String key, String member)
Set<String>	smembers(String key)
List<Boolean>	smismember(String key, String... members)
List<String>	sort(String key)
List<String>	sort(String key, SortingParams sortingParameters)
String	spop(String key)
Set<String>	spop(String key, long count)
String	srandmember(String key)
List<String>	srandmember(String key, int count)
Long	srem(String key, String... members)
ScanResult<String>	sscan(String key, String cursor)
ScanResult<String>	sscan(String key, String cursor, ScanParams params)
Long	strlen(String key)
String	substr(String key, int start, int end)
Long	touch(String key)
Long	ttl(String key)
String	type(String key)
Long	unlink(String key)
long	xack(String key, String group, StreamEntryID... ids) XACK key group ID [ID ...]
StreamEntryID	xadd(String key, Map<String,String> hash, XAddParams params) XADD key [NOMKSTREAM] [MAXLEN|MINID [=|~] threshold [LIMIT count]] *|ID field value [field value ...]
StreamEntryID	xadd(String key, StreamEntryID id, Map<String,String> hash) XADD key ID field string [field string ...]
StreamEntryID	xadd(String key, StreamEntryID id, Map<String,String> hash, long maxLen, boolean approximateLength) XADD key MAXLEN ~ LEN ID field string [field string ...]
List<StreamEntry>	xclaim(String key, String group, String consumername, long minIdleTime, long newIdleTime, int retries, boolean force, StreamEntryID... ids) XCLAIM [IDLE ] [TIME ] [RETRYCOUNT ] [FORCE] [JUSTID]
List<StreamEntry>	xclaim(String key, String group, String consumername, long minIdleTime, XClaimParams params, StreamEntryID... ids) XCLAIM ...
List<StreamEntryID>	xclaimJustId(String key, String group, String consumername, long minIdleTime, XClaimParams params, StreamEntryID... ids) XCLAIM ...
long	xdel(String key, StreamEntryID... ids) XDEL key ID [ID ...]
String	xgroupCreate(String key, String consumer, StreamEntryID id, boolean makeStream) XGROUP CREATE
Long	xgroupDelConsumer(String key, String groupname, String consumername) XGROUP DELCONSUMER
long	xgroupDestroy(String key, String groupname) XGROUP DESTROY
String	xgroupSetID(String key, String groupname, StreamEntryID id) XGROUP SETID
List<StreamConsumersInfo>	xinfoConsumers(String key, String group) Introspection command used in order to retrieve different information about consumers in the group
List<StreamGroupInfo>	xinfoGroup(String key) Introspection command used in order to retrieve different information about groups in the stream
StreamInfo	xinfoStream(String key) Introspection command used in order to retrieve different information about the stream
Long	xlen(String key) XLEN key
StreamPendingSummary	xpending(String key, String groupname) XPENDING key group
List<StreamPendingEntry>	xpending(String key, String groupname, StreamEntryID start, StreamEntryID end, int count, String consumername) XPENDING key group [start end count] [consumer]
List<StreamPendingEntry>	xpending(String key, String groupname, XPendingParams params) XPENDING key group [[IDLE min-idle-time] start end count [consumer]]
List<StreamEntry>	xrange(String key, StreamEntryID start, StreamEntryID end) XRANGE key start end
List<StreamEntry>	xrange(String key, StreamEntryID start, StreamEntryID end, int count) XRANGE key start end COUNT count
List<StreamEntry>	xrevrange(String key, StreamEntryID end, StreamEntryID start) XREVRANGE key end start
List<StreamEntry>	xrevrange(String key, StreamEntryID end, StreamEntryID start, int count) XREVRANGE key end start COUNT count
long	xtrim(String key, long maxLen, boolean approximateLength) XTRIM key MAXLEN [~] count
long	xtrim(String key, XTrimParams params) XTRIM key MAXLEN|MINID [=|~] threshold [LIMIT count]
Long	zadd(String key, double score, String member)
Long	zadd(String key, double score, String member, ZAddParams params)
Long	zadd(String key, Map<String,Double> scoreMembers)
Long	zadd(String key, Map<String,Double> scoreMembers, ZAddParams params)
Double	zaddIncr(String key, double score, String member, ZAddParams params)
Long	zcard(String key)
Long	zcount(String key, double min, double max)
Long	zcount(String key, String min, String max)
Double	zincrby(String key, double increment, String member)
Double	zincrby(String key, double increment, String member, ZIncrByParams params)
Long	zlexcount(String key, String min, String max)
List<Double>	zmscore(String key, String... members)
Tuple	zpopmax(String key)
Set<Tuple>	zpopmax(String key, int count)
Tuple	zpopmin(String key)
Set<Tuple>	zpopmin(String key, int count)
String	zrandmember(String key)
Set<String>	zrandmember(String key, long count)
Set<Tuple>	zrandmemberWithScores(String key, long count)
Set<String>	zrange(String key, long start, long stop)
Set<String>	zrangeByLex(String key, String min, String max)
Set<String>	zrangeByLex(String key, String min, String max, int offset, int count)
Set<String>	zrangeByScore(String key, double min, double max)
Set<String>	zrangeByScore(String key, double min, double max, int offset, int count)
Set<String>	zrangeByScore(String key, String min, String max)
Set<String>	zrangeByScore(String key, String min, String max, int offset, int count)
Set<Tuple>	zrangeByScoreWithScores(String key, double min, double max)
Set<Tuple>	zrangeByScoreWithScores(String key, double min, double max, int offset, int count)
Set<Tuple>	zrangeByScoreWithScores(String key, String min, String max)
Set<Tuple>	zrangeByScoreWithScores(String key, String min, String max, int offset, int count)
Set<Tuple>	zrangeWithScores(String key, long start, long stop)
Long	zrank(String key, String member)
Long	zrem(String key, String... members)
Long	zremrangeByLex(String key, String min, String max)
Long	zremrangeByRank(String key, long start, long stop)
Long	zremrangeByScore(String key, double min, double max)
Long	zremrangeByScore(String key, String min, String max)
Set<String>	zrevrange(String key, long start, long stop)
Set<String>	zrevrangeByLex(String key, String max, String min)
Set<String>	zrevrangeByLex(String key, String max, String min, int offset, int count)
Set<String>	zrevrangeByScore(String key, double max, double min)
Set<String>	zrevrangeByScore(String key, double max, double min, int offset, int count)
Set<String>	zrevrangeByScore(String key, String max, String min)
Set<String>	zrevrangeByScore(String key, String max, String min, int offset, int count)
Set<Tuple>	zrevrangeByScoreWithScores(String key, double max, double min)
Set<Tuple>	zrevrangeByScoreWithScores(String key, double max, double min, int offset, int count)
Set<Tuple>	zrevrangeByScoreWithScores(String key, String max, String min)
Set<Tuple>	zrevrangeByScoreWithScores(String key, String max, String min, int offset, int count)
Set<Tuple>	zrevrangeWithScores(String key, long start, long stop)
Long	zrevrank(String key, String member)
ScanResult<Tuple>	zscan(String key, String cursor)
ScanResult<Tuple>	zscan(String key, String cursor, ScanParams params)
Double	zscore(String key, String member)

Methods inherited from class redis.clients.jedis.BinaryShardedJedis

append, bitcount, bitcount, bitfield, bitfieldReadonly, blpop, brpop, create, decr, decrBy, del, disconnect, dump, echo, exists, expire, expireAt, geoadd, geoadd, geoadd, geodist, geodist, geohash, geopos, georadius, georadius, georadiusByMember, georadiusByMember, georadiusByMemberReadonly, georadiusByMemberReadonly, georadiusReadonly, georadiusReadonly, get, getbit, getDel, getEx, getrange, getSet, hdel, hexists, hget, hgetAll, hincrBy, hincrByFloat, hkeys, hlen, hmget, hmset, hrandfield, hrandfield, hrandfieldWithValues, hscan, hscan, hset, hset, hsetnx, hstrlen, hvals, incr, incrBy, incrByFloat, lindex, linsert, llen, lpop, lpop, lpos, lpos, lpos, lpush, lpushx, lrange, lrem, lset, ltrim, move, objectEncoding, objectFreq, objectHelp, objectIdletime, objectRefcount, persist, pexpire, pexpireAt, pfadd, pfcount, pipelined, psetex, pttl, restore, restore, restoreReplace, rpop, rpop, rpush, rpushx, sadd, scard, sendBlockingCommand, sendCommand, sendCommand, set, set, setbit, setbit, setex, setnx, setrange, sismember, smembers, smismember, sort, sort, spop, spop, srandmember, srandmember, srem, sscan, sscan, strlen, substr, touch, ttl, type, unlink, xack, xadd, xadd, xclaim, xclaim, xclaimJustId, xdel, xgroupCreate, xgroupDelConsumer, xgroupDestroy, xgroupSetID, xinfoConsumers, xinfoConsumersBinary, xinfoGroup, xinfoGroupBinary, xinfoStream, xinfoStreamBinary, xlen, xpending, xpending, xpending, xrange, xrange, xrevrange, xrevrange, xtrim, xtrim, zadd, zadd, zadd, zadd, zaddIncr, zcard, zcount, zcount, zincrby, zincrby, zlexcount, zmscore, zpopmax, zpopmax, zpopmin, zpopmin, zrandmember, zrandmember, zrandmemberWithScores, zrange, zrangeByLex, zrangeByLex, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeWithScores, zrank, zrem, zremrangeByLex, zremrangeByRank, zremrangeByScore, zremrangeByScore, zrevrange, zrevrangeByLex, zrevrangeByLex, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeWithScores, zrevrank, zscan, zscan, zscore

Methods inherited from class redis.clients.jedis.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

Methods inherited from interface redis.clients.jedis.commands.JedisCommands

expire, restore, restoreReplace, setex

Methods inherited from interface redis.clients.jedis.commands.BinaryJedisCommands

expire, restore, restoreReplace, setex, xrange

Field Detail

dataSource

protected ShardedJedisPool dataSource

Constructor Detail

ShardedJedis

public ShardedJedis(List<JedisShardInfo> shards)

ShardedJedis

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

ShardedJedis

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

ShardedJedis

public ShardedJedis(List<JedisShardInfo> shards,
                    Hashing algo,
                    Pattern keyTagPattern)

Method Detail

set

public String set(String key,
                  String value)

Specified by:

set in interface JedisCommands

set

public String set(String key,
                  String value,
                  SetParams params)

Specified by:

set in interface JedisCommands

get

public String get(String key)

Specified by:

get in interface JedisCommands

getDel

public String getDel(String key)

Specified by:

getDel in interface JedisCommands

getEx

public String getEx(String key,
                    GetExParams params)

Specified by:

getEx in interface JedisCommands

echo

public String echo(String string)

Specified by:

echo in interface JedisCommands

exists

public Boolean exists(String key)

Specified by:

exists in interface JedisCommands

type

public String type(String key)

Specified by:

type in interface JedisCommands

dump

public byte[] dump(String key)

Specified by:

dump in interface JedisCommands

restore

public String restore(String key,
                      long ttl,
                      byte[] serializedValue)

Specified by:

restore in interface JedisCommands

restoreReplace

public String restoreReplace(String key,
                             long ttl,
                             byte[] serializedValue)

Specified by:

restoreReplace in interface JedisCommands

restore

public String restore(String key,
                      long ttl,
                      byte[] serializedValue,
                      RestoreParams params)

Specified by:

restore in interface JedisCommands

expire

public Long expire(String key,
                   long seconds)

Specified by:

expire in interface JedisCommands

pexpire

public Long pexpire(String key,
                    long milliseconds)

Specified by:

pexpire in interface JedisCommands

expireAt

public Long expireAt(String key,
                     long unixTime)

Specified by:

expireAt in interface JedisCommands

pexpireAt

public Long pexpireAt(String key,
                      long millisecondsTimestamp)

Specified by:

pexpireAt in interface JedisCommands

ttl

public Long ttl(String key)

Specified by:

ttl in interface JedisCommands

pttl

public Long pttl(String key)

Specified by:

pttl in interface JedisCommands

setbit

public Boolean setbit(String key,
                      long offset,
                      boolean value)

Specified by:

setbit in interface JedisCommands

setbit

public Boolean setbit(String key,
                      long offset,
                      String value)

Specified by:

setbit in interface JedisCommands

getbit

public Boolean getbit(String key,
                      long offset)

Specified by:

getbit in interface JedisCommands

setrange

public Long setrange(String key,
                     long offset,
                     String value)

Specified by:

setrange in interface JedisCommands

getrange

public String getrange(String key,
                       long startOffset,
                       long endOffset)

Specified by:

getrange in interface JedisCommands

getSet

public String getSet(String key,
                     String value)

Specified by:

getSet in interface JedisCommands

setnx

public Long setnx(String key,
                  String value)

Specified by:

setnx in interface JedisCommands

setex

public String setex(String key,
                    long seconds,
                    String value)

Specified by:

setex in interface JedisCommands

psetex

public String psetex(String key,
                     long milliseconds,
                     String value)

Specified by:

psetex in interface JedisCommands

blpop

public List<String> blpop(int timeout,
                          String key)

Specified by:

blpop in interface JedisCommands

blpop

public KeyedListElement blpop(double timeout,
                              String key)

Specified by:

blpop in interface JedisCommands

brpop

public List<String> brpop(int timeout,
                          String key)

Specified by:

brpop in interface JedisCommands

brpop

public KeyedListElement brpop(double timeout,
                              String key)

Specified by:

brpop in interface JedisCommands

decrBy

public Long decrBy(String key,
                   long decrement)

Specified by:

decrBy in interface JedisCommands

decr

public Long decr(String key)

Specified by:

decr in interface JedisCommands

incrBy

public Long incrBy(String key,
                   long increment)

Specified by:

incrBy in interface JedisCommands

incrByFloat

public Double incrByFloat(String key,
                          double increment)

Specified by:

incrByFloat in interface JedisCommands

incr

public Long incr(String key)

Specified by:

incr in interface JedisCommands

append

public Long append(String key,
                   String value)

Specified by:

append in interface JedisCommands

substr

public String substr(String key,
                     int start,
                     int end)

Specified by:

substr in interface JedisCommands

hset

public Long hset(String key,
                 String field,
                 String value)

Specified by:

hset in interface JedisCommands

hset

public Long hset(String key,
                 Map<String,String> hash)

Specified by:

hset in interface JedisCommands

hget

public String hget(String key,
                   String field)

Specified by:

hget in interface JedisCommands

hsetnx

public Long hsetnx(String key,
                   String field,
                   String value)

Specified by:

hsetnx in interface JedisCommands

hmset

public String hmset(String key,
                    Map<String,String> hash)

Specified by:

hmset in interface JedisCommands

hmget

public List<String> hmget(String key,
                          String... fields)

Specified by:

hmget in interface JedisCommands

hincrBy

public Long hincrBy(String key,
                    String field,
                    long value)

Specified by:

hincrBy in interface JedisCommands

hincrByFloat

public Double hincrByFloat(String key,
                           String field,
                           double value)

Specified by:

hincrByFloat in interface JedisCommands

hexists

public Boolean hexists(String key,
                       String field)

Specified by:

hexists in interface JedisCommands

del

public Long del(String key)

Specified by:

del in interface JedisCommands

unlink

public Long unlink(String key)

Specified by:

unlink in interface JedisCommands

hdel

public Long hdel(String key,
                 String... fields)

Specified by:

hdel in interface JedisCommands

hlen

public Long hlen(String key)

Specified by:

hlen in interface JedisCommands

hkeys

public Set<String> hkeys(String key)

Specified by:

hkeys in interface JedisCommands

hvals

public List<String> hvals(String key)

Specified by:

hvals in interface JedisCommands

hgetAll

public Map<String,String> hgetAll(String key)

Specified by:

hgetAll in interface JedisCommands

hrandfield

public String hrandfield(String key)

Specified by:

hrandfield in interface JedisCommands

hrandfield

public List<String> hrandfield(String key,
                               long count)

Specified by:

hrandfield in interface JedisCommands

hrandfieldWithValues

public Map<String,String> hrandfieldWithValues(String key,
                                               long count)

Specified by:

hrandfieldWithValues in interface JedisCommands

rpush

public Long rpush(String key,
                  String... strings)

Specified by:

rpush in interface JedisCommands

lpush

public Long lpush(String key,
                  String... strings)

Specified by:

lpush in interface JedisCommands

lpushx

public Long lpushx(String key,
                   String... string)

Specified by:

lpushx in interface JedisCommands

strlen

public Long strlen(String key)

Specified by:

strlen in interface JedisCommands

move

public Long move(String key,
                 int dbIndex)

Specified by:

move in interface JedisCommands

rpushx

public Long rpushx(String key,
                   String... string)

Specified by:

rpushx in interface JedisCommands

persist

public Long persist(String key)

Specified by:

persist in interface JedisCommands

llen

public Long llen(String key)

Specified by:

llen in interface JedisCommands

lrange

public List<String> lrange(String key,
                           long start,
                           long stop)

Specified by:

lrange in interface JedisCommands

ltrim

public String ltrim(String key,
                    long start,
                    long stop)

Specified by:

ltrim in interface JedisCommands

lindex

public String lindex(String key,
                     long index)

Specified by:

lindex in interface JedisCommands

lset

public String lset(String key,
                   long index,
                   String value)

Specified by:

lset in interface JedisCommands

lrem

public Long lrem(String key,
                 long count,
                 String value)

Specified by:

lrem in interface JedisCommands

lpop

public String lpop(String key)

Specified by:

lpop in interface JedisCommands

lpop

public List<String> lpop(String key,
                         int count)

Specified by:

lpop in interface JedisCommands

lpos

public Long lpos(String key,
                 String element)

Specified by:

lpos in interface JedisCommands

lpos

public Long lpos(String key,
                 String element,
                 LPosParams params)

Specified by:

lpos in interface JedisCommands

lpos

public List<Long> lpos(String key,
                       String element,
                       LPosParams params,
                       long count)

Specified by:

lpos in interface JedisCommands

rpop

public String rpop(String key)

Specified by:

rpop in interface JedisCommands

rpop

public List<String> rpop(String key,
                         int count)

Specified by:

rpop in interface JedisCommands

sadd

public Long sadd(String key,
                 String... members)

Specified by:

sadd in interface JedisCommands

smembers

public Set<String> smembers(String key)

Specified by:

smembers in interface JedisCommands

srem

public Long srem(String key,
                 String... members)

Specified by:

srem in interface JedisCommands

spop

public String spop(String key)

Specified by:

spop in interface JedisCommands

spop

public Set<String> spop(String key,
                        long count)

Specified by:

spop in interface JedisCommands

scard

public Long scard(String key)

Specified by:

scard in interface JedisCommands

sismember

public Boolean sismember(String key,
                         String member)

Specified by:

sismember in interface JedisCommands

smismember

public List<Boolean> smismember(String key,
                                String... members)

Specified by:

smismember in interface JedisCommands

srandmember

public String srandmember(String key)

Specified by:

srandmember in interface JedisCommands

srandmember

public List<String> srandmember(String key,
                                int count)

Specified by:

srandmember in interface JedisCommands

zadd

public Long zadd(String key,
                 double score,
                 String member)

Specified by:

zadd in interface JedisCommands

zadd

public Long zadd(String key,
                 double score,
                 String member,
                 ZAddParams params)

Specified by:

zadd in interface JedisCommands

zadd

public Long zadd(String key,
                 Map<String,Double> scoreMembers)

Specified by:

zadd in interface JedisCommands

zadd

public Long zadd(String key,
                 Map<String,Double> scoreMembers,
                 ZAddParams params)

Specified by:

zadd in interface JedisCommands

zaddIncr

public Double zaddIncr(String key,
                       double score,
                       String member,
                       ZAddParams params)

Specified by:

zaddIncr in interface JedisCommands

zrange

public Set<String> zrange(String key,
                          long start,
                          long stop)

Specified by:

zrange in interface JedisCommands

zrem

public Long zrem(String key,
                 String... members)

Specified by:

zrem in interface JedisCommands

zincrby

public Double zincrby(String key,
                      double increment,
                      String member)

Specified by:

zincrby in interface JedisCommands

zincrby

public Double zincrby(String key,
                      double increment,
                      String member,
                      ZIncrByParams params)

Specified by:

zincrby in interface JedisCommands

zrank

public Long zrank(String key,
                  String member)

Specified by:

zrank in interface JedisCommands

zrevrank

public Long zrevrank(String key,
                     String member)

Specified by:

zrevrank in interface JedisCommands

zrevrange

public Set<String> zrevrange(String key,
                             long start,
                             long stop)

Specified by:

zrevrange in interface JedisCommands

zrangeWithScores

public Set<Tuple> zrangeWithScores(String key,
                                   long start,
                                   long stop)

Specified by:

zrangeWithScores in interface JedisCommands

zrevrangeWithScores

public Set<Tuple> zrevrangeWithScores(String key,
                                      long start,
                                      long stop)

Specified by:

zrevrangeWithScores in interface JedisCommands

zrandmember

public String zrandmember(String key)

Specified by:

zrandmember in interface JedisCommands

zrandmember

public Set<String> zrandmember(String key,
                               long count)

Specified by:

zrandmember in interface JedisCommands

zrandmemberWithScores

public Set<Tuple> zrandmemberWithScores(String key,
                                        long count)

Specified by:

zrandmemberWithScores in interface JedisCommands

zcard

public Long zcard(String key)

Specified by:

zcard in interface JedisCommands

zscore

public Double zscore(String key,
                     String member)

Specified by:

zscore in interface JedisCommands

zmscore

public List<Double> zmscore(String key,
                            String... members)

Specified by:

zmscore in interface JedisCommands

zpopmax

public Tuple zpopmax(String key)

Specified by:

zpopmax in interface JedisCommands

zpopmax

public Set<Tuple> zpopmax(String key,
                          int count)

Specified by:

zpopmax in interface JedisCommands

zpopmin

public Tuple zpopmin(String key)

Specified by:

zpopmin in interface JedisCommands

zpopmin

public Set<Tuple> zpopmin(String key,
                          int count)

Specified by:

zpopmin in interface JedisCommands

sort

public List<String> sort(String key)

Specified by:

sort in interface JedisCommands

sort

public List<String> sort(String key,
                         SortingParams sortingParameters)

Specified by:

sort in interface JedisCommands

zcount

public Long zcount(String key,
                   double min,
                   double max)

Specified by:

zcount in interface JedisCommands

zcount

public Long zcount(String key,
                   String min,
                   String max)

Specified by:

zcount in interface JedisCommands

zrangeByScore

public Set<String> zrangeByScore(String key,
                                 double min,
                                 double max)

Specified by:

zrangeByScore in interface JedisCommands

zrevrangeByScore

public Set<String> zrevrangeByScore(String key,
                                    double max,
                                    double min)

Specified by:

zrevrangeByScore in interface JedisCommands

zrangeByScore

public Set<String> zrangeByScore(String key,
                                 double min,
                                 double max,
                                 int offset,
                                 int count)

Specified by:

zrangeByScore in interface JedisCommands

zrevrangeByScore

public Set<String> zrevrangeByScore(String key,
                                    double max,
                                    double min,
                                    int offset,
                                    int count)

Specified by:

zrevrangeByScore in interface JedisCommands

zrangeByScoreWithScores

public Set<Tuple> zrangeByScoreWithScores(String key,
                                          double min,
                                          double max)

Specified by:

zrangeByScoreWithScores in interface JedisCommands

zrevrangeByScoreWithScores

public Set<Tuple> zrevrangeByScoreWithScores(String key,
                                             double max,
                                             double min)

Specified by:

zrevrangeByScoreWithScores in interface JedisCommands

zrangeByScoreWithScores

public Set<Tuple> zrangeByScoreWithScores(String key,
                                          double min,
                                          double max,
                                          int offset,
                                          int count)

Specified by:

zrangeByScoreWithScores in interface JedisCommands

zrevrangeByScoreWithScores

public Set<Tuple> zrevrangeByScoreWithScores(String key,
                                             double max,
                                             double min,
                                             int offset,
                                             int count)

Specified by:

zrevrangeByScoreWithScores in interface JedisCommands

zrangeByScore

public Set<String> zrangeByScore(String key,
                                 String min,
                                 String max)

Specified by:

zrangeByScore in interface JedisCommands

zrevrangeByScore

public Set<String> zrevrangeByScore(String key,
                                    String max,
                                    String min)

Specified by:

zrevrangeByScore in interface JedisCommands

zrangeByScore

public Set<String> zrangeByScore(String key,
                                 String min,
                                 String max,
                                 int offset,
                                 int count)

Specified by:

zrangeByScore in interface JedisCommands

zrevrangeByScore

public Set<String> zrevrangeByScore(String key,
                                    String max,
                                    String min,
                                    int offset,
                                    int count)

Specified by:

zrevrangeByScore in interface JedisCommands

zrangeByScoreWithScores

public Set<Tuple> zrangeByScoreWithScores(String key,
                                          String min,
                                          String max)

Specified by:

zrangeByScoreWithScores in interface JedisCommands

zrevrangeByScoreWithScores

public Set<Tuple> zrevrangeByScoreWithScores(String key,
                                             String max,
                                             String min)

Specified by:

zrevrangeByScoreWithScores in interface JedisCommands

zrangeByScoreWithScores

public Set<Tuple> zrangeByScoreWithScores(String key,
                                          String min,
                                          String max,
                                          int offset,
                                          int count)

Specified by:

zrangeByScoreWithScores in interface JedisCommands

zrevrangeByScoreWithScores

public Set<Tuple> zrevrangeByScoreWithScores(String key,
                                             String max,
                                             String min,
                                             int offset,
                                             int count)

Specified by:

zrevrangeByScoreWithScores in interface JedisCommands

zremrangeByRank

public Long zremrangeByRank(String key,
                            long start,
                            long stop)

Specified by:

zremrangeByRank in interface JedisCommands

zremrangeByScore

public Long zremrangeByScore(String key,
                             double min,
                             double max)

Specified by:

zremrangeByScore in interface JedisCommands

zremrangeByScore

public Long zremrangeByScore(String key,
                             String min,
                             String max)

Specified by:

zremrangeByScore in interface JedisCommands

zlexcount

public Long zlexcount(String key,
                      String min,
                      String max)

Specified by:

zlexcount in interface JedisCommands

zrangeByLex

public Set<String> zrangeByLex(String key,
                               String min,
                               String max)

Specified by:

zrangeByLex in interface JedisCommands

zrangeByLex

public Set<String> zrangeByLex(String key,
                               String min,
                               String max,
                               int offset,
                               int count)

Specified by:

zrangeByLex in interface JedisCommands

zrevrangeByLex

public Set<String> zrevrangeByLex(String key,
                                  String max,
                                  String min)

Specified by:

zrevrangeByLex in interface JedisCommands

zrevrangeByLex

public Set<String> zrevrangeByLex(String key,
                                  String max,
                                  String min,
                                  int offset,
                                  int count)

Specified by:

zrevrangeByLex in interface JedisCommands

zremrangeByLex

public Long zremrangeByLex(String key,
                           String min,
                           String max)

Specified by:

zremrangeByLex in interface JedisCommands

linsert

public Long linsert(String key,
                    ListPosition where,
                    String pivot,
                    String value)

Specified by:

linsert in interface JedisCommands

bitcount

public Long bitcount(String key)

Specified by:

bitcount in interface JedisCommands

bitcount

public Long bitcount(String key,
                     long start,
                     long end)

Specified by:

bitcount in interface JedisCommands

bitpos

public Long bitpos(String key,
                   boolean value)

Specified by:

bitpos in interface JedisCommands

bitpos

public Long bitpos(String key,
                   boolean value,
                   BitPosParams params)

Specified by:

bitpos in interface JedisCommands

hscan

public ScanResult<Map.Entry<String,String>> hscan(String key,
                                                  String cursor)

Specified by:

hscan in interface JedisCommands

hscan

public ScanResult<Map.Entry<String,String>> hscan(String key,
                                                  String cursor,
                                                  ScanParams params)

Specified by:

hscan in interface JedisCommands

sscan

public ScanResult<String> sscan(String key,
                                String cursor)

Specified by:

sscan in interface JedisCommands

zscan

public ScanResult<Tuple> zscan(String key,
                               String cursor)

Specified by:

zscan in interface JedisCommands

zscan

public ScanResult<Tuple> zscan(String key,
                               String cursor,
                               ScanParams params)

Specified by:

zscan in interface JedisCommands

sscan

public ScanResult<String> sscan(String key,
                                String cursor,
                                ScanParams params)

Specified by:

sscan in interface JedisCommands

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

setDataSource

public void setDataSource(ShardedJedisPool shardedJedisPool)

resetState

public void resetState()

pfadd

public Long pfadd(String key,
                  String... elements)

Specified by:

pfadd in interface JedisCommands

pfcount

public long pfcount(String key)

Specified by:

pfcount in interface JedisCommands

touch

public Long touch(String key)

Specified by:

touch in interface JedisCommands

geoadd

public Long geoadd(String key,
                   double longitude,
                   double latitude,
                   String member)

Specified by:

geoadd in interface JedisCommands

geoadd

public Long geoadd(String key,
                   Map<String,GeoCoordinate> memberCoordinateMap)

Specified by:

geoadd in interface JedisCommands

geoadd

public Long geoadd(String key,
                   GeoAddParams params,
                   Map<String,GeoCoordinate> memberCoordinateMap)

Specified by:

geoadd in interface JedisCommands

geodist

public Double geodist(String key,
                      String member1,
                      String member2)

Specified by:

geodist in interface JedisCommands

geodist

public Double geodist(String key,
                      String member1,
                      String member2,
                      GeoUnit unit)

Specified by:

geodist in interface JedisCommands

geohash

public List<String> geohash(String key,
                            String... members)

Specified by:

geohash in interface JedisCommands

geopos

public List<GeoCoordinate> geopos(String key,
                                  String... members)

Specified by:

geopos in interface JedisCommands

georadius

public List<GeoRadiusResponse> georadius(String key,
                                         double longitude,
                                         double latitude,
                                         double radius,
                                         GeoUnit unit)

Specified by:

georadius in interface JedisCommands

georadiusReadonly

public List<GeoRadiusResponse> georadiusReadonly(String key,
                                                 double longitude,
                                                 double latitude,
                                                 double radius,
                                                 GeoUnit unit)

Specified by:

georadiusReadonly in interface JedisCommands

georadius

public List<GeoRadiusResponse> georadius(String key,
                                         double longitude,
                                         double latitude,
                                         double radius,
                                         GeoUnit unit,
                                         GeoRadiusParam param)

Specified by:

georadius in interface JedisCommands

georadiusReadonly

public List<GeoRadiusResponse> georadiusReadonly(String key,
                                                 double longitude,
                                                 double latitude,
                                                 double radius,
                                                 GeoUnit unit,
                                                 GeoRadiusParam param)

Specified by:

georadiusReadonly in interface JedisCommands

georadiusByMember

public List<GeoRadiusResponse> georadiusByMember(String key,
                                                 String member,
                                                 double radius,
                                                 GeoUnit unit)

Specified by:

georadiusByMember in interface JedisCommands

georadiusByMemberReadonly

public List<GeoRadiusResponse> georadiusByMemberReadonly(String key,
                                                         String member,
                                                         double radius,
                                                         GeoUnit unit)

Specified by:

georadiusByMemberReadonly in interface JedisCommands

georadiusByMember

public List<GeoRadiusResponse> georadiusByMember(String key,
                                                 String member,
                                                 double radius,
                                                 GeoUnit unit,
                                                 GeoRadiusParam param)

Specified by:

georadiusByMember in interface JedisCommands

georadiusByMemberReadonly

public List<GeoRadiusResponse> georadiusByMemberReadonly(String key,
                                                         String member,
                                                         double radius,
                                                         GeoUnit unit,
                                                         GeoRadiusParam param)

Specified by:

georadiusByMemberReadonly in interface JedisCommands

bitfield

public List<Long> bitfield(String key,
                           String... arguments)

Description copied from interface: JedisCommands

Executes BITFIELD Redis command

Specified by:

bitfield in interface JedisCommands

Returns:

bitfieldReadonly

public List<Long> bitfieldReadonly(String key,
                                   String... arguments)

Specified by:

bitfieldReadonly in interface JedisCommands

hstrlen

public Long hstrlen(String key,
                    String field)

Description copied from interface: JedisCommands

Used for HSTRLEN Redis command

Specified by:

hstrlen in interface JedisCommands

Returns:

length of the value for key

xadd

public StreamEntryID xadd(String key,
                          StreamEntryID id,
                          Map<String,String> hash)

Description copied from interface: JedisCommands

XADD key ID field string [field string ...]

Specified by:

xadd in interface JedisCommands

Returns:

the ID of the added entry

xadd

public StreamEntryID xadd(String key,
                          StreamEntryID id,
                          Map<String,String> hash,
                          long maxLen,
                          boolean approximateLength)

Description copied from interface: JedisCommands

XADD key MAXLEN ~ LEN ID field string [field string ...]

Specified by:

xadd in interface JedisCommands

Returns:

xadd

public StreamEntryID xadd(String key,
                          Map<String,String> hash,
                          XAddParams params)

Description copied from interface: JedisCommands

XADD key [NOMKSTREAM] [MAXLEN|MINID [=|~] threshold [LIMIT count]] *|ID field value [field value ...]

Specified by:

xadd in interface JedisCommands

Returns:

xlen

public Long xlen(String key)

Description copied from interface: JedisCommands

XLEN key

Specified by:

xlen in interface JedisCommands

Returns:

xrange

public List<StreamEntry> xrange(String key,
                                StreamEntryID start,
                                StreamEntryID end)

Description copied from interface: JedisCommands

XRANGE key start end

Specified by:

xrange in interface JedisCommands

start - minimum StreamEntryID for the retrieved range, passing null will indicate minimum ID possible in the stream

end - maximum StreamEntryID for the retrieved range, passing null will indicate maximum ID possible in the stream

Returns:

The entries with IDs matching the specified range.

xrange

public List<StreamEntry> xrange(String key,
                                StreamEntryID start,
                                StreamEntryID end,
                                int count)

Description copied from interface: JedisCommands

XRANGE key start end COUNT count

Specified by:

xrange in interface JedisCommands

start - minimum StreamEntryID for the retrieved range, passing null will indicate minimum ID possible in the stream

end - maximum StreamEntryID for the retrieved range, passing null will indicate maximum ID possible in the stream

count - maximum number of entries returned

Returns:

The entries with IDs matching the specified range.

xack

public long xack(String key,
                 String group,
                 StreamEntryID... ids)

Description copied from interface: JedisCommands

XACK key group ID [ID ...]

Specified by:

xack in interface JedisCommands

Returns:

xgroupCreate

public String xgroupCreate(String key,
                           String consumer,
                           StreamEntryID id,
                           boolean makeStream)

Description copied from interface: JedisCommands

XGROUP CREATE

Specified by:

xgroupCreate in interface JedisCommands

Returns:

xgroupSetID

public String xgroupSetID(String key,
                          String groupname,
                          StreamEntryID id)

Description copied from interface: JedisCommands

XGROUP SETID

Specified by:

xgroupSetID in interface JedisCommands

Returns:

xgroupDestroy

public long xgroupDestroy(String key,
                          String groupname)

Description copied from interface: JedisCommands

XGROUP DESTROY

Specified by:

xgroupDestroy in interface JedisCommands

Returns:

xgroupDelConsumer

public Long xgroupDelConsumer(String key,
                              String groupname,
                              String consumername)

Description copied from interface: JedisCommands

XGROUP DELCONSUMER

Specified by:

xgroupDelConsumer in interface JedisCommands

Returns:

xdel

public long xdel(String key,
                 StreamEntryID... ids)

Description copied from interface: JedisCommands

XDEL key ID [ID ...]

Specified by:

xdel in interface JedisCommands

Returns:

xtrim

public long xtrim(String key,
                  long maxLen,
                  boolean approximateLength)

Description copied from interface: JedisCommands

XTRIM key MAXLEN [~] count

Specified by:

xtrim in interface JedisCommands

Returns:

xtrim

public long xtrim(String key,
                  XTrimParams params)

Description copied from interface: JedisCommands

XTRIM key MAXLEN|MINID [=|~] threshold [LIMIT count]

Specified by:

xtrim in interface JedisCommands

Returns:

xrevrange

public List<StreamEntry> xrevrange(String key,
                                   StreamEntryID end,
                                   StreamEntryID start)

Description copied from interface: JedisCommands

XREVRANGE key end start

Specified by:

xrevrange in interface JedisCommands

end - maximum StreamEntryID for the retrieved range, passing null will indicate maximum ID possible in the stream

start - minimum StreamEntryID for the retrieved range, passing null will indicate minimum ID possible in the stream

Returns:

the entries with IDs matching the specified range, from the higher ID to the lower ID matching.

xrevrange

public List<StreamEntry> xrevrange(String key,
                                   StreamEntryID end,
                                   StreamEntryID start,
                                   int count)

Description copied from interface: JedisCommands

XREVRANGE key end start COUNT count

Specified by:

xrevrange in interface JedisCommands

end - maximum StreamEntryID for the retrieved range, passing null will indicate maximum ID possible in the stream

start - minimum StreamEntryID for the retrieved range, passing null will indicate minimum ID possible in the stream

count - The entries with IDs matching the specified range.

Returns:

the entries with IDs matching the specified range, from the higher ID to the lower ID matching.

xpending

public StreamPendingSummary xpending(String key,
                                     String groupname)

Description copied from interface: JedisCommands

XPENDING key group

Specified by:

xpending in interface JedisCommands

Returns:

xpending

public List<StreamPendingEntry> xpending(String key,
                                         String groupname,
                                         StreamEntryID start,
                                         StreamEntryID end,
                                         int count,
                                         String consumername)

Description copied from interface: JedisCommands

XPENDING key group [start end count] [consumer]

Specified by:

xpending in interface JedisCommands

Returns:

xpending

public List<StreamPendingEntry> xpending(String key,
                                         String groupname,
                                         XPendingParams params)

Description copied from interface: JedisCommands

XPENDING key group [[IDLE min-idle-time] start end count [consumer]]

Specified by:

xpending in interface JedisCommands

xclaim

public List<StreamEntry> xclaim(String key,
                                String group,
                                String consumername,
                                long minIdleTime,
                                long newIdleTime,
                                int retries,
                                boolean force,
                                StreamEntryID... ids)

Description copied from interface: JedisCommands

XCLAIM [IDLE ] [TIME ] [RETRYCOUNT ] [FORCE] [JUSTID]

Specified by:

xclaim in interface JedisCommands

xclaim

public List<StreamEntry> xclaim(String key,
                                String group,
                                String consumername,
                                long minIdleTime,
                                XClaimParams params,
                                StreamEntryID... ids)

Description copied from interface: JedisCommands

XCLAIM ... [IDLE ] [TIME ] [RETRYCOUNT ] [FORCE]

Specified by:

xclaim in interface JedisCommands

xclaimJustId

public List<StreamEntryID> xclaimJustId(String key,
                                        String group,
                                        String consumername,
                                        long minIdleTime,
                                        XClaimParams params,
                                        StreamEntryID... ids)

Description copied from interface: JedisCommands

XCLAIM ... [IDLE ] [TIME ] [RETRYCOUNT ] [FORCE] JUSTID

Specified by:

xclaimJustId in interface JedisCommands

xinfoStream

public StreamInfo xinfoStream(String key)

Description copied from interface: JedisCommands

Introspection command used in order to retrieve different information about the stream

Specified by:

xinfoStream in interface JedisCommands

Parameters:

key - Stream name

Returns:

StreamInfo that contains information about the stream

xinfoGroup

public List<StreamGroupInfo> xinfoGroup(String key)

Description copied from interface: JedisCommands

Introspection command used in order to retrieve different information about groups in the stream

Specified by:

xinfoGroup in interface JedisCommands

Parameters:

key - Stream name

Returns:

List of StreamGroupInfo containing information about groups

xinfoConsumers

public List<StreamConsumersInfo> xinfoConsumers(String key,
                                                String group)

Description copied from interface: JedisCommands

Introspection command used in order to retrieve different information about consumers in the group

Specified by:

xinfoConsumers in interface JedisCommands

Parameters:

key - Stream name

group - Group name

Returns:

List of StreamConsumersInfo containing information about consumers that belong to the the group

sendCommand

public Object sendCommand(ProtocolCommand cmd,
                          String... args)

sendBlockingCommand

public Object sendBlockingCommand(ProtocolCommand cmd,
                                  String... args)