Interface ExternalShardAllocationClient
- 
 public interface ExternalShardAllocationClientNot for user extension
- 
- 
Method SummaryAll 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- 
getShardLocationsjava.util.concurrent.CompletionStage<ShardLocations> getShardLocations() Get all the current shard locations that have been set via setShardLocation
 - 
setShardLocationjava.util.concurrent.CompletionStage<Done> setShardLocation(java.lang.String shard, Address location) Update the given shard's location. TheAddressshould 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 identifier
- location- Location (akka node) to allocate the shard to
- Returns:
- Conformation that the update has been written to the local node
 
 - 
setShardLocationsjava.util.concurrent.CompletionStage<Done> setShardLocations(java.util.Map<java.lang.String,Address> locations) Update all of the provided ShardLocations. TheAddressshould 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
 
 
- 
 
-