redis.clients.jedis

Class UnifiedJedis

java.lang.Object

redis.clients.jedis.UnifiedJedis

All Implemented Interfaces:

AutoCloseable, GeoBinaryCommands, GeoCommands, HashBinaryCommands, HashCommands, HyperLogLogBinaryCommands, HyperLogLogCommands, JedisBinaryCommands, JedisCommands, KeyBinaryCommands, KeyCommands, ListBinaryCommands, ListCommands, RedisModuleCommands, SampleBinaryKeyedCommands, SampleKeyedCommands, ScriptingKeyBinaryCommands, ScriptingKeyCommands, SetBinaryCommands, SetCommands, SortedSetBinaryCommands, SortedSetCommands, StreamBinaryCommands, StreamCommands, StringBinaryCommands, StringCommands, RedisJsonCommands, RediSearchCommands

Direct Known Subclasses:

JedisCluster, JedisPooled, JedisSharding

public class UnifiedJedis
extends Object
implements JedisCommands, JedisBinaryCommands, SampleKeyedCommands, SampleBinaryKeyedCommands, RedisModuleCommands, AutoCloseable

Field Summary

Fields

Modifier and Type	Field and Description
protected CommandExecutor	executor
protected ConnectionProvider	provider

Constructor Summary

Constructors

Constructor and Description
UnifiedJedis()
UnifiedJedis(ClusterConnectionProvider provider, int maxAttempts, Duration maxTotalRetriesDuration)
UnifiedJedis(Connection connection)
UnifiedJedis(ConnectionProvider provider)
UnifiedJedis(ConnectionProvider provider, int maxAttempts, Duration maxTotalRetriesDuration)
UnifiedJedis(HostAndPort hostAndPort)
UnifiedJedis(HostAndPort hostAndPort, JedisClientConfig clientConfig)
UnifiedJedis(JedisSocketFactory socketFactory)
UnifiedJedis(Set<HostAndPort> jedisClusterNodes, JedisClientConfig clientConfig, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig, int maxAttempts, Duration maxTotalRetriesDuration)
UnifiedJedis(Set<HostAndPort> jedisClusterNodes, JedisClientConfig clientConfig, int maxAttempts)
UnifiedJedis(Set<HostAndPort> jedisClusterNodes, JedisClientConfig clientConfig, int maxAttempts, Duration maxTotalRetriesDuration)
UnifiedJedis(ShardedConnectionProvider provider)
UnifiedJedis(ShardedConnectionProvider provider, Pattern tagPattern)
UnifiedJedis(String url)
UnifiedJedis(URI uri)
UnifiedJedis(URI uri, JedisClientConfig config)

Method Summary

Modifier and Type	Method and Description
long	append(byte[] key, byte[] value)
long	append(String key, String value)
long	bitcount(byte[] key)
long	bitcount(byte[] key, long start, long end)
long	bitcount(byte[] key, long start, long end, BitCountOption option)
long	bitcount(String key)
long	bitcount(String key, long start, long end)
long	bitcount(String key, long start, long end, BitCountOption option)
List<Long>	bitfield(byte[] key, byte[]... arguments)
List<Long>	bitfield(String key, String... arguments)
List<Long>	bitfieldReadonly(byte[] key, byte[]... arguments)
List<Long>	bitfieldReadonly(String key, String... arguments)
long	bitop(BitOP op, byte[] destKey, byte[]... srcKeys)
long	bitop(BitOP op, String destKey, String... srcKeys)
long	bitpos(byte[] key, boolean value)
long	bitpos(byte[] key, boolean value, BitPosParams params)
long	bitpos(String key, boolean value)
long	bitpos(String key, boolean value, BitPosParams params)
byte[]	blmove(byte[] srcKey, byte[] dstKey, ListDirection from, ListDirection to, double timeout)
String	blmove(String srcKey, String dstKey, ListDirection from, ListDirection to, double timeout)
List<byte[]>	blpop(double timeout, byte[]... keys)
KeyedListElement	blpop(double timeout, String... keys)
KeyedListElement	blpop(double timeout, String key)
List<byte[]>	blpop(int timeout, byte[]... keys)
List<String>	blpop(int timeout, String... keys)
List<String>	blpop(int timeout, String key)
List<byte[]>	brpop(double timeout, byte[]... keys)
KeyedListElement	brpop(double timeout, String... keys)
KeyedListElement	brpop(double timeout, String key)
List<byte[]>	brpop(int timeout, byte[]... keys)
List<String>	brpop(int timeout, String... keys)
List<String>	brpop(int timeout, String key)
byte[]	brpoplpush(byte[] source, byte[] destination, int timeout)
String	brpoplpush(String source, String destination, int timeout)
List<byte[]>	bzpopmax(double timeout, byte[]... keys)
KeyedZSetElement	bzpopmax(double timeout, String... keys)
List<byte[]>	bzpopmin(double timeout, byte[]... keys)
KeyedZSetElement	bzpopmin(double timeout, String... keys)
void	close()
boolean	copy(byte[] srcKey, byte[] dstKey, boolean replace)
boolean	copy(String srcKey, String dstKey, boolean replace)
long	dbSize()
long	decr(byte[] key)
long	decr(String key)
long	decrBy(byte[] key, long decrement)
long	decrBy(String key, long decrement)
long	del(byte[]... keys)
long	del(byte[] key)
long	del(String... keys)
long	del(String key)
byte[]	dump(byte[] key)
byte[]	dump(String key)
Object	eval(byte[] script)
Object	eval(byte[] script, byte[] sampleKey)
Object	eval(byte[] script, int keyCount, byte[]... params)
Object	eval(byte[] script, List<byte[]> keys, List<byte[]> args)
Object	eval(String script)
Object	eval(String script, int keyCount, String... params)
Object	eval(String script, List<String> keys, List<String> args)
Object	eval(String script, String sampleKey)
Object	evalsha(byte[] sha1)
Object	evalsha(byte[] sha1, byte[] sampleKey)
Object	evalsha(byte[] sha1, int keyCount, byte[]... params)
Object	evalsha(byte[] sha1, List<byte[]> keys, List<byte[]> args)
Object	evalsha(String sha1)
Object	evalsha(String sha1, int keyCount, String... params)
Object	evalsha(String sha1, List<String> keys, List<String> args)
Object	evalsha(String sha1, String sampleKey)
Object	executeCommand(CommandArguments args)
<T> T	executeCommand(CommandObject<T> commandObject)
long	exists(byte[]... keys)
boolean	exists(byte[] key)
long	exists(String... keys)
boolean	exists(String key)
long	expire(byte[] key, long seconds)
long	expire(String key, long seconds)
long	expireAt(byte[] key, long unixTime)
long	expireAt(String key, long unixTime)
AggregationResult	ftAggregate(String indexName, AggregationBuilder aggr)
String	ftAliasAdd(String aliasName, String indexName)
String	ftAliasDel(String aliasName)
String	ftAliasUpdate(String aliasName, String indexName)
String	ftAlter(String indexName, Schema schema)
Map<String,String>	ftConfigGet(String option)
Map<String,String>	ftConfigGet(String indexName, String option)
String	ftConfigSet(String option, String value)
String	ftConfigSet(String indexName, String option, String value)
String	ftCreate(String indexName, IndexOptions indexOptions, Schema schema)
String	ftCursorDel(String indexName, long cursorId)
AggregationResult	ftCursorRead(String indexName, long cursorId, int count)
String	ftDropIndex(String indexName)
String	ftDropIndexDD(String indexName)
String	ftExplain(String indexName, Query query)
List<String>	ftExplainCLI(String indexName, Query query)
Map<String,Object>	ftInfo(String indexName)
SearchResult	ftSearch(byte[] indexName, Query query)
SearchResult	ftSearch(String indexName, Query query)
Map<String,List<String>>	ftSynDump(String indexName)
String	ftSynUpdate(String indexName, String synonymGroupId, String... terms)
long	geoadd(byte[] key, double longitude, double latitude, byte[] member)
long	geoadd(byte[] key, GeoAddParams params, Map<byte[],GeoCoordinate> memberCoordinateMap)
long	geoadd(byte[] key, Map<byte[],GeoCoordinate> memberCoordinateMap)
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(byte[] key, byte[] member1, byte[] member2)
Double	geodist(byte[] key, byte[] member1, byte[] member2, GeoUnit unit)
Double	geodist(String key, String member1, String member2)
Double	geodist(String key, String member1, String member2, GeoUnit unit)
List<byte[]>	geohash(byte[] key, byte[]... members)
List<String>	geohash(String key, String... members)
List<GeoCoordinate>	geopos(byte[] key, byte[]... members)
List<GeoCoordinate>	geopos(String key, String... members)
List<GeoRadiusResponse>	georadius(byte[] key, double longitude, double latitude, double radius, GeoUnit unit)
List<GeoRadiusResponse>	georadius(byte[] key, double longitude, double latitude, double radius, GeoUnit unit, GeoRadiusParam param)
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(byte[] key, byte[] member, double radius, GeoUnit unit)
List<GeoRadiusResponse>	georadiusByMember(byte[] key, byte[] member, 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(byte[] key, byte[] member, double radius, GeoUnit unit)
List<GeoRadiusResponse>	georadiusByMemberReadonly(byte[] key, byte[] 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)
long	georadiusByMemberStore(byte[] key, byte[] member, double radius, GeoUnit unit, GeoRadiusParam param, GeoRadiusStoreParam storeParam)
long	georadiusByMemberStore(String key, String member, double radius, GeoUnit unit, GeoRadiusParam param, GeoRadiusStoreParam storeParam)
List<GeoRadiusResponse>	georadiusReadonly(byte[] key, double longitude, double latitude, double radius, GeoUnit unit)
List<GeoRadiusResponse>	georadiusReadonly(byte[] key, double longitude, double latitude, 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)
long	georadiusStore(byte[] key, double longitude, double latitude, double radius, GeoUnit unit, GeoRadiusParam param, GeoRadiusStoreParam storeParam)
long	georadiusStore(String key, double longitude, double latitude, double radius, GeoUnit unit, GeoRadiusParam param, GeoRadiusStoreParam storeParam)
List<GeoRadiusResponse>	geosearch(byte[] key, byte[] member, double width, double height, GeoUnit unit)
List<GeoRadiusResponse>	geosearch(byte[] key, byte[] member, double radius, GeoUnit unit)
List<GeoRadiusResponse>	geosearch(byte[] key, GeoCoordinate coord, double width, double height, GeoUnit unit)
List<GeoRadiusResponse>	geosearch(byte[] key, GeoCoordinate coord, double radius, GeoUnit unit)
List<GeoRadiusResponse>	geosearch(byte[] key, GeoSearchParam params)
List<GeoRadiusResponse>	geosearch(String key, GeoCoordinate coord, double width, double height, GeoUnit unit)
List<GeoRadiusResponse>	geosearch(String key, GeoCoordinate coord, double radius, GeoUnit unit)
List<GeoRadiusResponse>	geosearch(String key, GeoSearchParam params)
List<GeoRadiusResponse>	geosearch(String key, String member, double width, double height, GeoUnit unit)
List<GeoRadiusResponse>	geosearch(String key, String member, double radius, GeoUnit unit)
long	geosearchStore(byte[] dest, byte[] src, byte[] member, double width, double height, GeoUnit unit)
long	geosearchStore(byte[] dest, byte[] src, byte[] member, double radius, GeoUnit unit)
long	geosearchStore(byte[] dest, byte[] src, GeoCoordinate coord, double width, double height, GeoUnit unit)
long	geosearchStore(byte[] dest, byte[] src, GeoCoordinate coord, double radius, GeoUnit unit)
long	geosearchStore(byte[] dest, byte[] src, GeoSearchParam params)
long	geosearchStore(String dest, String src, GeoCoordinate coord, double width, double height, GeoUnit unit)
long	geosearchStore(String dest, String src, GeoCoordinate coord, double radius, GeoUnit unit)
long	geosearchStore(String dest, String src, GeoSearchParam params)
long	geosearchStore(String dest, String src, String member, double width, double height, GeoUnit unit)
long	geosearchStore(String dest, String src, String member, double radius, GeoUnit unit)
long	geosearchStoreStoreDist(byte[] dest, byte[] src, GeoSearchParam params)
long	geosearchStoreStoreDist(String dest, String src, GeoSearchParam params)
byte[]	get(byte[] key)
String	get(String key)
boolean	getbit(byte[] key, long offset)
boolean	getbit(String key, long offset)
byte[]	getDel(byte[] key)
String	getDel(String key)
byte[]	getEx(byte[] key, GetExParams params)
String	getEx(String key, GetExParams params)
byte[]	getrange(byte[] key, long startOffset, long endOffset)
String	getrange(String key, long startOffset, long endOffset)
byte[]	getSet(byte[] key, byte[] value)
String	getSet(String key, String value)
long	hdel(byte[] key, byte[]... field)
long	hdel(String key, String... field)
boolean	hexists(byte[] key, byte[] field)
boolean	hexists(String key, String field)
byte[]	hget(byte[] key, byte[] field)
String	hget(String key, String field)
Map<byte[],byte[]>	hgetAll(byte[] key)
Map<String,String>	hgetAll(String key)
long	hincrBy(byte[] key, byte[] field, long value)
long	hincrBy(String key, String field, long value)
double	hincrByFloat(byte[] key, byte[] field, double value)
double	hincrByFloat(String key, String field, double value)
Set<byte[]>	hkeys(byte[] key)
Set<String>	hkeys(String key)
long	hlen(byte[] key)
long	hlen(String key)
List<byte[]>	hmget(byte[] key, byte[]... fields)
List<String>	hmget(String key, String... fields)
String	hmset(byte[] key, Map<byte[],byte[]> hash)
String	hmset(String key, Map<String,String> hash)
byte[]	hrandfield(byte[] key)
List<byte[]>	hrandfield(byte[] key, long count)
String	hrandfield(String key)
List<String>	hrandfield(String key, long count)
Map<byte[],byte[]>	hrandfieldWithValues(byte[] key, long count)
Map<String,String>	hrandfieldWithValues(String key, long count)
ScanResult<Map.Entry<byte[],byte[]>>	hscan(byte[] key, byte[] cursor, ScanParams params)
ScanResult<Map.Entry<String,String>>	hscan(String key, String cursor, ScanParams params)
long	hset(byte[] key, byte[] field, byte[] value)
long	hset(byte[] key, Map<byte[],byte[]> hash)
long	hset(String key, Map<String,String> hash)
long	hset(String key, String field, String value)
long	hsetnx(byte[] key, byte[] field, byte[] value)
long	hsetnx(String key, String field, String value)
long	hstrlen(byte[] key, byte[] field)
long	hstrlen(String key, String field)
List<byte[]>	hvals(byte[] key)
List<String>	hvals(String key)
long	incr(byte[] key)
long	incr(String key)
long	incrBy(byte[] key, long increment)
long	incrBy(String key, long increment)
double	incrByFloat(byte[] key, double increment)
double	incrByFloat(String key, double increment)
List<Long>	jsonArrAppend(String key, Path2 path, Object... objects)
Long	jsonArrAppend(String key, Path path, Object... pojos)
List<Long>	jsonArrAppendWithEscape(String key, Path2 path, Object... objects)
List<Long>	jsonArrIndex(String key, Path2 path, Object scalar)
long	jsonArrIndex(String key, Path path, Object scalar)
List<Long>	jsonArrIndexWithEscape(String key, Path2 path, Object scalar)
List<Long>	jsonArrInsert(String key, Path2 path, int index, Object... objects)
long	jsonArrInsert(String key, Path path, int index, Object... pojos)
List<Long>	jsonArrInsertWithEscape(String key, Path2 path, int index, Object... objects)
Long	jsonArrLen(String key)
Long	jsonArrLen(String key, Path path)
List<Long>	jsonArrLen(String key, Path2 path)
Object	jsonArrPop(String key)
<T> T	jsonArrPop(String key, Class<T> clazz)
<T> T	jsonArrPop(String key, Class<T> clazz, Path path)
<T> T	jsonArrPop(String key, Class<T> clazz, Path path, int index)
Object	jsonArrPop(String key, Path path)
List<Object>	jsonArrPop(String key, Path2 path)
List<Object>	jsonArrPop(String key, Path2 path, int index)
Object	jsonArrPop(String key, Path path, int index)
List<Long>	jsonArrTrim(String key, Path2 path, int start, int stop)
Long	jsonArrTrim(String key, Path path, int start, int stop)
long	jsonClear(String key)
long	jsonClear(String key, Path path)
long	jsonClear(String key, Path2 path)
long	jsonDel(String key)
long	jsonDel(String key, Path path)
long	jsonDel(String key, Path2 path)
Object	jsonGet(String key)
<T> T	jsonGet(String key, Class<T> clazz)
<T> T	jsonGet(String key, Class<T> clazz, Path... paths)
Object	jsonGet(String key, Path... paths)
Object	jsonGet(String key, Path2... paths)
List<org.json.JSONArray>	jsonMGet(Path2 path, String... keys)
<T> List<T>	jsonMGet(Path path, Class<T> clazz, String... keys)
String	jsonSet(String key, Path2 path, Object object)
String	jsonSet(String key, Path2 path, Object pojo, JsonSetParams params)
String	jsonSet(String key, Path path, Object pojo)
String	jsonSet(String key, Path path, Object pojo, JsonSetParams params)
String	jsonSetWithEscape(String key, Path2 path, Object object)
String	jsonSetWithEscape(String key, Path2 path, Object pojo, JsonSetParams params)
long	jsonStrAppend(String key, Object string)
List<Long>	jsonStrAppend(String key, Path2 path, Object string)
long	jsonStrAppend(String key, Path path, Object string)
Long	jsonStrLen(String key)
Long	jsonStrLen(String key, Path path)
List<Long>	jsonStrLen(String key, Path2 path)
String	jsonToggle(String key, Path path)
List<Boolean>	jsonToggle(String key, Path2 path)
Class<?>	jsonType(String key)
Class<?>	jsonType(String key, Path path)
List<Class<?>>	jsonType(String key, Path2 path)
Set<byte[]>	keys(byte[] pattern)
Set<String>	keys(String pattern)
byte[]	lindex(byte[] key, long index)
String	lindex(String key, long index)
long	linsert(byte[] key, ListPosition where, byte[] pivot, byte[] value)
long	linsert(String key, ListPosition where, String pivot, String value)
long	llen(byte[] key)
long	llen(String key)
byte[]	lmove(byte[] srcKey, byte[] dstKey, ListDirection from, ListDirection to)
String	lmove(String srcKey, String dstKey, ListDirection from, ListDirection to)
byte[]	lpop(byte[] key)
List<byte[]>	lpop(byte[] key, int count)
String	lpop(String key)
List<String>	lpop(String key, int count)
Long	lpos(byte[] key, byte[] element)
Long	lpos(byte[] key, byte[] element, LPosParams params)
List<Long>	lpos(byte[] key, byte[] element, LPosParams params, long 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(byte[] key, byte[]... args)
long	lpush(String key, String... string)
long	lpushx(byte[] key, byte[]... arg)
long	lpushx(String key, String... string)
List<byte[]>	lrange(byte[] key, long start, long stop)
List<String>	lrange(String key, long start, long stop)
long	lrem(byte[] key, long count, byte[] value)
long	lrem(String key, long count, String value)
String	lset(byte[] key, long index, byte[] value)
String	lset(String key, long index, String value)
String	ltrim(byte[] key, long start, long stop)
String	ltrim(String key, long start, long stop)
Long	memoryUsage(byte[] key)
Long	memoryUsage(byte[] key, int samples)
Long	memoryUsage(String key)
Long	memoryUsage(String key, int samples)
List<byte[]>	mget(byte[]... keys)
List<String>	mget(String... keys)
String	migrate(String host, int port, byte[] key, int timeout)
String	migrate(String host, int port, int timeout, MigrateParams params, byte[]... keys)
String	migrate(String host, int port, int timeout, MigrateParams params, String... keys)
String	migrate(String host, int port, String key, int timeout)
String	mset(byte[]... keysvalues)
String	mset(String... keysvalues)
long	msetnx(byte[]... keysvalues)
long	msetnx(String... keysvalues)
byte[]	objectEncoding(byte[] key)
String	objectEncoding(String key)
Long	objectFreq(byte[] key)
Long	objectFreq(String key)
Long	objectIdletime(byte[] key)
Long	objectIdletime(String key)
Long	objectRefcount(byte[] key)
Long	objectRefcount(String key)
long	persist(byte[] key)
long	persist(String key)
long	pexpire(byte[] key, long milliseconds)
long	pexpire(String key, long milliseconds)
long	pexpireAt(byte[] key, long millisecondsTimestamp)
long	pexpireAt(String key, long millisecondsTimestamp)
long	pfadd(byte[] key, byte[]... elements)
long	pfadd(String key, String... elements)
long	pfcount(byte[]... keys)
long	pfcount(byte[] key)
long	pfcount(String... keys)
long	pfcount(String key)
String	pfmerge(byte[] destkey, byte[]... sourcekeys)
String	pfmerge(String destkey, String... sourcekeys)
String	psetex(byte[] key, long milliseconds, byte[] value)
String	psetex(String key, long milliseconds, String value)
void	psubscribe(BinaryJedisPubSub jedisPubSub, byte[]... patterns)
void	psubscribe(JedisPubSub jedisPubSub, String... patterns)
long	pttl(byte[] key)
long	pttl(String key)
long	publish(byte[] channel, byte[] message)
long	publish(String channel, String message)
byte[]	randomBinaryKey()
String	randomKey()
String	rename(byte[] oldkey, byte[] newkey)
String	rename(String oldkey, String newkey)
long	renamenx(byte[] oldkey, byte[] newkey)
long	renamenx(String oldkey, String newkey)
String	restore(byte[] key, long ttl, byte[] serializedValue)
String	restore(byte[] key, long ttl, byte[] serializedValue, RestoreParams params)
String	restore(String key, long ttl, byte[] serializedValue)
String	restore(String key, long ttl, byte[] serializedValue, RestoreParams params)
byte[]	rpop(byte[] key)
List<byte[]>	rpop(byte[] key, int count)
String	rpop(String key)
List<String>	rpop(String key, int count)
byte[]	rpoplpush(byte[] srckey, byte[] dstkey)
String	rpoplpush(String srckey, String dstkey)
long	rpush(byte[] key, byte[]... args)
long	rpush(String key, String... string)
long	rpushx(byte[] key, byte[]... arg)
long	rpushx(String key, String... string)
long	sadd(byte[] key, byte[]... member)
long	sadd(String key, String... member)
ScanResult<byte[]>	scan(byte[] cursor)
ScanResult<byte[]>	scan(byte[] cursor, ScanParams params)
ScanResult<byte[]>	scan(byte[] cursor, ScanParams params, byte[] type)
ScanResult<String>	scan(String cursor)
ScanResult<String>	scan(String cursor, ScanParams params)
ScanResult<String>	scan(String cursor, ScanParams params, String type)
long	scard(byte[] key)
long	scard(String key)
List<Boolean>	scriptExists(byte[] sampleKey, byte[]... sha1s)
Boolean	scriptExists(byte[] sha1, byte[] sampleKey)
List<Boolean>	scriptExists(String sampleKey, String... sha1s)
Boolean	scriptExists(String sha1, String sampleKey)
String	scriptFlush(byte[] sampleKey)
String	scriptFlush(byte[] sampleKey, FlushMode flushMode)
String	scriptFlush(String sampleKey)
String	scriptFlush(String sampleKey, FlushMode flushMode)
String	scriptKill(byte[] sampleKey)
String	scriptKill(String sampleKey)
byte[]	scriptLoad(byte[] script, byte[] sampleKey)
String	scriptLoad(String script, String sampleKey)
Set<byte[]>	sdiff(byte[]... keys)
Set<String>	sdiff(String... keys)
long	sdiffstore(byte[] dstkey, byte[]... keys)
long	sdiffstore(String dstkey, String... keys)
Object	sendBlockingCommand(byte[] sampleKey, ProtocolCommand cmd, byte[]... args)
Object	sendBlockingCommand(ProtocolCommand cmd, byte[]... args)
Object	sendBlockingCommand(ProtocolCommand cmd, String... args)
Object	sendBlockingCommand(String sampleKey, ProtocolCommand cmd, String... args)
Object	sendCommand(byte[] sampleKey, ProtocolCommand cmd, byte[]... args)
Object	sendCommand(ProtocolCommand cmd)
Object	sendCommand(ProtocolCommand cmd, byte[]... args)
Object	sendCommand(ProtocolCommand cmd, String... args)
Object	sendCommand(String sampleKey, ProtocolCommand cmd, String... args)
String	set(byte[] key, byte[] value)
String	set(byte[] key, byte[] value, SetParams params)
String	set(String key, String value)
String	set(String key, String value, SetParams params)
boolean	setbit(byte[] key, long offset, boolean value)
boolean	setbit(String key, long offset, boolean value)
String	setex(byte[] key, long seconds, byte[] value)
String	setex(String key, long seconds, String value)
long	setnx(byte[] key, byte[] value)
long	setnx(String key, String value)
long	setrange(byte[] key, long offset, byte[] value)
long	setrange(String key, long offset, String value)
Set<byte[]>	sinter(byte[]... keys)
Set<String>	sinter(String... keys)
long	sintercard(byte[]... keys) This command works exactly like SINTER but instead of returning the result set, it returns just the cardinality of the result.
long	sintercard(int limit, byte[]... keys) This command works exactly like SINTER but instead of returning the result set, it returns just the cardinality of the result.
long	sintercard(int limit, String... keys) This command works exactly like SINTER but instead of returning the result set, it returns just the cardinality of the result.
long	sintercard(String... keys) This command works exactly like SINTER but instead of returning the result set, it returns just the cardinality of the result.
long	sinterstore(byte[] dstkey, byte[]... keys)
long	sinterstore(String dstkey, String... keys)
boolean	sismember(byte[] key, byte[] member)
boolean	sismember(String key, String member)
Set<byte[]>	smembers(byte[] key)
Set<String>	smembers(String key)
List<Boolean>	smismember(byte[] key, byte[]... members)
List<Boolean>	smismember(String key, String... members)
long	smove(byte[] srckey, byte[] dstkey, byte[] member)
long	smove(String srckey, String dstkey, String member)
List<byte[]>	sort(byte[] key)
long	sort(byte[] key, byte[] dstkey)
List<byte[]>	sort(byte[] key, SortingParams sortingParams)
long	sort(byte[] key, SortingParams sortingParams, byte[] dstkey)
List<String>	sort(String key)
List<String>	sort(String key, SortingParams sortingParams)
long	sort(String key, SortingParams sortingParams, String dstkey)
long	sort(String key, String dstkey)
List<byte[]>	sortReadonly(byte[] key, SortingParams sortingParams)
List<String>	sortReadonly(String key, SortingParams sortingParams) Read-only variant of the SORT command.
byte[]	spop(byte[] key)
Set<byte[]>	spop(byte[] key, long count)
String	spop(String key)
Set<String>	spop(String key, long count)
byte[]	srandmember(byte[] key)
List<byte[]>	srandmember(byte[] key, int count)
String	srandmember(String key)
List<String>	srandmember(String key, int count)
long	srem(byte[] key, byte[]... member)
long	srem(String key, String... member)
ScanResult<byte[]>	sscan(byte[] key, byte[] cursor, ScanParams params)
ScanResult<String>	sscan(String key, String cursor, ScanParams params)
LCSMatchResult	strAlgoLCSKeys(byte[] keyA, byte[] keyB, StrAlgoLCSParams params)
LCSMatchResult	strAlgoLCSKeys(String keyA, String keyB, StrAlgoLCSParams params)
LCSMatchResult	strAlgoLCSStrings(byte[] strA, byte[] strB, StrAlgoLCSParams params)
LCSMatchResult	strAlgoLCSStrings(String strA, String strB, StrAlgoLCSParams params)
long	strlen(byte[] key)
long	strlen(String key)
void	subscribe(BinaryJedisPubSub jedisPubSub, byte[]... channels)
void	subscribe(JedisPubSub jedisPubSub, String... channels)
byte[]	substr(byte[] key, int start, int end)
String	substr(String key, int start, int end)
Set<byte[]>	sunion(byte[]... keys)
Set<String>	sunion(String... keys)
long	sunionstore(byte[] dstkey, byte[]... keys)
long	sunionstore(String dstkey, String... keys)
long	touch(byte[]... keys)
long	touch(byte[] key)
long	touch(String... keys)
long	touch(String key)
long	ttl(byte[] key)
long	ttl(String key)
String	type(byte[] key)
String	type(String key)
long	unlink(byte[]... keys)
long	unlink(byte[] key)
long	unlink(String... keys)
long	unlink(String key)
long	waitReplicas(byte[] sampleKey, int replicas, long timeout)
long	waitReplicas(String sampleKey, int replicas, long timeout)
long	xack(byte[] key, byte[] group, byte[]... ids)
long	xack(String key, String group, StreamEntryID... ids) XACK key group ID [ID ...]
byte[]	xadd(byte[] key, XAddParams params, Map<byte[],byte[]> hash)
StreamEntryID	xadd(String key, StreamEntryID id, Map<String,String> hash) XADD key ID field string [field string ...]
StreamEntryID	xadd(String key, XAddParams params, Map<String,String> hash)
List<Object>	xautoclaim(byte[] key, byte[] groupName, byte[] consumerName, long minIdleTime, byte[] start, XAutoClaimParams params)
Map.Entry<StreamEntryID,List<StreamEntry>>	xautoclaim(String key, String group, String consumerName, long minIdleTime, StreamEntryID start, XAutoClaimParams params) XAUTOCLAIM key group consumer min-idle-time start [COUNT count]
List<Object>	xautoclaimJustId(byte[] key, byte[] groupName, byte[] consumerName, long minIdleTime, byte[] start, XAutoClaimParams params)
Map.Entry<StreamEntryID,List<StreamEntryID>>	xautoclaimJustId(String key, String group, String consumerName, long minIdleTime, StreamEntryID start, XAutoClaimParams params) XAUTOCLAIM key group consumer min-idle-time start [COUNT count] JUSTID
List<byte[]>	xclaim(byte[] key, byte[] group, byte[] consumername, long minIdleTime, XClaimParams params, byte[]... ids)
List<StreamEntry>	xclaim(String key, String group, String consumername, long minIdleTime, XClaimParams params, StreamEntryID... ids) XCLAIM ...
List<byte[]>	xclaimJustId(byte[] key, byte[] group, byte[] consumername, long minIdleTime, XClaimParams params, byte[]... ids)
List<StreamEntryID>	xclaimJustId(String key, String group, String consumername, long minIdleTime, XClaimParams params, StreamEntryID... ids) XCLAIM ...
long	xdel(byte[] key, byte[]... ids)
long	xdel(String key, StreamEntryID... ids) XDEL key ID [ID ...]
String	xgroupCreate(byte[] key, byte[] groupname, byte[] id, boolean makeStream)
String	xgroupCreate(String key, String groupname, StreamEntryID id, boolean makeStream) XGROUP CREATE
long	xgroupDelConsumer(byte[] key, byte[] groupname, byte[] consumerName)
long	xgroupDelConsumer(String key, String groupname, String consumername) XGROUP DELCONSUMER
long	xgroupDestroy(byte[] key, byte[] groupname)
long	xgroupDestroy(String key, String groupname) XGROUP DESTROY
String	xgroupSetID(byte[] key, byte[] groupname, byte[] id)
String	xgroupSetID(String key, String groupname, StreamEntryID id) XGROUP SETID
List<Object>	xinfoConsumers(byte[] key, byte[] group)
List<StreamConsumersInfo>	xinfoConsumers(String key, String group) Introspection command used in order to retrieve different information about consumers in the group
List<Object>	xinfoGroup(byte[] key) Deprecated.
List<StreamGroupInfo>	xinfoGroup(String key) Deprecated.
List<Object>	xinfoGroups(byte[] key)
List<StreamGroupInfo>	xinfoGroups(String key) Introspection command used in order to retrieve different information about groups in the stream
Object	xinfoStream(byte[] key)
StreamInfo	xinfoStream(String key) Introspection command used in order to retrieve different information about the stream
Object	xinfoStreamFull(byte[] key) Introspection command used in order to retrieve all information about the stream
Object	xinfoStreamFull(byte[] key, int count) Introspection command used in order to retrieve all information about the stream
StreamFullInfo	xinfoStreamFull(String key) Introspection command used in order to retrieve all information about the stream
StreamFullInfo	xinfoStreamFull(String key, int count) Introspection command used in order to retrieve all information about the stream
long	xlen(byte[] key)
long	xlen(String key) XLEN key
Object	xpending(byte[] key, byte[] groupname)
List<Object>	xpending(byte[] key, byte[] groupname, byte[] start, byte[] end, int count, byte[] consumername)
List<Object>	xpending(byte[] key, byte[] groupname, XPendingParams params)
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<byte[]>	xrange(byte[] key, byte[] start, byte[] end)
List<byte[]>	xrange(byte[] key, byte[] start, byte[] end, int count)
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>	xrange(String key, String start, String end)
List<StreamEntry>	xrange(String key, String start, String end, int count)
List<byte[]>	xread(XReadParams xReadParams, Map.Entry<byte[],byte[]>... streams)
List<Map.Entry<String,List<StreamEntry>>>	xread(XReadParams xReadParams, Map<String,StreamEntryID> streams) XREAD [COUNT count] [BLOCK milliseconds] STREAMS key [key ...] ID [ID ...]
List<byte[]>	xreadGroup(byte[] groupname, byte[] consumer, XReadGroupParams xReadGroupParams, Map.Entry<byte[],byte[]>... streams)
List<Map.Entry<String,List<StreamEntry>>>	xreadGroup(String groupname, String consumer, XReadGroupParams xReadGroupParams, Map<String,StreamEntryID> streams) XREAD [COUNT count] [BLOCK milliseconds] STREAMS key [key ...] ID [ID ...]
List<byte[]>	xrevrange(byte[] key, byte[] end, byte[] start)
List<byte[]>	xrevrange(byte[] key, byte[] end, byte[] start, int 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
List<StreamEntry>	xrevrange(String key, String end, String start)
List<StreamEntry>	xrevrange(String key, String end, String start, int count)
long	xtrim(byte[] key, long maxLen, boolean approximateLength)
long	xtrim(byte[] key, XTrimParams params)
long	xtrim(String key, long maxLen, boolean approximate) XTRIM key MAXLEN [~] count
long	xtrim(String key, XTrimParams params) XTRIM key MAXLEN|MINID [=|~] threshold [LIMIT count]
long	zadd(byte[] key, double score, byte[] member)
long	zadd(byte[] key, double score, byte[] member, ZAddParams params)
long	zadd(byte[] key, Map<byte[],Double> scoreMembers)
long	zadd(byte[] key, Map<byte[],Double> scoreMembers, ZAddParams params)
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(byte[] key, double score, byte[] member, ZAddParams params)
Double	zaddIncr(String key, double score, String member, ZAddParams params)
long	zcard(byte[] key)
long	zcard(String key)
long	zcount(byte[] key, byte[] min, byte[] max)
long	zcount(byte[] key, double min, double max)
long	zcount(String key, double min, double max)
long	zcount(String key, String min, String max)
Set<byte[]>	zdiff(byte[]... keys)
Set<String>	zdiff(String... keys)
long	zdiffStore(byte[] dstkey, byte[]... keys)
long	zdiffStore(String dstkey, String... keys)
Set<Tuple>	zdiffWithScores(byte[]... keys)
Set<Tuple>	zdiffWithScores(String... keys)
double	zincrby(byte[] key, double increment, byte[] member)
Double	zincrby(byte[] key, double increment, byte[] member, ZIncrByParams params)
double	zincrby(String key, double increment, String member)
Double	zincrby(String key, double increment, String member, ZIncrByParams params)
Set<byte[]>	zinter(ZParams params, byte[]... keys)
Set<String>	zinter(ZParams params, String... keys)
long	zinterstore(byte[] dstkey, byte[]... sets)
long	zinterstore(byte[] dstkey, ZParams params, byte[]... sets)
long	zinterstore(String dstkey, String... sets)
long	zinterstore(String dstkey, ZParams params, String... sets)
Set<Tuple>	zinterWithScores(ZParams params, byte[]... keys)
Set<Tuple>	zinterWithScores(ZParams params, String... keys)
long	zlexcount(byte[] key, byte[] min, byte[] max)
long	zlexcount(String key, String min, String max)
List<Double>	zmscore(byte[] key, byte[]... members)
List<Double>	zmscore(String key, String... members)
Tuple	zpopmax(byte[] key)
List<Tuple>	zpopmax(byte[] key, int count)
Tuple	zpopmax(String key)
List<Tuple>	zpopmax(String key, int count)
Tuple	zpopmin(byte[] key)
List<Tuple>	zpopmin(byte[] key, int count)
Tuple	zpopmin(String key)
List<Tuple>	zpopmin(String key, int count)
byte[]	zrandmember(byte[] key)
List<byte[]>	zrandmember(byte[] key, long count)
String	zrandmember(String key)
List<String>	zrandmember(String key, long count)
List<Tuple>	zrandmemberWithScores(byte[] key, long count)
List<Tuple>	zrandmemberWithScores(String key, long count)
List<byte[]>	zrange(byte[] key, long start, long stop)
List<byte[]>	zrange(byte[] key, ZRangeParams zRangeParams)
List<String>	zrange(String key, long start, long stop)
List<String>	zrange(String key, ZRangeParams zRangeParams)
List<byte[]>	zrangeByLex(byte[] key, byte[] min, byte[] max)
List<byte[]>	zrangeByLex(byte[] key, byte[] min, byte[] max, int offset, int count)
List<String>	zrangeByLex(String key, String min, String max)
List<String>	zrangeByLex(String key, String min, String max, int offset, int count)
List<byte[]>	zrangeByScore(byte[] key, byte[] min, byte[] max)
List<byte[]>	zrangeByScore(byte[] key, byte[] min, byte[] max, int offset, int count)
List<byte[]>	zrangeByScore(byte[] key, double min, double max)
List<byte[]>	zrangeByScore(byte[] key, double min, double max, int offset, int count)
List<String>	zrangeByScore(String key, double min, double max)
List<String>	zrangeByScore(String key, double min, double max, int offset, int count)
List<String>	zrangeByScore(String key, String min, String max)
List<String>	zrangeByScore(String key, String min, String max, int offset, int count)
List<Tuple>	zrangeByScoreWithScores(byte[] key, byte[] min, byte[] max)
List<Tuple>	zrangeByScoreWithScores(byte[] key, byte[] min, byte[] max, int offset, int count)
List<Tuple>	zrangeByScoreWithScores(byte[] key, double min, double max)
List<Tuple>	zrangeByScoreWithScores(byte[] key, double min, double max, int offset, int count)
List<Tuple>	zrangeByScoreWithScores(String key, double min, double max)
List<Tuple>	zrangeByScoreWithScores(String key, double min, double max, int offset, int count)
List<Tuple>	zrangeByScoreWithScores(String key, String min, String max)
List<Tuple>	zrangeByScoreWithScores(String key, String min, String max, int offset, int count)
long	zrangestore(byte[] dest, byte[] src, ZRangeParams zRangeParams)
long	zrangestore(String dest, String src, ZRangeParams zRangeParams)
List<Tuple>	zrangeWithScores(byte[] key, long start, long stop)
List<Tuple>	zrangeWithScores(byte[] key, ZRangeParams zRangeParams)
List<Tuple>	zrangeWithScores(String key, long start, long stop)
List<Tuple>	zrangeWithScores(String key, ZRangeParams zRangeParams)
Long	zrank(byte[] key, byte[] member)
Long	zrank(String key, String member)
long	zrem(byte[] key, byte[]... members)
long	zrem(String key, String... members)
long	zremrangeByLex(byte[] key, byte[] min, byte[] max)
long	zremrangeByLex(String key, String min, String max)
long	zremrangeByRank(byte[] key, long start, long stop)
long	zremrangeByRank(String key, long start, long stop)
long	zremrangeByScore(byte[] key, byte[] min, byte[] max)
long	zremrangeByScore(byte[] key, double min, double max)
long	zremrangeByScore(String key, double min, double max)
long	zremrangeByScore(String key, String min, String max)
List<byte[]>	zrevrange(byte[] key, long start, long stop)
List<String>	zrevrange(String key, long start, long stop)
List<byte[]>	zrevrangeByLex(byte[] key, byte[] max, byte[] min)
List<byte[]>	zrevrangeByLex(byte[] key, byte[] max, byte[] min, int offset, int count)
List<String>	zrevrangeByLex(String key, String max, String min)
List<String>	zrevrangeByLex(String key, String max, String min, int offset, int count)
List<byte[]>	zrevrangeByScore(byte[] key, byte[] max, byte[] min)
List<byte[]>	zrevrangeByScore(byte[] key, byte[] max, byte[] min, int offset, int count)
List<byte[]>	zrevrangeByScore(byte[] key, double max, double min)
List<byte[]>	zrevrangeByScore(byte[] key, double max, double min, int offset, int count)
List<String>	zrevrangeByScore(String key, double max, double min)
List<String>	zrevrangeByScore(String key, double max, double min, int offset, int count)
List<String>	zrevrangeByScore(String key, String max, String min)
List<String>	zrevrangeByScore(String key, String max, String min, int offset, int count)
List<Tuple>	zrevrangeByScoreWithScores(byte[] key, byte[] max, byte[] min)
List<Tuple>	zrevrangeByScoreWithScores(byte[] key, byte[] max, byte[] min, int offset, int count)
List<Tuple>	zrevrangeByScoreWithScores(byte[] key, double max, double min)
List<Tuple>	zrevrangeByScoreWithScores(byte[] key, double max, double min, int offset, int count)
List<Tuple>	zrevrangeByScoreWithScores(String key, double max, double min)
List<Tuple>	zrevrangeByScoreWithScores(String key, double max, double min, int offset, int count)
List<Tuple>	zrevrangeByScoreWithScores(String key, String max, String min)
List<Tuple>	zrevrangeByScoreWithScores(String key, String max, String min, int offset, int count)
List<Tuple>	zrevrangeWithScores(byte[] key, long start, long stop)
List<Tuple>	zrevrangeWithScores(String key, long start, long stop)
Long	zrevrank(byte[] key, byte[] member)
Long	zrevrank(String key, String member)
ScanResult<Tuple>	zscan(byte[] key, byte[] cursor, ScanParams params)
ScanResult<Tuple>	zscan(String key, String cursor, ScanParams params)
Double	zscore(byte[] key, byte[] member)
Double	zscore(String key, String member)
Set<byte[]>	zunion(ZParams params, byte[]... keys)
Set<String>	zunion(ZParams params, String... keys)
long	zunionstore(byte[] dstkey, byte[]... sets)
long	zunionstore(byte[] dstkey, ZParams params, byte[]... sets)
long	zunionstore(String dstkey, String... sets)
long	zunionstore(String dstkey, ZParams params, String... sets)
Set<Tuple>	zunionWithScores(ZParams params, byte[]... keys)
Set<Tuple>	zunionWithScores(ZParams params, String... keys)

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.HashCommands

hscan

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

sscan

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

zscan

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

xadd

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

hscan

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

sscan

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

zscan

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

xadd

Methods inherited from interface redis.clients.jedis.search.RediSearchCommands

ftAlter

Methods inherited from interface redis.clients.jedis.json.RedisJsonCommands

jsonMGet, jsonMGet, jsonSet, jsonSet, jsonSetLegacy, jsonSetLegacy, jsonSetWithEscape, jsonSetWithEscape

Field Detail

provider

protected final ConnectionProvider provider

executor

protected final CommandExecutor executor

Constructor Detail

UnifiedJedis

public UnifiedJedis()

UnifiedJedis

public UnifiedJedis(HostAndPort hostAndPort)

UnifiedJedis

public UnifiedJedis(String url)

UnifiedJedis

public UnifiedJedis(URI uri)

UnifiedJedis

public UnifiedJedis(URI uri,
                    JedisClientConfig config)

UnifiedJedis

public UnifiedJedis(HostAndPort hostAndPort,
                    JedisClientConfig clientConfig)

UnifiedJedis

public UnifiedJedis(ConnectionProvider provider)

UnifiedJedis

public UnifiedJedis(JedisSocketFactory socketFactory)

UnifiedJedis

public UnifiedJedis(Connection connection)

UnifiedJedis

public UnifiedJedis(Set<HostAndPort> jedisClusterNodes,
                    JedisClientConfig clientConfig,
                    int maxAttempts)

UnifiedJedis

public UnifiedJedis(Set<HostAndPort> jedisClusterNodes,
                    JedisClientConfig clientConfig,
                    int maxAttempts,
                    Duration maxTotalRetriesDuration)

UnifiedJedis

public UnifiedJedis(Set<HostAndPort> jedisClusterNodes,
                    JedisClientConfig clientConfig,
                    org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig,
                    int maxAttempts,
                    Duration maxTotalRetriesDuration)

UnifiedJedis

public UnifiedJedis(ClusterConnectionProvider provider,
                    int maxAttempts,
                    Duration maxTotalRetriesDuration)

UnifiedJedis

public UnifiedJedis(ShardedConnectionProvider provider)

UnifiedJedis

public UnifiedJedis(ShardedConnectionProvider provider,
                    Pattern tagPattern)

UnifiedJedis

public UnifiedJedis(ConnectionProvider provider,
                    int maxAttempts,
                    Duration maxTotalRetriesDuration)

Method Detail

close

public void close()

Specified by:

close in interface AutoCloseable

executeCommand

public final <T> T executeCommand(CommandObject<T> commandObject)

exists

public boolean exists(String key)

Specified by:

exists in interface KeyCommands

exists

public long exists(String... keys)

Specified by:

exists in interface KeyCommands

persist

public long persist(String key)

Specified by:

persist in interface KeyCommands

type

public String type(String key)

Specified by:

type in interface KeyCommands

exists

public boolean exists(byte[] key)

Specified by:

exists in interface KeyBinaryCommands

exists

public long exists(byte[]... keys)

Specified by:

exists in interface KeyBinaryCommands

persist

public long persist(byte[] key)

Specified by:

persist in interface KeyBinaryCommands

type

public String type(byte[] key)

Specified by:

type in interface KeyBinaryCommands

dump

public byte[] dump(String key)

Specified by:

dump in interface KeyCommands

restore

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

Specified by:

restore in interface KeyCommands

restore

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

Specified by:

restore in interface KeyCommands

dump

public byte[] dump(byte[] key)

Specified by:

dump in interface KeyBinaryCommands

restore

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

Specified by:

restore in interface KeyBinaryCommands

restore

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

Specified by:

restore in interface KeyBinaryCommands

expire

public long expire(String key,
                   long seconds)

Specified by:

expire in interface KeyCommands

pexpire

public long pexpire(String key,
                    long milliseconds)

Specified by:

pexpire in interface KeyCommands

expireAt

public long expireAt(String key,
                     long unixTime)

Specified by:

expireAt in interface KeyCommands

pexpireAt

public long pexpireAt(String key,
                      long millisecondsTimestamp)

Specified by:

pexpireAt in interface KeyCommands

expire

public long expire(byte[] key,
                   long seconds)

Specified by:

expire in interface KeyBinaryCommands

pexpire

public long pexpire(byte[] key,
                    long milliseconds)

Specified by:

pexpire in interface KeyBinaryCommands

expireAt

public long expireAt(byte[] key,
                     long unixTime)

Specified by:

expireAt in interface KeyBinaryCommands

pexpireAt

public long pexpireAt(byte[] key,
                      long millisecondsTimestamp)

Specified by:

pexpireAt in interface KeyBinaryCommands

ttl

public long ttl(String key)

Specified by:

ttl in interface KeyCommands

pttl

public long pttl(String key)

Specified by:

pttl in interface KeyCommands

touch

public long touch(String key)

Specified by:

touch in interface KeyCommands

touch

public long touch(String... keys)

Specified by:

touch in interface KeyCommands

ttl

public long ttl(byte[] key)

Specified by:

ttl in interface KeyBinaryCommands

pttl

public long pttl(byte[] key)

Specified by:

pttl in interface KeyBinaryCommands

touch

public long touch(byte[] key)

Specified by:

touch in interface KeyBinaryCommands

touch

public long touch(byte[]... keys)

Specified by:

touch in interface KeyBinaryCommands

sort

public List<String> sort(String key)

Specified by:

sort in interface KeyCommands

sort

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

Specified by:

sort in interface KeyCommands

sort

public long sort(String key,
                 String dstkey)

Specified by:

sort in interface KeyCommands

sort

public long sort(String key,
                 SortingParams sortingParams,
                 String dstkey)

Specified by:

sort in interface KeyCommands

sortReadonly

public List<String> sortReadonly(String key,
                                 SortingParams sortingParams)

Description copied from interface: KeyCommands

Read-only variant of the SORT command. It is exactly like the original SORT but refuses the STORE option and can safely be used in read-only replicas.

Specified by:

sortReadonly in interface KeyCommands

Parameters:

key - the key to sort

sortingParams - SortingParams

Returns:

list of sorted elements.

sort

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

Specified by:

sort in interface KeyBinaryCommands

sort

public List<byte[]> sort(byte[] key,
                         SortingParams sortingParams)

Specified by:

sort in interface KeyBinaryCommands

sort

public long sort(byte[] key,
                 byte[] dstkey)

Specified by:

sort in interface KeyBinaryCommands

sortReadonly

public List<byte[]> sortReadonly(byte[] key,
                                 SortingParams sortingParams)

Specified by:

sortReadonly in interface KeyBinaryCommands

sort

public long sort(byte[] key,
                 SortingParams sortingParams,
                 byte[] dstkey)

Specified by:

sort in interface KeyBinaryCommands

del

public long del(String key)

Specified by:

del in interface KeyCommands

del

public long del(String... keys)

Specified by:

del in interface KeyCommands

unlink

public long unlink(String key)

Specified by:

unlink in interface KeyCommands

unlink

public long unlink(String... keys)

Specified by:

unlink in interface KeyCommands

del

public long del(byte[] key)

Specified by:

del in interface KeyBinaryCommands

del

public long del(byte[]... keys)

Specified by:

del in interface KeyBinaryCommands

unlink

public long unlink(byte[] key)

Specified by:

unlink in interface KeyBinaryCommands

unlink

public long unlink(byte[]... keys)

Specified by:

unlink in interface KeyBinaryCommands

memoryUsage

public Long memoryUsage(String key)

Specified by:

memoryUsage in interface KeyCommands

memoryUsage

public Long memoryUsage(String key,
                        int samples)

Specified by:

memoryUsage in interface KeyCommands

memoryUsage

public Long memoryUsage(byte[] key)

Specified by:

memoryUsage in interface KeyBinaryCommands

memoryUsage

public Long memoryUsage(byte[] key,
                        int samples)

Specified by:

memoryUsage in interface KeyBinaryCommands

copy

public boolean copy(String srcKey,
                    String dstKey,
                    boolean replace)

Specified by:

copy in interface KeyCommands

rename

public String rename(String oldkey,
                     String newkey)

Specified by:

rename in interface KeyCommands

renamenx

public long renamenx(String oldkey,
                     String newkey)

Specified by:

renamenx in interface KeyCommands

copy

public boolean copy(byte[] srcKey,
                    byte[] dstKey,
                    boolean replace)

Specified by:

copy in interface KeyBinaryCommands

rename

public String rename(byte[] oldkey,
                     byte[] newkey)

Specified by:

rename in interface KeyBinaryCommands

renamenx

public long renamenx(byte[] oldkey,
                     byte[] newkey)

Specified by:

renamenx in interface KeyBinaryCommands

dbSize

public long dbSize()

keys

public Set<String> keys(String pattern)

Specified by:

keys in interface KeyCommands

scan

public ScanResult<String> scan(String cursor)

Specified by:

scan in interface KeyCommands

scan

public ScanResult<String> scan(String cursor,
                               ScanParams params)

Specified by:

scan in interface KeyCommands

scan

public ScanResult<String> scan(String cursor,
                               ScanParams params,
                               String type)

Specified by:

scan in interface KeyCommands

keys

public Set<byte[]> keys(byte[] pattern)

Specified by:

keys in interface KeyBinaryCommands

scan

public ScanResult<byte[]> scan(byte[] cursor)

Specified by:

scan in interface KeyBinaryCommands

scan

public ScanResult<byte[]> scan(byte[] cursor,
                               ScanParams params)

Specified by:

scan in interface KeyBinaryCommands

scan

public ScanResult<byte[]> scan(byte[] cursor,
                               ScanParams params,
                               byte[] type)

Specified by:

scan in interface KeyBinaryCommands

randomKey

public String randomKey()

Specified by:

randomKey in interface KeyCommands

randomBinaryKey

public byte[] randomBinaryKey()

Specified by:

randomBinaryKey in interface KeyBinaryCommands

set

public String set(String key,
                  String value)

Specified by:

set in interface StringCommands

set

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

Specified by:

set in interface StringCommands

get

public String get(String key)

Specified by:

get in interface StringCommands

getDel

public String getDel(String key)

Specified by:

getDel in interface StringCommands

getEx

public String getEx(String key,
                    GetExParams params)

Specified by:

getEx in interface StringCommands

set

public String set(byte[] key,
                  byte[] value)

Specified by:

set in interface StringBinaryCommands

set

public String set(byte[] key,
                  byte[] value,
                  SetParams params)

Specified by:

set in interface StringBinaryCommands

get

public byte[] get(byte[] key)

Specified by:

get in interface StringBinaryCommands

getDel

public byte[] getDel(byte[] key)

Specified by:

getDel in interface StringBinaryCommands

getEx

public byte[] getEx(byte[] key,
                    GetExParams params)

Specified by:

getEx in interface StringBinaryCommands

setbit

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

Specified by:

setbit in interface StringCommands

getbit

public boolean getbit(String key,
                      long offset)

Specified by:

getbit in interface StringCommands

setrange

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

Specified by:

setrange in interface StringCommands

getrange

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

Specified by:

getrange in interface StringCommands

setbit

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

Specified by:

setbit in interface StringBinaryCommands

getbit

public boolean getbit(byte[] key,
                      long offset)

Specified by:

getbit in interface StringBinaryCommands

setrange

public long setrange(byte[] key,
                     long offset,
                     byte[] value)

Specified by:

setrange in interface StringBinaryCommands

getrange

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

Specified by:

getrange in interface StringBinaryCommands

getSet

public String getSet(String key,
                     String value)

Specified by:

getSet in interface StringCommands

setnx

public long setnx(String key,
                  String value)

Specified by:

setnx in interface StringCommands

setex

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

Specified by:

setex in interface StringCommands

psetex

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

Specified by:

psetex in interface StringCommands

getSet

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

Specified by:

getSet in interface StringBinaryCommands

setnx

public long setnx(byte[] key,
                  byte[] value)

Specified by:

setnx in interface StringBinaryCommands

setex

public String setex(byte[] key,
                    long seconds,
                    byte[] value)

Specified by:

setex in interface StringBinaryCommands

psetex

public String psetex(byte[] key,
                     long milliseconds,
                     byte[] value)

Specified by:

psetex in interface StringBinaryCommands

incr

public long incr(String key)

Specified by:

incr in interface StringCommands

incrBy

public long incrBy(String key,
                   long increment)

Specified by:

incrBy in interface StringCommands

incrByFloat

public double incrByFloat(String key,
                          double increment)

Specified by:

incrByFloat in interface StringCommands

decr

public long decr(String key)

Specified by:

decr in interface StringCommands

decrBy

public long decrBy(String key,
                   long decrement)

Specified by:

decrBy in interface StringCommands

incr

public long incr(byte[] key)

Specified by:

incr in interface StringBinaryCommands

incrBy

public long incrBy(byte[] key,
                   long increment)

Specified by:

incrBy in interface StringBinaryCommands

incrByFloat

public double incrByFloat(byte[] key,
                          double increment)

Specified by:

incrByFloat in interface StringBinaryCommands

decr

public long decr(byte[] key)

Specified by:

decr in interface StringBinaryCommands

decrBy

public long decrBy(byte[] key,
                   long decrement)

Specified by:

decrBy in interface StringBinaryCommands

mget

public List<String> mget(String... keys)

Specified by:

mget in interface StringCommands

mset

public String mset(String... keysvalues)

Specified by:

mset in interface StringCommands

msetnx

public long msetnx(String... keysvalues)

Specified by:

msetnx in interface StringCommands

mget

public List<byte[]> mget(byte[]... keys)

Specified by:

mget in interface StringBinaryCommands

mset

public String mset(byte[]... keysvalues)

Specified by:

mset in interface StringBinaryCommands

msetnx

public long msetnx(byte[]... keysvalues)

Specified by:

msetnx in interface StringBinaryCommands

append

public long append(String key,
                   String value)

Specified by:

append in interface StringCommands

substr

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

Specified by:

substr in interface StringCommands

strlen

public long strlen(String key)

Specified by:

strlen in interface StringCommands

append

public long append(byte[] key,
                   byte[] value)

Specified by:

append in interface StringBinaryCommands

substr

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

Specified by:

substr in interface StringBinaryCommands

strlen

public long strlen(byte[] key)

Specified by:

strlen in interface StringBinaryCommands

bitcount

public long bitcount(String key)

Specified by:

bitcount in interface StringCommands

bitcount

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

Specified by:

bitcount in interface StringCommands

bitcount

public long bitcount(String key,
                     long start,
                     long end,
                     BitCountOption option)

Specified by:

bitcount in interface StringCommands

bitpos

public long bitpos(String key,
                   boolean value)

Specified by:

bitpos in interface StringCommands

bitpos

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

Specified by:

bitpos in interface StringCommands

bitcount

public long bitcount(byte[] key)

Specified by:

bitcount in interface StringBinaryCommands

bitcount

public long bitcount(byte[] key,
                     long start,
                     long end)

Specified by:

bitcount in interface StringBinaryCommands

bitcount

public long bitcount(byte[] key,
                     long start,
                     long end,
                     BitCountOption option)

Specified by:

bitcount in interface StringBinaryCommands

bitpos

public long bitpos(byte[] key,
                   boolean value)

Specified by:

bitpos in interface StringBinaryCommands

bitpos

public long bitpos(byte[] key,
                   boolean value,
                   BitPosParams params)

Specified by:

bitpos in interface StringBinaryCommands

bitfield

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

Specified by:

bitfield in interface StringCommands

bitfieldReadonly

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

Specified by:

bitfieldReadonly in interface StringCommands

bitfield

public List<Long> bitfield(byte[] key,
                           byte[]... arguments)

Specified by:

bitfield in interface StringBinaryCommands

bitfieldReadonly

public List<Long> bitfieldReadonly(byte[] key,
                                   byte[]... arguments)

Specified by:

bitfieldReadonly in interface StringBinaryCommands

bitop

public long bitop(BitOP op,
                  String destKey,
                  String... srcKeys)

Specified by:

bitop in interface StringCommands

bitop

public long bitop(BitOP op,
                  byte[] destKey,
                  byte[]... srcKeys)

Specified by:

bitop in interface StringBinaryCommands

strAlgoLCSKeys

public LCSMatchResult strAlgoLCSKeys(String keyA,
                                     String keyB,
                                     StrAlgoLCSParams params)

Specified by:

strAlgoLCSKeys in interface StringCommands

strAlgoLCSKeys

public LCSMatchResult strAlgoLCSKeys(byte[] keyA,
                                     byte[] keyB,
                                     StrAlgoLCSParams params)

Specified by:

strAlgoLCSKeys in interface StringBinaryCommands

rpush

public long rpush(String key,
                  String... string)

Specified by:

rpush in interface ListCommands

lpush

public long lpush(String key,
                  String... string)

Specified by:

lpush in interface ListCommands

llen

public long llen(String key)

Specified by:

llen in interface ListCommands

lrange

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

Specified by:

lrange in interface ListCommands

ltrim

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

Specified by:

ltrim in interface ListCommands

lindex

public String lindex(String key,
                     long index)

Specified by:

lindex in interface ListCommands

rpush

public long rpush(byte[] key,
                  byte[]... args)

Specified by:

rpush in interface ListBinaryCommands

lpush

public long lpush(byte[] key,
                  byte[]... args)

Specified by:

lpush in interface ListBinaryCommands

llen

public long llen(byte[] key)

Specified by:

llen in interface ListBinaryCommands

lrange

public List<byte[]> lrange(byte[] key,
                           long start,
                           long stop)

Specified by:

lrange in interface ListBinaryCommands

ltrim

public String ltrim(byte[] key,
                    long start,
                    long stop)

Specified by:

ltrim in interface ListBinaryCommands

lindex

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

Specified by:

lindex in interface ListBinaryCommands

lset

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

Specified by:

lset in interface ListCommands

lrem

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

Specified by:

lrem in interface ListCommands

lpop

public String lpop(String key)

Specified by:

lpop in interface ListCommands

lpop

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

Specified by:

lpop in interface ListCommands

lset

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

Specified by:

lset in interface ListBinaryCommands

lrem

public long lrem(byte[] key,
                 long count,
                 byte[] value)

Specified by:

lrem in interface ListBinaryCommands

lpop

public byte[] lpop(byte[] key)

Specified by:

lpop in interface ListBinaryCommands

lpop

public List<byte[]> lpop(byte[] key,
                         int count)

Specified by:

lpop in interface ListBinaryCommands

lpos

public Long lpos(String key,
                 String element)

Specified by:

lpos in interface ListCommands

lpos

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

Specified by:

lpos in interface ListCommands

lpos

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

Specified by:

lpos in interface ListCommands

lpos

public Long lpos(byte[] key,
                 byte[] element)

Specified by:

lpos in interface ListBinaryCommands

lpos

public Long lpos(byte[] key,
                 byte[] element,
                 LPosParams params)

Specified by:

lpos in interface ListBinaryCommands

lpos

public List<Long> lpos(byte[] key,
                       byte[] element,
                       LPosParams params,
                       long count)

Specified by:

lpos in interface ListBinaryCommands

rpop

public String rpop(String key)

Specified by:

rpop in interface ListCommands

rpop

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

Specified by:

rpop in interface ListCommands

rpop

public byte[] rpop(byte[] key)

Specified by:

rpop in interface ListBinaryCommands

rpop

public List<byte[]> rpop(byte[] key,
                         int count)

Specified by:

rpop in interface ListBinaryCommands

linsert

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

Specified by:

linsert in interface ListCommands

lpushx

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

Specified by:

lpushx in interface ListCommands

rpushx

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

Specified by:

rpushx in interface ListCommands

linsert

public long linsert(byte[] key,
                    ListPosition where,
                    byte[] pivot,
                    byte[] value)

Specified by:

linsert in interface ListBinaryCommands

lpushx

public long lpushx(byte[] key,
                   byte[]... arg)

Specified by:

lpushx in interface ListBinaryCommands

rpushx

public long rpushx(byte[] key,
                   byte[]... arg)

Specified by:

rpushx in interface ListBinaryCommands

blpop

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

Specified by:

blpop in interface ListCommands

blpop

public KeyedListElement blpop(double timeout,
                              String key)

Specified by:

blpop in interface ListCommands

brpop

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

Specified by:

brpop in interface ListCommands

brpop

public KeyedListElement brpop(double timeout,
                              String key)

Specified by:

brpop in interface ListCommands

blpop

public List<String> blpop(int timeout,
                          String... keys)

Specified by:

blpop in interface ListCommands

blpop

public KeyedListElement blpop(double timeout,
                              String... keys)

Specified by:

blpop in interface ListCommands

brpop

public List<String> brpop(int timeout,
                          String... keys)

Specified by:

brpop in interface ListCommands

brpop

public KeyedListElement brpop(double timeout,
                              String... keys)

Specified by:

brpop in interface ListCommands

blpop

public List<byte[]> blpop(int timeout,
                          byte[]... keys)

Specified by:

blpop in interface ListBinaryCommands

blpop

public List<byte[]> blpop(double timeout,
                          byte[]... keys)

Specified by:

blpop in interface ListBinaryCommands

brpop

public List<byte[]> brpop(int timeout,
                          byte[]... keys)

Specified by:

brpop in interface ListBinaryCommands

brpop

public List<byte[]> brpop(double timeout,
                          byte[]... keys)

Specified by:

brpop in interface ListBinaryCommands

rpoplpush

public String rpoplpush(String srckey,
                        String dstkey)

Specified by:

rpoplpush in interface ListCommands

brpoplpush

public String brpoplpush(String source,
                         String destination,
                         int timeout)

Specified by:

brpoplpush in interface ListCommands

rpoplpush

public byte[] rpoplpush(byte[] srckey,
                        byte[] dstkey)

Specified by:

rpoplpush in interface ListBinaryCommands

brpoplpush

public byte[] brpoplpush(byte[] source,
                         byte[] destination,
                         int timeout)

Specified by:

brpoplpush in interface ListBinaryCommands

lmove

public String lmove(String srcKey,
                    String dstKey,
                    ListDirection from,
                    ListDirection to)

Specified by:

lmove in interface ListCommands

blmove

public String blmove(String srcKey,
                     String dstKey,
                     ListDirection from,
                     ListDirection to,
                     double timeout)

Specified by:

blmove in interface ListCommands

lmove

public byte[] lmove(byte[] srcKey,
                    byte[] dstKey,
                    ListDirection from,
                    ListDirection to)

Specified by:

lmove in interface ListBinaryCommands

blmove

public byte[] blmove(byte[] srcKey,
                     byte[] dstKey,
                     ListDirection from,
                     ListDirection to,
                     double timeout)

Specified by:

blmove in interface ListBinaryCommands

hset

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

Specified by:

hset in interface HashCommands

hset

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

Specified by:

hset in interface HashCommands

hget

public String hget(String key,
                   String field)

Specified by:

hget in interface HashCommands

hsetnx

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

Specified by:

hsetnx in interface HashCommands

hmset

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

Specified by:

hmset in interface HashCommands

hmget

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

Specified by:

hmget in interface HashCommands

hset

public long hset(byte[] key,
                 byte[] field,
                 byte[] value)

Specified by:

hset in interface HashBinaryCommands

hset

public long hset(byte[] key,
                 Map<byte[],byte[]> hash)

Specified by:

hset in interface HashBinaryCommands

hget

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

Specified by:

hget in interface HashBinaryCommands

hsetnx

public long hsetnx(byte[] key,
                   byte[] field,
                   byte[] value)

Specified by:

hsetnx in interface HashBinaryCommands

hmset

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

Specified by:

hmset in interface HashBinaryCommands

hmget

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

Specified by:

hmget in interface HashBinaryCommands

hincrBy

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

Specified by:

hincrBy in interface HashCommands

hincrByFloat

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

Specified by:

hincrByFloat in interface HashCommands

hexists

public boolean hexists(String key,
                       String field)

Specified by:

hexists in interface HashCommands

hdel

public long hdel(String key,
                 String... field)

Specified by:

hdel in interface HashCommands

hlen

public long hlen(String key)

Specified by:

hlen in interface HashCommands

hincrBy

public long hincrBy(byte[] key,
                    byte[] field,
                    long value)

Specified by:

hincrBy in interface HashBinaryCommands

hincrByFloat

public double hincrByFloat(byte[] key,
                           byte[] field,
                           double value)

Specified by:

hincrByFloat in interface HashBinaryCommands

hexists

public boolean hexists(byte[] key,
                       byte[] field)

Specified by:

hexists in interface HashBinaryCommands

hdel

public long hdel(byte[] key,
                 byte[]... field)

Specified by:

hdel in interface HashBinaryCommands

hlen

public long hlen(byte[] key)

Specified by:

hlen in interface HashBinaryCommands

hkeys

public Set<String> hkeys(String key)

Specified by:

hkeys in interface HashCommands

hvals

public List<String> hvals(String key)

Specified by:

hvals in interface HashCommands

hgetAll

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

Specified by:

hgetAll in interface HashCommands

hkeys

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

Specified by:

hkeys in interface HashBinaryCommands

hvals

public List<byte[]> hvals(byte[] key)

Specified by:

hvals in interface HashBinaryCommands

hgetAll

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

Specified by:

hgetAll in interface HashBinaryCommands

hrandfield

public String hrandfield(String key)

Specified by:

hrandfield in interface HashCommands

hrandfield

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

Specified by:

hrandfield in interface HashCommands

hrandfieldWithValues

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

Specified by:

hrandfieldWithValues in interface HashCommands

hscan

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

Specified by:

hscan in interface HashCommands

hstrlen

public long hstrlen(String key,
                    String field)

Specified by:

hstrlen in interface HashCommands

hrandfield

public byte[] hrandfield(byte[] key)

Specified by:

hrandfield in interface HashBinaryCommands

hrandfield

public List<byte[]> hrandfield(byte[] key,
                               long count)

Specified by:

hrandfield in interface HashBinaryCommands

hrandfieldWithValues

public Map<byte[],byte[]> hrandfieldWithValues(byte[] key,
                                               long count)

Specified by:

hrandfieldWithValues in interface HashBinaryCommands

hscan

public ScanResult<Map.Entry<byte[],byte[]>> hscan(byte[] key,
                                                  byte[] cursor,
                                                  ScanParams params)

Specified by:

hscan in interface HashBinaryCommands

hstrlen

public long hstrlen(byte[] key,
                    byte[] field)

Specified by:

hstrlen in interface HashBinaryCommands

sadd

public long sadd(String key,
                 String... member)

Specified by:

sadd in interface SetCommands

smembers

public Set<String> smembers(String key)

Specified by:

smembers in interface SetCommands

srem

public long srem(String key,
                 String... member)

Specified by:

srem in interface SetCommands

spop

public String spop(String key)

Specified by:

spop in interface SetCommands

spop

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

Specified by:

spop in interface SetCommands

scard

public long scard(String key)

Specified by:

scard in interface SetCommands

sismember

public boolean sismember(String key,
                         String member)

Specified by:

sismember in interface SetCommands

smismember

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

Specified by:

smismember in interface SetCommands

sadd

public long sadd(byte[] key,
                 byte[]... member)

Specified by:

sadd in interface SetBinaryCommands

smembers

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

Specified by:

smembers in interface SetBinaryCommands

srem

public long srem(byte[] key,
                 byte[]... member)

Specified by:

srem in interface SetBinaryCommands

spop

public byte[] spop(byte[] key)

Specified by:

spop in interface SetBinaryCommands

spop

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

Specified by:

spop in interface SetBinaryCommands

scard

public long scard(byte[] key)

Specified by:

scard in interface SetBinaryCommands

sismember

public boolean sismember(byte[] key,
                         byte[] member)

Specified by:

sismember in interface SetBinaryCommands

smismember

public List<Boolean> smismember(byte[] key,
                                byte[]... members)

Specified by:

smismember in interface SetBinaryCommands

srandmember

public String srandmember(String key)

Specified by:

srandmember in interface SetCommands

srandmember

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

Specified by:

srandmember in interface SetCommands

sscan

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

Specified by:

sscan in interface SetCommands

srandmember

public byte[] srandmember(byte[] key)

Specified by:

srandmember in interface SetBinaryCommands

srandmember

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

Specified by:

srandmember in interface SetBinaryCommands

sscan

public ScanResult<byte[]> sscan(byte[] key,
                                byte[] cursor,
                                ScanParams params)

Specified by:

sscan in interface SetBinaryCommands

sdiff

public Set<String> sdiff(String... keys)

Specified by:

sdiff in interface SetCommands

sdiffstore

public long sdiffstore(String dstkey,
                       String... keys)

Specified by:

sdiffstore in interface SetCommands

sinter

public Set<String> sinter(String... keys)

Specified by:

sinter in interface SetCommands

sinterstore

public long sinterstore(String dstkey,
                        String... keys)

Specified by:

sinterstore in interface SetCommands

sintercard

public long sintercard(String... keys)

Description copied from interface: SetCommands

This command works exactly like SINTER but instead of returning the result set, it returns just the cardinality of the result. LIMIT defaults to 0 and means unlimited

Time complexity O(N*M) worst case where N is the cardinality of the smallest

Specified by:

sintercard in interface SetCommands

Returns:

The cardinality of the set which would result from the intersection of all the given sets

sintercard

public long sintercard(int limit,
                       String... keys)

Description copied from interface: SetCommands

This command works exactly like SINTER but instead of returning the result set, it returns just the cardinality of the result.

Time complexity O(N*M) worst case where N is the cardinality of the smallest

Specified by:

sintercard in interface SetCommands

Parameters:

limit - If the intersection cardinality reaches limit partway through the computation, the algorithm will exit and yield limit as the cardinality.

Returns:

The cardinality of the set which would result from the intersection of all the given sets

sunion

public Set<String> sunion(String... keys)

Specified by:

sunion in interface SetCommands

sunionstore

public long sunionstore(String dstkey,
                        String... keys)

Specified by:

sunionstore in interface SetCommands

smove

public long smove(String srckey,
                  String dstkey,
                  String member)

Specified by:

smove in interface SetCommands

sdiff

public Set<byte[]> sdiff(byte[]... keys)

Specified by:

sdiff in interface SetBinaryCommands

sdiffstore

public long sdiffstore(byte[] dstkey,
                       byte[]... keys)

Specified by:

sdiffstore in interface SetBinaryCommands

sinter

public Set<byte[]> sinter(byte[]... keys)

Specified by:

sinter in interface SetBinaryCommands

sinterstore

public long sinterstore(byte[] dstkey,
                        byte[]... keys)

Specified by:

sinterstore in interface SetBinaryCommands

sintercard

public long sintercard(byte[]... keys)

Description copied from interface: SetBinaryCommands

This command works exactly like SINTER but instead of returning the result set, it returns just the cardinality of the result. LIMIT defaults to 0 and means unlimited

Time complexity O(N*M) worst case where N is the cardinality of the smallest

Specified by:

sintercard in interface SetBinaryCommands

Returns:

The cardinality of the set which would result from the intersection of all the given sets

sintercard

public long sintercard(int limit,
                       byte[]... keys)

Description copied from interface: SetBinaryCommands

This command works exactly like SINTER but instead of returning the result set, it returns just the cardinality of the result.

Time complexity O(N*M) worst case where N is the cardinality of the smallest

Specified by:

sintercard in interface SetBinaryCommands

Parameters:

limit - If the intersection cardinality reaches limit partway through the computation, the algorithm will exit and yield limit as the cardinality.

Returns:

The cardinality of the set which would result from the intersection of all the given sets

sunion

public Set<byte[]> sunion(byte[]... keys)

Specified by:

sunion in interface SetBinaryCommands

sunionstore

public long sunionstore(byte[] dstkey,
                        byte[]... keys)

Specified by:

sunionstore in interface SetBinaryCommands

smove

public long smove(byte[] srckey,
                  byte[] dstkey,
                  byte[] member)

Specified by:

smove in interface SetBinaryCommands

zadd

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

Specified by:

zadd in interface SortedSetCommands

zadd

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

Specified by:

zadd in interface SortedSetCommands

zadd

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

Specified by:

zadd in interface SortedSetCommands

zadd

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

Specified by:

zadd in interface SortedSetCommands

zaddIncr

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

Specified by:

zaddIncr in interface SortedSetCommands

zadd

public long zadd(byte[] key,
                 double score,
                 byte[] member)

Specified by:

zadd in interface SortedSetBinaryCommands

zadd

public long zadd(byte[] key,
                 double score,
                 byte[] member,
                 ZAddParams params)

Specified by:

zadd in interface SortedSetBinaryCommands

zadd

public long zadd(byte[] key,
                 Map<byte[],Double> scoreMembers)

Specified by:

zadd in interface SortedSetBinaryCommands

zadd

public long zadd(byte[] key,
                 Map<byte[],Double> scoreMembers,
                 ZAddParams params)

Specified by:

zadd in interface SortedSetBinaryCommands

zaddIncr

public Double zaddIncr(byte[] key,
                       double score,
                       byte[] member,
                       ZAddParams params)

Specified by:

zaddIncr in interface SortedSetBinaryCommands

zrem

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

Specified by:

zrem in interface SortedSetCommands

zincrby

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

Specified by:

zincrby in interface SortedSetCommands

zincrby

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

Specified by:

zincrby in interface SortedSetCommands

zrank

public Long zrank(String key,
                  String member)

Specified by:

zrank in interface SortedSetCommands

zrevrank

public Long zrevrank(String key,
                     String member)

Specified by:

zrevrank in interface SortedSetCommands

zrem

public long zrem(byte[] key,
                 byte[]... members)

Specified by:

zrem in interface SortedSetBinaryCommands

zincrby

public double zincrby(byte[] key,
                      double increment,
                      byte[] member)

Specified by:

zincrby in interface SortedSetBinaryCommands

zincrby

public Double zincrby(byte[] key,
                      double increment,
                      byte[] member,
                      ZIncrByParams params)

Specified by:

zincrby in interface SortedSetBinaryCommands

zrank

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

Specified by:

zrank in interface SortedSetBinaryCommands

zrevrank

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

Specified by:

zrevrank in interface SortedSetBinaryCommands

zrandmember

public String zrandmember(String key)

Specified by:

zrandmember in interface SortedSetCommands

zrandmember

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

Specified by:

zrandmember in interface SortedSetCommands

zrandmemberWithScores

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

Specified by:

zrandmemberWithScores in interface SortedSetCommands

zcard

public long zcard(String key)

Specified by:

zcard in interface SortedSetCommands

zscore

public Double zscore(String key,
                     String member)

Specified by:

zscore in interface SortedSetCommands

zmscore

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

Specified by:

zmscore in interface SortedSetCommands

zrandmember

public byte[] zrandmember(byte[] key)

Specified by:

zrandmember in interface SortedSetBinaryCommands

zrandmember

public List<byte[]> zrandmember(byte[] key,
                                long count)

Specified by:

zrandmember in interface SortedSetBinaryCommands

zrandmemberWithScores

public List<Tuple> zrandmemberWithScores(byte[] key,
                                         long count)

Specified by:

zrandmemberWithScores in interface SortedSetBinaryCommands

zcard

public long zcard(byte[] key)

Specified by:

zcard in interface SortedSetBinaryCommands

zscore

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

Specified by:

zscore in interface SortedSetBinaryCommands

zmscore

public List<Double> zmscore(byte[] key,
                            byte[]... members)

Specified by:

zmscore in interface SortedSetBinaryCommands

zpopmax

public Tuple zpopmax(String key)

Specified by:

zpopmax in interface SortedSetCommands

zpopmax

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

Specified by:

zpopmax in interface SortedSetCommands

zpopmin

public Tuple zpopmin(String key)

Specified by:

zpopmin in interface SortedSetCommands

zpopmin

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

Specified by:

zpopmin in interface SortedSetCommands

zcount

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

Specified by:

zcount in interface SortedSetCommands

zcount

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

Specified by:

zcount in interface SortedSetCommands

zpopmax

public Tuple zpopmax(byte[] key)

Specified by:

zpopmax in interface SortedSetBinaryCommands

zpopmax

public List<Tuple> zpopmax(byte[] key,
                           int count)

Specified by:

zpopmax in interface SortedSetBinaryCommands

zpopmin

public Tuple zpopmin(byte[] key)

Specified by:

zpopmin in interface SortedSetBinaryCommands

zpopmin

public List<Tuple> zpopmin(byte[] key,
                           int count)

Specified by:

zpopmin in interface SortedSetBinaryCommands

zcount

public long zcount(byte[] key,
                   double min,
                   double max)

Specified by:

zcount in interface SortedSetBinaryCommands

zcount

public long zcount(byte[] key,
                   byte[] min,
                   byte[] max)

Specified by:

zcount in interface SortedSetBinaryCommands

zrange

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

Specified by:

zrange in interface SortedSetCommands

zrevrange

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

Specified by:

zrevrange in interface SortedSetCommands

zrangeWithScores

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

Specified by:

zrangeWithScores in interface SortedSetCommands

zrevrangeWithScores

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

Specified by:

zrevrangeWithScores in interface SortedSetCommands

zrange

public List<String> zrange(String key,
                           ZRangeParams zRangeParams)

Specified by:

zrange in interface SortedSetCommands

zrangeWithScores

public List<Tuple> zrangeWithScores(String key,
                                    ZRangeParams zRangeParams)

Specified by:

zrangeWithScores in interface SortedSetCommands

zrangestore

public long zrangestore(String dest,
                        String src,
                        ZRangeParams zRangeParams)

Specified by:

zrangestore in interface SortedSetCommands

zrangeByScore

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

Specified by:

zrangeByScore in interface SortedSetCommands

zrangeByScore

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

Specified by:

zrangeByScore in interface SortedSetCommands

zrevrangeByScore

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

Specified by:

zrevrangeByScore in interface SortedSetCommands

zrangeByScore

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

Specified by:

zrangeByScore in interface SortedSetCommands

zrevrangeByScore

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

Specified by:

zrevrangeByScore in interface SortedSetCommands

zrangeByScore

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

Specified by:

zrangeByScore in interface SortedSetCommands

zrevrangeByScore

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

Specified by:

zrevrangeByScore in interface SortedSetCommands

zrangeByScoreWithScores

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

Specified by:

zrangeByScoreWithScores in interface SortedSetCommands

zrevrangeByScoreWithScores

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

Specified by:

zrevrangeByScoreWithScores in interface SortedSetCommands

zrangeByScoreWithScores

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

Specified by:

zrangeByScoreWithScores in interface SortedSetCommands

zrevrangeByScore

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

Specified by:

zrevrangeByScore in interface SortedSetCommands

zrangeByScoreWithScores

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

Specified by:

zrangeByScoreWithScores in interface SortedSetCommands

zrevrangeByScoreWithScores

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

Specified by:

zrevrangeByScoreWithScores in interface SortedSetCommands

zrangeByScoreWithScores

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

Specified by:

zrangeByScoreWithScores in interface SortedSetCommands

zrevrangeByScoreWithScores

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

Specified by:

zrevrangeByScoreWithScores in interface SortedSetCommands

zrevrangeByScoreWithScores

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

Specified by:

zrevrangeByScoreWithScores in interface SortedSetCommands

zrange

public List<byte[]> zrange(byte[] key,
                           long start,
                           long stop)

Specified by:

zrange in interface SortedSetBinaryCommands

zrevrange

public List<byte[]> zrevrange(byte[] key,
                              long start,
                              long stop)

Specified by:

zrevrange in interface SortedSetBinaryCommands

zrangeWithScores

public List<Tuple> zrangeWithScores(byte[] key,
                                    long start,
                                    long stop)

Specified by:

zrangeWithScores in interface SortedSetBinaryCommands

zrevrangeWithScores

public List<Tuple> zrevrangeWithScores(byte[] key,
                                       long start,
                                       long stop)

Specified by:

zrevrangeWithScores in interface SortedSetBinaryCommands

zrange

public List<byte[]> zrange(byte[] key,
                           ZRangeParams zRangeParams)

Specified by:

zrange in interface SortedSetBinaryCommands

zrangeWithScores

public List<Tuple> zrangeWithScores(byte[] key,
                                    ZRangeParams zRangeParams)

Specified by:

zrangeWithScores in interface SortedSetBinaryCommands

zrangestore

public long zrangestore(byte[] dest,
                        byte[] src,
                        ZRangeParams zRangeParams)

Specified by:

zrangestore in interface SortedSetBinaryCommands

zrangeByScore

public List<byte[]> zrangeByScore(byte[] key,
                                  double min,
                                  double max)

Specified by:

zrangeByScore in interface SortedSetBinaryCommands

zrangeByScore

public List<byte[]> zrangeByScore(byte[] key,
                                  byte[] min,
                                  byte[] max)

Specified by:

zrangeByScore in interface SortedSetBinaryCommands

zrevrangeByScore

public List<byte[]> zrevrangeByScore(byte[] key,
                                     double max,
                                     double min)

Specified by:

zrevrangeByScore in interface SortedSetBinaryCommands

zrangeByScore

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

Specified by:

zrangeByScore in interface SortedSetBinaryCommands

zrevrangeByScore

public List<byte[]> zrevrangeByScore(byte[] key,
                                     byte[] max,
                                     byte[] min)

Specified by:

zrevrangeByScore in interface SortedSetBinaryCommands

zrangeByScore

public List<byte[]> zrangeByScore(byte[] key,
                                  byte[] min,
                                  byte[] max,
                                  int offset,
                                  int count)

Specified by:

zrangeByScore in interface SortedSetBinaryCommands

zrevrangeByScore

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

Specified by:

zrevrangeByScore in interface SortedSetBinaryCommands

zrangeByScoreWithScores

public List<Tuple> zrangeByScoreWithScores(byte[] key,
                                           double min,
                                           double max)

Specified by:

zrangeByScoreWithScores in interface SortedSetBinaryCommands

zrevrangeByScoreWithScores

public List<Tuple> zrevrangeByScoreWithScores(byte[] key,
                                              double max,
                                              double min)

Specified by:

zrevrangeByScoreWithScores in interface SortedSetBinaryCommands

zrangeByScoreWithScores

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

Specified by:

zrangeByScoreWithScores in interface SortedSetBinaryCommands

zrevrangeByScore

public List<byte[]> zrevrangeByScore(byte[] key,
                                     byte[] max,
                                     byte[] min,
                                     int offset,
                                     int count)

Specified by:

zrevrangeByScore in interface SortedSetBinaryCommands

zrangeByScoreWithScores

public List<Tuple> zrangeByScoreWithScores(byte[] key,
                                           byte[] min,
                                           byte[] max)

Specified by:

zrangeByScoreWithScores in interface SortedSetBinaryCommands

zrevrangeByScoreWithScores

public List<Tuple> zrevrangeByScoreWithScores(byte[] key,
                                              byte[] max,
                                              byte[] min)

Specified by:

zrevrangeByScoreWithScores in interface SortedSetBinaryCommands

zrangeByScoreWithScores

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

Specified by:

zrangeByScoreWithScores in interface SortedSetBinaryCommands

zrevrangeByScoreWithScores

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

Specified by:

zrevrangeByScoreWithScores in interface SortedSetBinaryCommands

zrevrangeByScoreWithScores

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

Specified by:

zrevrangeByScoreWithScores in interface SortedSetBinaryCommands

zremrangeByRank

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

Specified by:

zremrangeByRank in interface SortedSetCommands

zremrangeByScore

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

Specified by:

zremrangeByScore in interface SortedSetCommands

zremrangeByScore

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

Specified by:

zremrangeByScore in interface SortedSetCommands

zremrangeByRank

public long zremrangeByRank(byte[] key,
                            long start,
                            long stop)

Specified by:

zremrangeByRank in interface SortedSetBinaryCommands

zremrangeByScore

public long zremrangeByScore(byte[] key,
                             double min,
                             double max)

Specified by:

zremrangeByScore in interface SortedSetBinaryCommands

zremrangeByScore

public long zremrangeByScore(byte[] key,
                             byte[] min,
                             byte[] max)

Specified by:

zremrangeByScore in interface SortedSetBinaryCommands

zlexcount

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

Specified by:

zlexcount in interface SortedSetCommands

zrangeByLex

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

Specified by:

zrangeByLex in interface SortedSetCommands

zrangeByLex

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

Specified by:

zrangeByLex in interface SortedSetCommands

zrevrangeByLex

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

Specified by:

zrevrangeByLex in interface SortedSetCommands

zrevrangeByLex

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

Specified by:

zrevrangeByLex in interface SortedSetCommands

zremrangeByLex

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

Specified by:

zremrangeByLex in interface SortedSetCommands

zlexcount

public long zlexcount(byte[] key,
                      byte[] min,
                      byte[] max)

Specified by:

zlexcount in interface SortedSetBinaryCommands

zrangeByLex

public List<byte[]> zrangeByLex(byte[] key,
                                byte[] min,
                                byte[] max)

Specified by:

zrangeByLex in interface SortedSetBinaryCommands

zrangeByLex

public List<byte[]> zrangeByLex(byte[] key,
                                byte[] min,
                                byte[] max,
                                int offset,
                                int count)

Specified by:

zrangeByLex in interface SortedSetBinaryCommands

zrevrangeByLex

public List<byte[]> zrevrangeByLex(byte[] key,
                                   byte[] max,
                                   byte[] min)

Specified by:

zrevrangeByLex in interface SortedSetBinaryCommands

zrevrangeByLex

public List<byte[]> zrevrangeByLex(byte[] key,
                                   byte[] max,
                                   byte[] min,
                                   int offset,
                                   int count)

Specified by:

zrevrangeByLex in interface SortedSetBinaryCommands

zremrangeByLex

public long zremrangeByLex(byte[] key,
                           byte[] min,
                           byte[] max)

Specified by:

zremrangeByLex in interface SortedSetBinaryCommands

zscan

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

Specified by:

zscan in interface SortedSetCommands

zscan

public ScanResult<Tuple> zscan(byte[] key,
                               byte[] cursor,
                               ScanParams params)

Specified by:

zscan in interface SortedSetBinaryCommands

bzpopmax

public KeyedZSetElement bzpopmax(double timeout,
                                 String... keys)

Specified by:

bzpopmax in interface SortedSetCommands

bzpopmin

public KeyedZSetElement bzpopmin(double timeout,
                                 String... keys)

Specified by:

bzpopmin in interface SortedSetCommands

bzpopmax

public List<byte[]> bzpopmax(double timeout,
                             byte[]... keys)

Specified by:

bzpopmax in interface SortedSetBinaryCommands

bzpopmin

public List<byte[]> bzpopmin(double timeout,
                             byte[]... keys)

Specified by:

bzpopmin in interface SortedSetBinaryCommands

zdiff

public Set<String> zdiff(String... keys)

Specified by:

zdiff in interface SortedSetCommands

zdiffWithScores

public Set<Tuple> zdiffWithScores(String... keys)

Specified by:

zdiffWithScores in interface SortedSetCommands

zdiffStore

public long zdiffStore(String dstkey,
                       String... keys)

Specified by:

zdiffStore in interface SortedSetCommands

zdiff

public Set<byte[]> zdiff(byte[]... keys)

Specified by:

zdiff in interface SortedSetBinaryCommands

zdiffWithScores

public Set<Tuple> zdiffWithScores(byte[]... keys)

Specified by:

zdiffWithScores in interface SortedSetBinaryCommands

zdiffStore

public long zdiffStore(byte[] dstkey,
                       byte[]... keys)

Specified by:

zdiffStore in interface SortedSetBinaryCommands

zinterstore

public long zinterstore(String dstkey,
                        String... sets)

Specified by:

zinterstore in interface SortedSetCommands

zinterstore

public long zinterstore(String dstkey,
                        ZParams params,
                        String... sets)

Specified by:

zinterstore in interface SortedSetCommands

zinter

public Set<String> zinter(ZParams params,
                          String... keys)

Specified by:

zinter in interface SortedSetCommands

zinterWithScores

public Set<Tuple> zinterWithScores(ZParams params,
                                   String... keys)

Specified by:

zinterWithScores in interface SortedSetCommands

zinterstore

public long zinterstore(byte[] dstkey,
                        byte[]... sets)

Specified by:

zinterstore in interface SortedSetBinaryCommands

zinterstore

public long zinterstore(byte[] dstkey,
                        ZParams params,
                        byte[]... sets)

Specified by:

zinterstore in interface SortedSetBinaryCommands

zinter

public Set<byte[]> zinter(ZParams params,
                          byte[]... keys)

Specified by:

zinter in interface SortedSetBinaryCommands

zinterWithScores

public Set<Tuple> zinterWithScores(ZParams params,
                                   byte[]... keys)

Specified by:

zinterWithScores in interface SortedSetBinaryCommands

zunion

public Set<String> zunion(ZParams params,
                          String... keys)

Specified by:

zunion in interface SortedSetCommands

zunionWithScores

public Set<Tuple> zunionWithScores(ZParams params,
                                   String... keys)

Specified by:

zunionWithScores in interface SortedSetCommands

zunionstore

public long zunionstore(String dstkey,
                        String... sets)

Specified by:

zunionstore in interface SortedSetCommands

zunionstore

public long zunionstore(String dstkey,
                        ZParams params,
                        String... sets)

Specified by:

zunionstore in interface SortedSetCommands

zunion

public Set<byte[]> zunion(ZParams params,
                          byte[]... keys)

Specified by:

zunion in interface SortedSetBinaryCommands

zunionWithScores

public Set<Tuple> zunionWithScores(ZParams params,
                                   byte[]... keys)

Specified by:

zunionWithScores in interface SortedSetBinaryCommands

zunionstore

public long zunionstore(byte[] dstkey,
                        byte[]... sets)

Specified by:

zunionstore in interface SortedSetBinaryCommands

zunionstore

public long zunionstore(byte[] dstkey,
                        ZParams params,
                        byte[]... sets)

Specified by:

zunionstore in interface SortedSetBinaryCommands

geoadd

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

Specified by:

geoadd in interface GeoCommands

geoadd

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

Specified by:

geoadd in interface GeoCommands

geoadd

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

Specified by:

geoadd in interface GeoCommands

geodist

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

Specified by:

geodist in interface GeoCommands

geodist

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

Specified by:

geodist in interface GeoCommands

geohash

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

Specified by:

geohash in interface GeoCommands

geopos

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

Specified by:

geopos in interface GeoCommands

geoadd

public long geoadd(byte[] key,
                   double longitude,
                   double latitude,
                   byte[] member)

Specified by:

geoadd in interface GeoBinaryCommands

geoadd

public long geoadd(byte[] key,
                   Map<byte[],GeoCoordinate> memberCoordinateMap)

Specified by:

geoadd in interface GeoBinaryCommands

geoadd

public long geoadd(byte[] key,
                   GeoAddParams params,
                   Map<byte[],GeoCoordinate> memberCoordinateMap)

Specified by:

geoadd in interface GeoBinaryCommands

geodist

public Double geodist(byte[] key,
                      byte[] member1,
                      byte[] member2)

Specified by:

geodist in interface GeoBinaryCommands

geodist

public Double geodist(byte[] key,
                      byte[] member1,
                      byte[] member2,
                      GeoUnit unit)

Specified by:

geodist in interface GeoBinaryCommands

geohash

public List<byte[]> geohash(byte[] key,
                            byte[]... members)

Specified by:

geohash in interface GeoBinaryCommands

geopos

public List<GeoCoordinate> geopos(byte[] key,
                                  byte[]... members)

Specified by:

geopos in interface GeoBinaryCommands

georadius

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

Specified by:

georadius in interface GeoCommands

georadiusReadonly

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

Specified by:

georadiusReadonly in interface GeoCommands

georadius

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

Specified by:

georadius in interface GeoCommands

georadiusReadonly

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

Specified by:

georadiusReadonly in interface GeoCommands

georadiusByMember

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

Specified by:

georadiusByMember in interface GeoCommands

georadiusByMemberReadonly

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

Specified by:

georadiusByMemberReadonly in interface GeoCommands

georadiusByMember

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

Specified by:

georadiusByMember in interface GeoCommands

georadiusByMemberReadonly

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

Specified by:

georadiusByMemberReadonly in interface GeoCommands

georadiusStore

public long georadiusStore(String key,
                           double longitude,
                           double latitude,
                           double radius,
                           GeoUnit unit,
                           GeoRadiusParam param,
                           GeoRadiusStoreParam storeParam)

Specified by:

georadiusStore in interface GeoCommands

georadiusByMemberStore

public long georadiusByMemberStore(String key,
                                   String member,
                                   double radius,
                                   GeoUnit unit,
                                   GeoRadiusParam param,
                                   GeoRadiusStoreParam storeParam)

Specified by:

georadiusByMemberStore in interface GeoCommands

geosearch

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

Specified by:

geosearch in interface GeoCommands

geosearch

public List<GeoRadiusResponse> geosearch(String key,
                                         GeoCoordinate coord,
                                         double radius,
                                         GeoUnit unit)

Specified by:

geosearch in interface GeoCommands

geosearch

public List<GeoRadiusResponse> geosearch(String key,
                                         String member,
                                         double width,
                                         double height,
                                         GeoUnit unit)

Specified by:

geosearch in interface GeoCommands

geosearch

public List<GeoRadiusResponse> geosearch(String key,
                                         GeoCoordinate coord,
                                         double width,
                                         double height,
                                         GeoUnit unit)

Specified by:

geosearch in interface GeoCommands

geosearch

public List<GeoRadiusResponse> geosearch(String key,
                                         GeoSearchParam params)

Specified by:

geosearch in interface GeoCommands

geosearchStore

public long geosearchStore(String dest,
                           String src,
                           String member,
                           double radius,
                           GeoUnit unit)

Specified by:

geosearchStore in interface GeoCommands

geosearchStore

public long geosearchStore(String dest,
                           String src,
                           GeoCoordinate coord,
                           double radius,
                           GeoUnit unit)

Specified by:

geosearchStore in interface GeoCommands

geosearchStore

public long geosearchStore(String dest,
                           String src,
                           String member,
                           double width,
                           double height,
                           GeoUnit unit)

Specified by:

geosearchStore in interface GeoCommands

geosearchStore

public long geosearchStore(String dest,
                           String src,
                           GeoCoordinate coord,
                           double width,
                           double height,
                           GeoUnit unit)

Specified by:

geosearchStore in interface GeoCommands

geosearchStore

public long geosearchStore(String dest,
                           String src,
                           GeoSearchParam params)

Specified by:

geosearchStore in interface GeoCommands

geosearchStoreStoreDist

public long geosearchStoreStoreDist(String dest,
                                    String src,
                                    GeoSearchParam params)

Specified by:

geosearchStoreStoreDist in interface GeoCommands

georadius

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

Specified by:

georadius in interface GeoBinaryCommands

georadiusReadonly

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

Specified by:

georadiusReadonly in interface GeoBinaryCommands

georadius

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

Specified by:

georadius in interface GeoBinaryCommands

georadiusReadonly

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

Specified by:

georadiusReadonly in interface GeoBinaryCommands

georadiusByMember

public List<GeoRadiusResponse> georadiusByMember(byte[] key,
                                                 byte[] member,
                                                 double radius,
                                                 GeoUnit unit)

Specified by:

georadiusByMember in interface GeoBinaryCommands

georadiusByMemberReadonly

public List<GeoRadiusResponse> georadiusByMemberReadonly(byte[] key,
                                                         byte[] member,
                                                         double radius,
                                                         GeoUnit unit)

Specified by:

georadiusByMemberReadonly in interface GeoBinaryCommands

georadiusByMember

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

Specified by:

georadiusByMember in interface GeoBinaryCommands

georadiusByMemberReadonly

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

Specified by:

georadiusByMemberReadonly in interface GeoBinaryCommands

georadiusStore

public long georadiusStore(byte[] key,
                           double longitude,
                           double latitude,
                           double radius,
                           GeoUnit unit,
                           GeoRadiusParam param,
                           GeoRadiusStoreParam storeParam)

Specified by:

georadiusStore in interface GeoBinaryCommands

georadiusByMemberStore

public long georadiusByMemberStore(byte[] key,
                                   byte[] member,
                                   double radius,
                                   GeoUnit unit,
                                   GeoRadiusParam param,
                                   GeoRadiusStoreParam storeParam)

Specified by:

georadiusByMemberStore in interface GeoBinaryCommands

geosearch

public List<GeoRadiusResponse> geosearch(byte[] key,
                                         byte[] member,
                                         double radius,
                                         GeoUnit unit)

Specified by:

geosearch in interface GeoBinaryCommands

geosearch

public List<GeoRadiusResponse> geosearch(byte[] key,
                                         GeoCoordinate coord,
                                         double radius,
                                         GeoUnit unit)

Specified by:

geosearch in interface GeoBinaryCommands

geosearch

public List<GeoRadiusResponse> geosearch(byte[] key,
                                         byte[] member,
                                         double width,
                                         double height,
                                         GeoUnit unit)

Specified by:

geosearch in interface GeoBinaryCommands

geosearch

public List<GeoRadiusResponse> geosearch(byte[] key,
                                         GeoCoordinate coord,
                                         double width,
                                         double height,
                                         GeoUnit unit)

Specified by:

geosearch in interface GeoBinaryCommands

geosearch

public List<GeoRadiusResponse> geosearch(byte[] key,
                                         GeoSearchParam params)

Specified by:

geosearch in interface GeoBinaryCommands

geosearchStore

public long geosearchStore(byte[] dest,
                           byte[] src,
                           byte[] member,
                           double radius,
                           GeoUnit unit)

Specified by:

geosearchStore in interface GeoBinaryCommands

geosearchStore

public long geosearchStore(byte[] dest,
                           byte[] src,
                           GeoCoordinate coord,
                           double radius,
                           GeoUnit unit)

Specified by:

geosearchStore in interface GeoBinaryCommands

geosearchStore

public long geosearchStore(byte[] dest,
                           byte[] src,
                           byte[] member,
                           double width,
                           double height,
                           GeoUnit unit)

Specified by:

geosearchStore in interface GeoBinaryCommands

geosearchStore

public long geosearchStore(byte[] dest,
                           byte[] src,
                           GeoCoordinate coord,
                           double width,
                           double height,
                           GeoUnit unit)

Specified by:

geosearchStore in interface GeoBinaryCommands

geosearchStore

public long geosearchStore(byte[] dest,
                           byte[] src,
                           GeoSearchParam params)

Specified by:

geosearchStore in interface GeoBinaryCommands

geosearchStoreStoreDist

public long geosearchStoreStoreDist(byte[] dest,
                                    byte[] src,
                                    GeoSearchParam params)

Specified by:

geosearchStoreStoreDist in interface GeoBinaryCommands

pfadd

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

Specified by:

pfadd in interface HyperLogLogCommands

pfmerge

public String pfmerge(String destkey,
                      String... sourcekeys)

Specified by:

pfmerge in interface HyperLogLogCommands

pfcount

public long pfcount(String key)

Specified by:

pfcount in interface HyperLogLogCommands

pfcount

public long pfcount(String... keys)

Specified by:

pfcount in interface HyperLogLogCommands

pfadd

public long pfadd(byte[] key,
                  byte[]... elements)

Specified by:

pfadd in interface HyperLogLogBinaryCommands

pfmerge

public String pfmerge(byte[] destkey,
                      byte[]... sourcekeys)

Specified by:

pfmerge in interface HyperLogLogBinaryCommands

pfcount

public long pfcount(byte[] key)

Specified by:

pfcount in interface HyperLogLogBinaryCommands

pfcount

public long pfcount(byte[]... keys)

Specified by:

pfcount in interface HyperLogLogBinaryCommands

xadd

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

Description copied from interface: StreamCommands

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

Specified by:

xadd in interface StreamCommands

Returns:

the ID of the added entry

xadd

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

Specified by:

xadd in interface StreamCommands

xlen

public long xlen(String key)

Description copied from interface: StreamCommands

XLEN key

Specified by:

xlen in interface StreamCommands

Returns:

length of stream

xrange

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

Description copied from interface: StreamCommands

XRANGE key start end

Specified by:

xrange in interface StreamCommands

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: StreamCommands

XRANGE key start end COUNT count

Specified by:

xrange in interface StreamCommands

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.

xrevrange

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

Description copied from interface: StreamCommands

XREVRANGE key end start

Specified by:

xrevrange in interface StreamCommands

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: StreamCommands

XREVRANGE key end start COUNT count

Specified by:

xrevrange in interface StreamCommands

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.

xrange

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

Specified by:

xrange in interface StreamCommands

xrange

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

Specified by:

xrange in interface StreamCommands

xrevrange

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

Specified by:

xrevrange in interface StreamCommands

xrevrange

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

Specified by:

xrevrange in interface StreamCommands

xack

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

Description copied from interface: StreamCommands

XACK key group ID [ID ...]

Specified by:

xack in interface StreamCommands

xgroupCreate

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

Description copied from interface: StreamCommands

XGROUP CREATE

Specified by:

xgroupCreate in interface StreamCommands

xgroupSetID

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

Description copied from interface: StreamCommands

XGROUP SETID

Specified by:

xgroupSetID in interface StreamCommands

xgroupDestroy

public long xgroupDestroy(String key,
                          String groupname)

Description copied from interface: StreamCommands

XGROUP DESTROY

Specified by:

xgroupDestroy in interface StreamCommands

xgroupDelConsumer

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

Description copied from interface: StreamCommands

XGROUP DELCONSUMER

Specified by:

xgroupDelConsumer in interface StreamCommands

xpending

public StreamPendingSummary xpending(String key,
                                     String groupname)

Description copied from interface: StreamCommands

XPENDING key group

Specified by:

xpending in interface StreamCommands

xpending

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

Description copied from interface: StreamCommands

XPENDING key group [start end count] [consumer]

Specified by:

xpending in interface StreamCommands

xpending

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

Description copied from interface: StreamCommands

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

Specified by:

xpending in interface StreamCommands

xdel

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

Description copied from interface: StreamCommands

XDEL key ID [ID ...]

Specified by:

xdel in interface StreamCommands

xtrim

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

Description copied from interface: StreamCommands

XTRIM key MAXLEN [~] count

Specified by:

xtrim in interface StreamCommands

xtrim

public long xtrim(String key,
                  XTrimParams params)

Description copied from interface: StreamCommands

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

Specified by:

xtrim in interface StreamCommands

xclaim

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

Description copied from interface: StreamCommands

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

Specified by:

xclaim in interface StreamCommands

xclaimJustId

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

Description copied from interface: StreamCommands

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

Specified by:

xclaimJustId in interface StreamCommands

xautoclaim

public Map.Entry<StreamEntryID,List<StreamEntry>> xautoclaim(String key,
                                                             String group,
                                                             String consumerName,
                                                             long minIdleTime,
                                                             StreamEntryID start,
                                                             XAutoClaimParams params)

Description copied from interface: StreamCommands

XAUTOCLAIM key group consumer min-idle-time start [COUNT count]

Specified by:

xautoclaim in interface StreamCommands

Parameters:

key - Stream Key

group - Consumer Group

consumerName - Consumer name to transfer the auto claimed entries

minIdleTime - Entries pending more than minIdleTime will be transferred ownership

start - StreamEntryID - Entries >= start will be transferred ownership, passing null will indicate '-'

params - XAutoClaimParams

xautoclaimJustId

public Map.Entry<StreamEntryID,List<StreamEntryID>> xautoclaimJustId(String key,
                                                                     String group,
                                                                     String consumerName,
                                                                     long minIdleTime,
                                                                     StreamEntryID start,
                                                                     XAutoClaimParams params)

Description copied from interface: StreamCommands

XAUTOCLAIM key group consumer min-idle-time start [COUNT count] JUSTID

Specified by:

xautoclaimJustId in interface StreamCommands

Parameters:

key - Stream Key

group - Consumer Group

consumerName - Consumer name to transfer the auto claimed entries

minIdleTime - Entries pending more than minIdleTime will be transferred ownership

start - StreamEntryID - Entries >= start will be transferred ownership, passing null will indicate '-'

params - XAutoClaimParams

xinfoStream

public StreamInfo xinfoStream(String key)

Description copied from interface: StreamCommands

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

Specified by:

xinfoStream in interface StreamCommands

Parameters:

key - Stream name

Returns:

StreamInfo that contains information about the stream

xinfoStreamFull

public StreamFullInfo xinfoStreamFull(String key)

Description copied from interface: StreamCommands

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

Specified by:

xinfoStreamFull in interface StreamCommands

Parameters:

key - Stream name

Returns:

StreamFullInfo that contains information about the stream

xinfoStreamFull

public StreamFullInfo xinfoStreamFull(String key,
                                      int count)

Description copied from interface: StreamCommands

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

Specified by:

xinfoStreamFull in interface StreamCommands

Parameters:

key - Stream name

count - stream info count

Returns:

StreamFullInfo that contains information about the stream

xinfoGroup

@Deprecated
public List<StreamGroupInfo> xinfoGroup(String key)

Deprecated.

Specified by:

xinfoGroup in interface StreamCommands

xinfoGroups

public List<StreamGroupInfo> xinfoGroups(String key)

Description copied from interface: StreamCommands

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

Specified by:

xinfoGroups in interface StreamCommands

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: StreamCommands

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

Specified by:

xinfoConsumers in interface StreamCommands

Parameters:

key - Stream name

group - Group name

Returns:

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

xread

public List<Map.Entry<String,List<StreamEntry>>> xread(XReadParams xReadParams,
                                                       Map<String,StreamEntryID> streams)

Description copied from interface: StreamCommands

XREAD [COUNT count] [BLOCK milliseconds] STREAMS key [key ...] ID [ID ...]

Specified by:

xread in interface StreamCommands

xreadGroup

public List<Map.Entry<String,List<StreamEntry>>> xreadGroup(String groupname,
                                                            String consumer,
                                                            XReadGroupParams xReadGroupParams,
                                                            Map<String,StreamEntryID> streams)

Description copied from interface: StreamCommands

XREAD [COUNT count] [BLOCK milliseconds] STREAMS key [key ...] ID [ID ...]

Specified by:

xreadGroup in interface StreamCommands

xadd

public byte[] xadd(byte[] key,
                   XAddParams params,
                   Map<byte[],byte[]> hash)

Specified by:

xadd in interface StreamBinaryCommands

xlen

public long xlen(byte[] key)

Specified by:

xlen in interface StreamBinaryCommands

xrange

public List<byte[]> xrange(byte[] key,
                           byte[] start,
                           byte[] end)

Specified by:

xrange in interface StreamBinaryCommands

xrange

public List<byte[]> xrange(byte[] key,
                           byte[] start,
                           byte[] end,
                           int count)

Specified by:

xrange in interface StreamBinaryCommands

xrevrange

public List<byte[]> xrevrange(byte[] key,
                              byte[] end,
                              byte[] start)

Specified by:

xrevrange in interface StreamBinaryCommands

xrevrange

public List<byte[]> xrevrange(byte[] key,
                              byte[] end,
                              byte[] start,
                              int count)

Specified by:

xrevrange in interface StreamBinaryCommands

xack

public long xack(byte[] key,
                 byte[] group,
                 byte[]... ids)

Specified by:

xack in interface StreamBinaryCommands

xgroupCreate

public String xgroupCreate(byte[] key,
                           byte[] groupname,
                           byte[] id,
                           boolean makeStream)

Specified by:

xgroupCreate in interface StreamBinaryCommands

xgroupSetID

public String xgroupSetID(byte[] key,
                          byte[] groupname,
                          byte[] id)

Specified by:

xgroupSetID in interface StreamBinaryCommands

xgroupDestroy

public long xgroupDestroy(byte[] key,
                          byte[] groupname)

Specified by:

xgroupDestroy in interface StreamBinaryCommands

xgroupDelConsumer

public long xgroupDelConsumer(byte[] key,
                              byte[] groupname,
                              byte[] consumerName)

Specified by:

xgroupDelConsumer in interface StreamBinaryCommands

xdel

public long xdel(byte[] key,
                 byte[]... ids)

Specified by:

xdel in interface StreamBinaryCommands

xtrim

public long xtrim(byte[] key,
                  long maxLen,
                  boolean approximateLength)

Specified by:

xtrim in interface StreamBinaryCommands

xtrim

public long xtrim(byte[] key,
                  XTrimParams params)

Specified by:

xtrim in interface StreamBinaryCommands

xpending

public Object xpending(byte[] key,
                       byte[] groupname)

Specified by:

xpending in interface StreamBinaryCommands

xpending

public List<Object> xpending(byte[] key,
                             byte[] groupname,
                             byte[] start,
                             byte[] end,
                             int count,
                             byte[] consumername)

Specified by:

xpending in interface StreamBinaryCommands

xpending

public List<Object> xpending(byte[] key,
                             byte[] groupname,
                             XPendingParams params)

Specified by:

xpending in interface StreamBinaryCommands

xclaim

public List<byte[]> xclaim(byte[] key,
                           byte[] group,
                           byte[] consumername,
                           long minIdleTime,
                           XClaimParams params,
                           byte[]... ids)

Specified by:

xclaim in interface StreamBinaryCommands

xclaimJustId

public List<byte[]> xclaimJustId(byte[] key,
                                 byte[] group,
                                 byte[] consumername,
                                 long minIdleTime,
                                 XClaimParams params,
                                 byte[]... ids)

Specified by:

xclaimJustId in interface StreamBinaryCommands

xautoclaim

public List<Object> xautoclaim(byte[] key,
                               byte[] groupName,
                               byte[] consumerName,
                               long minIdleTime,
                               byte[] start,
                               XAutoClaimParams params)

Specified by:

xautoclaim in interface StreamBinaryCommands

xautoclaimJustId

public List<Object> xautoclaimJustId(byte[] key,
                                     byte[] groupName,
                                     byte[] consumerName,
                                     long minIdleTime,
                                     byte[] start,
                                     XAutoClaimParams params)

Specified by:

xautoclaimJustId in interface StreamBinaryCommands

xinfoStream

public Object xinfoStream(byte[] key)

Specified by:

xinfoStream in interface StreamBinaryCommands

xinfoStreamFull

public Object xinfoStreamFull(byte[] key)

Description copied from interface: StreamBinaryCommands

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

Specified by:

xinfoStreamFull in interface StreamBinaryCommands

Parameters:

key - Stream name

xinfoStreamFull

public Object xinfoStreamFull(byte[] key,
                              int count)

Description copied from interface: StreamBinaryCommands

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

Specified by:

xinfoStreamFull in interface StreamBinaryCommands

Parameters:

key - Stream name

count - stream info count

xinfoGroup

@Deprecated
public List<Object> xinfoGroup(byte[] key)

Deprecated.

Specified by:

xinfoGroup in interface StreamBinaryCommands

xinfoGroups

public List<Object> xinfoGroups(byte[] key)

Specified by:

xinfoGroups in interface StreamBinaryCommands

xinfoConsumers

public List<Object> xinfoConsumers(byte[] key,
                                   byte[] group)

Specified by:

xinfoConsumers in interface StreamBinaryCommands

xread

public List<byte[]> xread(XReadParams xReadParams,
                          Map.Entry<byte[],byte[]>... streams)

Specified by:

xread in interface StreamBinaryCommands

xreadGroup

public List<byte[]> xreadGroup(byte[] groupname,
                               byte[] consumer,
                               XReadGroupParams xReadGroupParams,
                               Map.Entry<byte[],byte[]>... streams)

Specified by:

xreadGroup in interface StreamBinaryCommands

eval

public Object eval(String script)

Specified by:

eval in interface ScriptingKeyCommands

eval

public Object eval(String script,
                   int keyCount,
                   String... params)

Specified by:

eval in interface ScriptingKeyCommands

eval

public Object eval(String script,
                   List<String> keys,
                   List<String> args)

Specified by:

eval in interface ScriptingKeyCommands

evalsha

public Object evalsha(String sha1)

Specified by:

evalsha in interface ScriptingKeyCommands

evalsha

public Object evalsha(String sha1,
                      int keyCount,
                      String... params)

Specified by:

evalsha in interface ScriptingKeyCommands

evalsha

public Object evalsha(String sha1,
                      List<String> keys,
                      List<String> args)

Specified by:

evalsha in interface ScriptingKeyCommands

eval

public Object eval(byte[] script)

Specified by:

eval in interface ScriptingKeyBinaryCommands

eval

public Object eval(byte[] script,
                   int keyCount,
                   byte[]... params)

Specified by:

eval in interface ScriptingKeyBinaryCommands

eval

public Object eval(byte[] script,
                   List<byte[]> keys,
                   List<byte[]> args)

Specified by:

eval in interface ScriptingKeyBinaryCommands

evalsha

public Object evalsha(byte[] sha1)

Specified by:

evalsha in interface ScriptingKeyBinaryCommands

evalsha

public Object evalsha(byte[] sha1,
                      int keyCount,
                      byte[]... params)

Specified by:

evalsha in interface ScriptingKeyBinaryCommands

evalsha

public Object evalsha(byte[] sha1,
                      List<byte[]> keys,
                      List<byte[]> args)

Specified by:

evalsha in interface ScriptingKeyBinaryCommands

objectRefcount

public Long objectRefcount(String key)

Specified by:

objectRefcount in interface KeyCommands

objectEncoding

public String objectEncoding(String key)

Specified by:

objectEncoding in interface KeyCommands

objectIdletime

public Long objectIdletime(String key)

Specified by:

objectIdletime in interface KeyCommands

objectFreq

public Long objectFreq(String key)

Specified by:

objectFreq in interface KeyCommands

objectRefcount

public Long objectRefcount(byte[] key)

Specified by:

objectRefcount in interface KeyBinaryCommands

objectEncoding

public byte[] objectEncoding(byte[] key)

Specified by:

objectEncoding in interface KeyBinaryCommands

objectIdletime

public Long objectIdletime(byte[] key)

Specified by:

objectIdletime in interface KeyBinaryCommands

objectFreq

public Long objectFreq(byte[] key)

Specified by:

objectFreq in interface KeyBinaryCommands

migrate

public String migrate(String host,
                      int port,
                      String key,
                      int timeout)

Specified by:

migrate in interface KeyCommands

migrate

public String migrate(String host,
                      int port,
                      int timeout,
                      MigrateParams params,
                      String... keys)

Specified by:

migrate in interface KeyCommands

migrate

public String migrate(String host,
                      int port,
                      byte[] key,
                      int timeout)

Specified by:

migrate in interface KeyBinaryCommands

migrate

public String migrate(String host,
                      int port,
                      int timeout,
                      MigrateParams params,
                      byte[]... keys)

Specified by:

migrate in interface KeyBinaryCommands

waitReplicas

public long waitReplicas(String sampleKey,
                         int replicas,
                         long timeout)

Specified by:

waitReplicas in interface SampleKeyedCommands

waitReplicas

public long waitReplicas(byte[] sampleKey,
                         int replicas,
                         long timeout)

Specified by:

waitReplicas in interface SampleBinaryKeyedCommands

eval

public Object eval(String script,
                   String sampleKey)

Specified by:

eval in interface SampleKeyedCommands

evalsha

public Object evalsha(String sha1,
                      String sampleKey)

Specified by:

evalsha in interface SampleKeyedCommands

eval

public Object eval(byte[] script,
                   byte[] sampleKey)

Specified by:

eval in interface SampleBinaryKeyedCommands

evalsha

public Object evalsha(byte[] sha1,
                      byte[] sampleKey)

Specified by:

evalsha in interface SampleBinaryKeyedCommands

scriptExists

public Boolean scriptExists(String sha1,
                            String sampleKey)

Specified by:

scriptExists in interface SampleKeyedCommands

scriptExists

public List<Boolean> scriptExists(String sampleKey,
                                  String... sha1s)

Specified by:

scriptExists in interface SampleKeyedCommands

scriptExists

public Boolean scriptExists(byte[] sha1,
                            byte[] sampleKey)

Specified by:

scriptExists in interface SampleBinaryKeyedCommands

scriptExists

public List<Boolean> scriptExists(byte[] sampleKey,
                                  byte[]... sha1s)

Specified by:

scriptExists in interface SampleBinaryKeyedCommands

scriptLoad

public String scriptLoad(String script,
                         String sampleKey)

Specified by:

scriptLoad in interface SampleKeyedCommands

scriptFlush

public String scriptFlush(String sampleKey)

Specified by:

scriptFlush in interface SampleKeyedCommands

scriptFlush

public String scriptFlush(String sampleKey,
                          FlushMode flushMode)

Specified by:

scriptFlush in interface SampleKeyedCommands

scriptKill

public String scriptKill(String sampleKey)

Specified by:

scriptKill in interface SampleKeyedCommands

scriptLoad

public byte[] scriptLoad(byte[] script,
                         byte[] sampleKey)

Specified by:

scriptLoad in interface SampleBinaryKeyedCommands

scriptFlush

public String scriptFlush(byte[] sampleKey)

Specified by:

scriptFlush in interface SampleBinaryKeyedCommands

scriptFlush

public String scriptFlush(byte[] sampleKey,
                          FlushMode flushMode)

Specified by:

scriptFlush in interface SampleBinaryKeyedCommands

scriptKill

public String scriptKill(byte[] sampleKey)

Specified by:

scriptKill in interface SampleBinaryKeyedCommands

publish

public long publish(String channel,
                    String message)

publish

public long publish(byte[] channel,
                    byte[] message)

subscribe

public void subscribe(JedisPubSub jedisPubSub,
                      String... channels)

psubscribe

public void psubscribe(JedisPubSub jedisPubSub,
                       String... patterns)

subscribe

public void subscribe(BinaryJedisPubSub jedisPubSub,
                      byte[]... channels)

psubscribe

public void psubscribe(BinaryJedisPubSub jedisPubSub,
                       byte[]... patterns)

strAlgoLCSStrings

public LCSMatchResult strAlgoLCSStrings(String strA,
                                        String strB,
                                        StrAlgoLCSParams params)

strAlgoLCSStrings

public LCSMatchResult strAlgoLCSStrings(byte[] strA,
                                        byte[] strB,
                                        StrAlgoLCSParams params)

ftCreate

public String ftCreate(String indexName,
                       IndexOptions indexOptions,
                       Schema schema)

Specified by:

ftCreate in interface RediSearchCommands

ftAlter

public String ftAlter(String indexName,
                      Schema schema)

Specified by:

ftAlter in interface RediSearchCommands

ftSearch

public SearchResult ftSearch(String indexName,
                             Query query)

Specified by:

ftSearch in interface RediSearchCommands

ftSearch

public SearchResult ftSearch(byte[] indexName,
                             Query query)

Specified by:

ftSearch in interface RediSearchCommands

ftExplain

public String ftExplain(String indexName,
                        Query query)

Specified by:

ftExplain in interface RediSearchCommands

ftExplainCLI

public List<String> ftExplainCLI(String indexName,
                                 Query query)

Specified by:

ftExplainCLI in interface RediSearchCommands

ftAggregate

public AggregationResult ftAggregate(String indexName,
                                     AggregationBuilder aggr)

Specified by:

ftAggregate in interface RediSearchCommands

ftCursorRead

public AggregationResult ftCursorRead(String indexName,
                                      long cursorId,
                                      int count)

Specified by:

ftCursorRead in interface RediSearchCommands

ftCursorDel

public String ftCursorDel(String indexName,
                          long cursorId)

Specified by:

ftCursorDel in interface RediSearchCommands

ftDropIndex

public String ftDropIndex(String indexName)

Specified by:

ftDropIndex in interface RediSearchCommands

ftDropIndexDD

public String ftDropIndexDD(String indexName)

Specified by:

ftDropIndexDD in interface RediSearchCommands

ftSynUpdate

public String ftSynUpdate(String indexName,
                          String synonymGroupId,
                          String... terms)

Specified by:

ftSynUpdate in interface RediSearchCommands

ftSynDump

public Map<String,List<String>> ftSynDump(String indexName)

Specified by:

ftSynDump in interface RediSearchCommands

ftInfo

public Map<String,Object> ftInfo(String indexName)

Specified by:

ftInfo in interface RediSearchCommands

ftAliasAdd

public String ftAliasAdd(String aliasName,
                         String indexName)

Specified by:

ftAliasAdd in interface RediSearchCommands

ftAliasUpdate

public String ftAliasUpdate(String aliasName,
                            String indexName)

Specified by:

ftAliasUpdate in interface RediSearchCommands

ftAliasDel

public String ftAliasDel(String aliasName)

Specified by:

ftAliasDel in interface RediSearchCommands

ftConfigGet

public Map<String,String> ftConfigGet(String option)

Specified by:

ftConfigGet in interface RediSearchCommands

ftConfigGet

public Map<String,String> ftConfigGet(String indexName,
                                      String option)

Specified by:

ftConfigGet in interface RediSearchCommands

ftConfigSet

public String ftConfigSet(String option,
                          String value)

Specified by:

ftConfigSet in interface RediSearchCommands

ftConfigSet

public String ftConfigSet(String indexName,
                          String option,
                          String value)

Specified by:

ftConfigSet in interface RediSearchCommands

jsonSet

public String jsonSet(String key,
                      Path2 path,
                      Object object)

Specified by:

jsonSet in interface RedisJsonCommands

jsonSetWithEscape

public String jsonSetWithEscape(String key,
                                Path2 path,
                                Object object)

Specified by:

jsonSetWithEscape in interface RedisJsonCommands

jsonSet

public String jsonSet(String key,
                      Path path,
                      Object pojo)

Specified by:

jsonSet in interface RedisJsonCommands

jsonSet

public String jsonSet(String key,
                      Path2 path,
                      Object pojo,
                      JsonSetParams params)

Specified by:

jsonSet in interface RedisJsonCommands

jsonSetWithEscape

public String jsonSetWithEscape(String key,
                                Path2 path,
                                Object pojo,
                                JsonSetParams params)

Specified by:

jsonSetWithEscape in interface RedisJsonCommands

jsonSet

public String jsonSet(String key,
                      Path path,
                      Object pojo,
                      JsonSetParams params)

Specified by:

jsonSet in interface RedisJsonCommands

jsonGet

public Object jsonGet(String key)

Specified by:

jsonGet in interface RedisJsonCommands

jsonGet

public <T> T jsonGet(String key,
                     Class<T> clazz)

Specified by:

jsonGet in interface RedisJsonCommands

jsonGet

public Object jsonGet(String key,
                      Path2... paths)

Specified by:

jsonGet in interface RedisJsonCommands

jsonGet

public Object jsonGet(String key,
                      Path... paths)

Specified by:

jsonGet in interface RedisJsonCommands

jsonGet

public <T> T jsonGet(String key,
                     Class<T> clazz,
                     Path... paths)

Specified by:

jsonGet in interface RedisJsonCommands

jsonMGet

public List<org.json.JSONArray> jsonMGet(Path2 path,
                                         String... keys)

Specified by:

jsonMGet in interface RedisJsonCommands

jsonMGet

public <T> List<T> jsonMGet(Path path,
                            Class<T> clazz,
                            String... keys)

Specified by:

jsonMGet in interface RedisJsonCommands

jsonDel

public long jsonDel(String key)

Specified by:

jsonDel in interface RedisJsonCommands

jsonDel

public long jsonDel(String key,
                    Path2 path)

Specified by:

jsonDel in interface RedisJsonCommands

jsonDel

public long jsonDel(String key,
                    Path path)

Specified by:

jsonDel in interface RedisJsonCommands

jsonClear

public long jsonClear(String key)

Specified by:

jsonClear in interface RedisJsonCommands

jsonClear

public long jsonClear(String key,
                      Path2 path)

Specified by:

jsonClear in interface RedisJsonCommands

jsonClear

public long jsonClear(String key,
                      Path path)

Specified by:

jsonClear in interface RedisJsonCommands

jsonToggle

public List<Boolean> jsonToggle(String key,
                                Path2 path)

Specified by:

jsonToggle in interface RedisJsonCommands

jsonToggle

public String jsonToggle(String key,
                         Path path)

Specified by:

jsonToggle in interface RedisJsonCommands

jsonType

public Class<?> jsonType(String key)

Specified by:

jsonType in interface RedisJsonCommands

jsonType

public List<Class<?>> jsonType(String key,
                               Path2 path)

Specified by:

jsonType in interface RedisJsonCommands

jsonType

public Class<?> jsonType(String key,
                         Path path)

Specified by:

jsonType in interface RedisJsonCommands

jsonStrAppend

public long jsonStrAppend(String key,
                          Object string)

Specified by:

jsonStrAppend in interface RedisJsonCommands

jsonStrAppend

public List<Long> jsonStrAppend(String key,
                                Path2 path,
                                Object string)

Specified by:

jsonStrAppend in interface RedisJsonCommands

jsonStrAppend

public long jsonStrAppend(String key,
                          Path path,
                          Object string)

Specified by:

jsonStrAppend in interface RedisJsonCommands

jsonStrLen

public Long jsonStrLen(String key)

Specified by:

jsonStrLen in interface RedisJsonCommands

jsonStrLen

public List<Long> jsonStrLen(String key,
                             Path2 path)

Specified by:

jsonStrLen in interface RedisJsonCommands

jsonStrLen

public Long jsonStrLen(String key,
                       Path path)

Specified by:

jsonStrLen in interface RedisJsonCommands

jsonArrAppend

public List<Long> jsonArrAppend(String key,
                                Path2 path,
                                Object... objects)

Specified by:

jsonArrAppend in interface RedisJsonCommands

jsonArrAppendWithEscape

public List<Long> jsonArrAppendWithEscape(String key,
                                          Path2 path,
                                          Object... objects)

Specified by:

jsonArrAppendWithEscape in interface RedisJsonCommands

jsonArrAppend

public Long jsonArrAppend(String key,
                          Path path,
                          Object... pojos)

Specified by:

jsonArrAppend in interface RedisJsonCommands

jsonArrIndex

public List<Long> jsonArrIndex(String key,
                               Path2 path,
                               Object scalar)

Specified by:

jsonArrIndex in interface RedisJsonCommands

jsonArrIndexWithEscape

public List<Long> jsonArrIndexWithEscape(String key,
                                         Path2 path,
                                         Object scalar)

Specified by:

jsonArrIndexWithEscape in interface RedisJsonCommands

jsonArrIndex

public long jsonArrIndex(String key,
                         Path path,
                         Object scalar)

Specified by:

jsonArrIndex in interface RedisJsonCommands

jsonArrInsert

public List<Long> jsonArrInsert(String key,
                                Path2 path,
                                int index,
                                Object... objects)

Specified by:

jsonArrInsert in interface RedisJsonCommands

jsonArrInsertWithEscape

public List<Long> jsonArrInsertWithEscape(String key,
                                          Path2 path,
                                          int index,
                                          Object... objects)

Specified by:

jsonArrInsertWithEscape in interface RedisJsonCommands

jsonArrInsert

public long jsonArrInsert(String key,
                          Path path,
                          int index,
                          Object... pojos)

Specified by:

jsonArrInsert in interface RedisJsonCommands

jsonArrPop

public Object jsonArrPop(String key)

Specified by:

jsonArrPop in interface RedisJsonCommands

jsonArrPop

public <T> T jsonArrPop(String key,
                        Class<T> clazz)

Specified by:

jsonArrPop in interface RedisJsonCommands

jsonArrPop

public List<Object> jsonArrPop(String key,
                               Path2 path)

Specified by:

jsonArrPop in interface RedisJsonCommands

jsonArrPop

public Object jsonArrPop(String key,
                         Path path)

Specified by:

jsonArrPop in interface RedisJsonCommands

jsonArrPop

public <T> T jsonArrPop(String key,
                        Class<T> clazz,
                        Path path)

Specified by:

jsonArrPop in interface RedisJsonCommands

jsonArrPop

public List<Object> jsonArrPop(String key,
                               Path2 path,
                               int index)

Specified by:

jsonArrPop in interface RedisJsonCommands

jsonArrPop

public Object jsonArrPop(String key,
                         Path path,
                         int index)

Specified by:

jsonArrPop in interface RedisJsonCommands

jsonArrPop

public <T> T jsonArrPop(String key,
                        Class<T> clazz,
                        Path path,
                        int index)

Specified by:

jsonArrPop in interface RedisJsonCommands

jsonArrLen

public Long jsonArrLen(String key)

Specified by:

jsonArrLen in interface RedisJsonCommands

jsonArrLen

public List<Long> jsonArrLen(String key,
                             Path2 path)

Specified by:

jsonArrLen in interface RedisJsonCommands

jsonArrLen

public Long jsonArrLen(String key,
                       Path path)

Specified by:

jsonArrLen in interface RedisJsonCommands

jsonArrTrim

public List<Long> jsonArrTrim(String key,
                              Path2 path,
                              int start,
                              int stop)

Specified by:

jsonArrTrim in interface RedisJsonCommands

jsonArrTrim

public Long jsonArrTrim(String key,
                        Path path,
                        int start,
                        int stop)

Specified by:

jsonArrTrim in interface RedisJsonCommands

sendCommand

public Object sendCommand(ProtocolCommand cmd)

sendCommand

public Object sendCommand(ProtocolCommand cmd,
                          byte[]... args)

sendBlockingCommand

public Object sendBlockingCommand(ProtocolCommand cmd,
                                  byte[]... args)

sendCommand

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

sendBlockingCommand

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

sendCommand

public Object sendCommand(byte[] sampleKey,
                          ProtocolCommand cmd,
                          byte[]... args)

sendBlockingCommand

public Object sendBlockingCommand(byte[] sampleKey,
                                  ProtocolCommand cmd,
                                  byte[]... args)

sendCommand

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

sendBlockingCommand

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

executeCommand

public Object executeCommand(CommandArguments args)