Package redis.clients.jedis.executors

Class ClusterCommandExecutor

java.lang.Object

redis.clients.jedis.executors.ClusterCommandExecutor

All Implemented Interfaces:

AutoCloseable, CommandExecutor

public class ClusterCommandExecutor
extends Object
implements CommandExecutor

Field Summary

Fields

Modifier and Type	Field	Description
private final org.slf4j.Logger	log
protected final int	maxAttempts
protected final Duration	maxTotalRetriesDuration
final ClusterConnectionProvider	provider

Constructor Summary

Constructors

Constructor	Description
ClusterCommandExecutor(ClusterConnectionProvider provider, int maxAttempts, Duration maxTotalRetriesDuration)

Method Summary

Modifier and Type	Method	Description
final <T> T	broadcastCommand(CommandObject<T> commandObject)
void	close()
protected <T> T	execute(Connection connection, CommandObject<T> commandObject)	WARNING: This method is accessible for the purpose of testing.
final <T> T	executeCommand(CommandObject<T> commandObject)
private static long	getBackoffSleepMillis(int attemptsLeft, Instant deadline)
private boolean	handleConnectionProblem(int attemptsLeft, int consecutiveConnectionFailures, Instant doneDeadline)	Related values should be reset if TRUE is returned.
protected void	sleep(long sleepMillis)	WARNING: This method is accessible for the purpose of testing.

Methods inherited from class java.lang.Object

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

Field Details

log

private final org.slf4j.Logger log

provider

public final ClusterConnectionProvider provider

maxAttempts

protected final int maxAttempts

maxTotalRetriesDuration

protected final Duration maxTotalRetriesDuration

Constructor Details

ClusterCommandExecutor

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

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

broadcastCommand

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

Specified by:

broadcastCommand in interface CommandExecutor

executeCommand

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

Specified by:

executeCommand in interface CommandExecutor

execute

protected <T> T execute(Connection connection,
 CommandObject<T> commandObject)

WARNING: This method is accessible for the purpose of testing. This should not be used or overriden.

handleConnectionProblem

private boolean handleConnectionProblem(int attemptsLeft,
 int consecutiveConnectionFailures,
 Instant doneDeadline)

Related values should be reset if TRUE is returned.

Parameters:

attemptsLeft -

consecutiveConnectionFailures -

doneDeadline -

Returns:

true - if some actions are taken
false - if no actions are taken

getBackoffSleepMillis

private static long getBackoffSleepMillis(int attemptsLeft,
 Instant deadline)

sleep

protected void sleep(long sleepMillis)

WARNING: This method is accessible for the purpose of testing. This should not be used or overriden.