Packages

t

akka.cluster.sharding.external.javadsl

ExternalShardAllocationClient

trait ExternalShardAllocationClient extends AnyRef

Not for user extension

Annotations
@DoNotInherit()
Source
ExternalShardAllocationClient.scala
Linear Supertypes
AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ExternalShardAllocationClient
  2. AnyRef
  3. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def getShardLocations(): CompletionStage[ShardLocations]

    Get all the current shard locations that have been set via setShardLocation

  2. abstract def setShardLocation(shard: ShardId, location: Address): CompletionStage[Done]

    Update the given shard's 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.

    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

  3. abstract def setShardLocations(locations: Map[ShardId, Address]): CompletionStage[Done]

    Update all of the provided ShardLocations.

    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.

    locations

    to update

    returns

    Confirmation that the update has been written to the local node