public class SequentialShardAccessStrategy extends Object implements IShardAccessStrategy
Constructor and Description |
---|
SequentialShardAccessStrategy() |
Modifier and Type | Method and Description |
---|---|
void |
addOnError(ShardingErrorHandle<IDatabaseCommands> handler) |
<T> T[] |
apply(Class<?> clazz,
List<IDatabaseCommands> commands,
ShardRequestData request,
Function2<IDatabaseCommands,Integer,T> operation)
Applies the specified action for all shard sessions.
|
void |
removeOnError(ShardingErrorHandle<IDatabaseCommands> handler) |
public void addOnError(ShardingErrorHandle<IDatabaseCommands> handler)
addOnError
in interface IShardAccessStrategy
public void removeOnError(ShardingErrorHandle<IDatabaseCommands> handler)
removeOnError
in interface IShardAccessStrategy
public <T> T[] apply(Class<?> clazz, List<IDatabaseCommands> commands, ShardRequestData request, Function2<IDatabaseCommands,Integer,T> operation)
apply
in interface IShardAccessStrategy
Copyright © 2016. All Rights Reserved.