redis.clients.jedis

Class JedisClusterCommand<T>

java.lang.Object

redis.clients.jedis.JedisClusterCommand<T>

public abstract class JedisClusterCommand<T>
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
private java.lang.ThreadLocal<Jedis>	askConnection
private JedisClusterConnectionHandler	connectionHandler
private int	maxAttempts

Constructor Summary

Constructors

Constructor and Description
JedisClusterCommand(JedisClusterConnectionHandler connectionHandler, int maxAttempts)

Method Summary

Modifier and Type	Method and Description
abstract T	execute(Jedis connection)
private void	releaseConnection(Jedis connection)
T	run(int keyCount, java.lang.String... keys)
T	run(java.lang.String key)
T	runBinary(byte[] key)
T	runBinary(int keyCount, byte[]... keys)
T	runWithAnyNode()
private T	runWithRetries(byte[] key, int attempts, boolean tryRandomNode, boolean asking)

Methods inherited from class java.lang.Object

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

Field Detail

connectionHandler

private JedisClusterConnectionHandler connectionHandler

maxAttempts

private int maxAttempts

askConnection

private java.lang.ThreadLocal<Jedis> askConnection

Constructor Detail

JedisClusterCommand

public JedisClusterCommand(JedisClusterConnectionHandler connectionHandler,
                           int maxAttempts)

Method Detail

execute

public abstract T execute(Jedis connection)

run

public T run(java.lang.String key)

run

public T run(int keyCount,
             java.lang.String... keys)

runBinary

public T runBinary(byte[] key)

runBinary

public T runBinary(int keyCount,
                   byte[]... keys)

runWithAnyNode

public T runWithAnyNode()

runWithRetries

private T runWithRetries(byte[] key,
                         int attempts,
                         boolean tryRandomNode,
                         boolean asking)

releaseConnection

private void releaseConnection(Jedis connection)