Interface ExternalShardAllocationClient

    • 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. The Address 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 identifier
        location - 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. The Address 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