Package org.springframework.data.redis.connection

Class ClusterCommandExecutor

java.lang.Object

org.springframework.data.redis.connection.ClusterCommandExecutor

All Implemented Interfaces:

DisposableBean

public class ClusterCommandExecutor
extends Object
implements DisposableBean

ClusterCommandExecutor takes care of running commands across the known cluster nodes. By providing an AsyncTaskExecutor the execution behavior can be configured.

Since:

1.7

Author:

Christoph Strobl, Mark Paluch, John Blum

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ClusterCommandExecutor.ClusterCommandCallback<T,S>	Callback interface for Redis 'low level' code using the cluster client directly.
static interface	ClusterCommandExecutor.MultiKeyClusterCommandCallback<T,S>	Callback interface for Redis 'low level' code using the cluster client to execute multi key commands.
static class	ClusterCommandExecutor.MultiNodeResult<T>	ClusterCommandExecutor.MultiNodeResult holds all ClusterCommandExecutor.NodeResult of a command executed on multiple RedisClusterNode.
static class	ClusterCommandExecutor.NodeResult<T>	ClusterCommandExecutor.NodeResult encapsulates the actual value returned by a ClusterCommandExecutor.ClusterCommandCallback on a given RedisClusterNode.

Constructor Summary

Constructors

Constructor	Description
ClusterCommandExecutor(ClusterTopologyProvider topologyProvider, ClusterNodeResourceProvider resourceProvider, ExceptionTranslationStrategy exceptionTranslation)	Create a new ClusterCommandExecutor.
ClusterCommandExecutor(ClusterTopologyProvider topologyProvider, ClusterNodeResourceProvider resourceProvider, ExceptionTranslationStrategy exceptionTranslation, AsyncTaskExecutor executor)

Method Summary

Modifier and Type	Method	Description
void	destroy()
<S, T> ClusterCommandExecutor.MultiNodeResult<T>	executeCommandAsyncOnNodes(ClusterCommandExecutor.ClusterCommandCallback<S,T> commandCallback, Iterable<RedisClusterNode> nodes)
<S, T> ClusterCommandExecutor.MultiNodeResult<T>	executeCommandOnAllNodes(ClusterCommandExecutor.ClusterCommandCallback<S,T> commandCallback)	Run ClusterCommandExecutor.ClusterCommandCallback on all reachable master nodes.
<T> ClusterCommandExecutor.NodeResult<T>	executeCommandOnArbitraryNode(ClusterCommandExecutor.ClusterCommandCallback<?,T> commandCallback)	Run ClusterCommandExecutor.ClusterCommandCallback on a random node.
<S, T> ClusterCommandExecutor.NodeResult<T>	executeCommandOnSingleNode(ClusterCommandExecutor.ClusterCommandCallback<S,T> commandCallback, RedisClusterNode node)	Run ClusterCommandExecutor.ClusterCommandCallback on given RedisClusterNode.
<S, T> ClusterCommandExecutor.MultiNodeResult<T>	executeMultiKeyCommand(ClusterCommandExecutor.MultiKeyClusterCommandCallback<S,T> commandCallback, Iterable<byte[]> keys)	Run ClusterCommandExecutor.MultiKeyClusterCommandCallback with on a curated set of nodes serving one or more keys.
void	setMaxRedirects(int maxRedirects)	Set the maximum number of redirects to follow on MOVED or ASK.

Methods inherited from class java.lang.Object

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

Constructor Details

ClusterCommandExecutor

public ClusterCommandExecutor(ClusterTopologyProvider topologyProvider,
 ClusterNodeResourceProvider resourceProvider,
 ExceptionTranslationStrategy exceptionTranslation)

Create a new ClusterCommandExecutor.

Parameters:

topologyProvider - must not be null.

resourceProvider - must not be null.

exceptionTranslation - must not be null.

ClusterCommandExecutor

public ClusterCommandExecutor(ClusterTopologyProvider topologyProvider,
 ClusterNodeResourceProvider resourceProvider,
 ExceptionTranslationStrategy exceptionTranslation,
 @Nullable
 AsyncTaskExecutor executor)

Parameters:

topologyProvider - must not be null.

resourceProvider - must not be null.

exceptionTranslation - must not be null.

executor - the task executor to null, defaults to SimpleAsyncTaskExecutor if null.

Method Details

executeCommandOnArbitraryNode

public <T> ClusterCommandExecutor.NodeResult<T> executeCommandOnArbitraryNode(ClusterCommandExecutor.ClusterCommandCallback<?,T> commandCallback)

Run ClusterCommandExecutor.ClusterCommandCallback on a random node.

Parameters:

commandCallback - must not be null.

Returns:

never null.

executeCommandOnSingleNode

public <S,
T> ClusterCommandExecutor.NodeResult<T> executeCommandOnSingleNode(ClusterCommandExecutor.ClusterCommandCallback<S,T> commandCallback,
 RedisClusterNode node)

Run ClusterCommandExecutor.ClusterCommandCallback on given RedisClusterNode.

Parameters:

commandCallback - must not be null.

node - must not be null.

Returns:

the ClusterCommandExecutor.NodeResult from the single, targeted RedisClusterNode.

Throws:

IllegalArgumentException - in case no resource can be acquired for given node.

executeCommandOnAllNodes

public <S,
T>
ClusterCommandExecutor.MultiNodeResult<T> executeCommandOnAllNodes(ClusterCommandExecutor.ClusterCommandCallback<S,T> commandCallback)

Run ClusterCommandExecutor.ClusterCommandCallback on all reachable master nodes.

Parameters:

commandCallback - must not be null.

Returns:

never null.

Throws:

ClusterCommandExecutionFailureException - if a failure occurs while executing the given command on any given node.

executeCommandAsyncOnNodes

public <S,
T>
ClusterCommandExecutor.MultiNodeResult<T> executeCommandAsyncOnNodes(ClusterCommandExecutor.ClusterCommandCallback<S,T> commandCallback,
 Iterable<RedisClusterNode> nodes)

Parameters:

commandCallback - must not be null.

nodes - must not be null.

Returns:

never null.

Throws:

ClusterCommandExecutionFailureException - if a failure occurs while executing the given command on any given node.

IllegalArgumentException - in case the node could not be resolved to a topology-known node

executeMultiKeyCommand

public <S,
T>
ClusterCommandExecutor.MultiNodeResult<T> executeMultiKeyCommand(ClusterCommandExecutor.MultiKeyClusterCommandCallback<S,T> commandCallback,
 Iterable<byte[]> keys)

Run ClusterCommandExecutor.MultiKeyClusterCommandCallback with on a curated set of nodes serving one or more keys.

Parameters:

commandCallback - must not be null.

Returns:

never null.

Throws:

ClusterCommandExecutionFailureException - if a failure occurs while executing the given command.

setMaxRedirects

public void setMaxRedirects(int maxRedirects)

Set the maximum number of redirects to follow on MOVED or ASK.

Parameters:

maxRedirects - set to zero to suspend redirects.

destroy

public void destroy()
             throws Exception

Specified by:

destroy in interface DisposableBean

Throws:

Exception