Interface ExternalShardAllocationClient
-
public interface ExternalShardAllocationClient
API May ChangeNot for user extension
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description java.util.concurrent.CompletionStage<ShardLocations>
getShardLocations()
Get all the current shard locations that have been set via setShardLocationjava.util.concurrent.CompletionStage<Done>
setShardLocation(java.lang.String shard, Address location)
Update the given shard's location.java.util.concurrent.CompletionStage<Done>
setShardLocations(java.util.Map<java.lang.String,Address> locations)
Update all of the provided ShardLocations.
-
-
-
Method Detail
-
getShardLocations
java.util.concurrent.CompletionStage<ShardLocations> getShardLocations()
Get all the current shard locations that have been set via setShardLocation
-
setShardLocation
java.util.concurrent.CompletionStage<Done> setShardLocation(java.lang.String shard, Address location)
Update the given shard's location. TheAddress
should match one of the nodes in the cluster. If the node has not joined the cluster yet it will be moved to that node after the first cluster sharding rebalance.- Parameters:
shard
- The shard identifierlocation
- Location (akka node) to allocate the shard to- Returns:
- Conformation that the update has been written to the local node
-
setShardLocations
java.util.concurrent.CompletionStage<Done> setShardLocations(java.util.Map<java.lang.String,Address> locations)
Update all of the provided ShardLocations. TheAddress
should match one of the nodes in the cluster. If the node has not joined the cluster yet it will be moved to that node after the first cluster sharding rebalance it does.- Parameters:
locations
- to update- Returns:
- Confirmation that the update has been written to the local node
-
-