Interface IExternalShardAllocationClient

API May Change Not for user extension

Namespace: Akka.Cluster.Sharding.External
Assembly: Akka.Cluster.Sharding.dll
Syntax
public interface IExternalShardAllocationClient

Methods

| Improve this Doc View Source

ShardLocations()

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

Declaration
Task<ShardLocations> ShardLocations()
Returns
Type Description
Task<ShardLocations>
| Improve this Doc View Source

UpdateShardLocation(String, Address)

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 it does.

Declaration
Task<Done> UpdateShardLocation(string shard, Address location)
Parameters
Type Name Description
String shard

The shard identifier
Address location

Location (akka node) to allocate the shard to
Returns
Type Description
Task<Done>

Confirmation that the update has been propagated to a majority of cluster nodes
| Improve this Doc View Source

UpdateShardLocations(IImmutableDictionary<String, Address>)

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.

Declaration
Task<Done> UpdateShardLocations(IImmutableDictionary<string, Address> locations)
Parameters
Type Name Description
System.Collections.Immutable.IImmutableDictionary<String, Address> locations

to update
Returns
Type Description
Task<Done>

Confirmation that the update has been propagates to a majority of cluster nodes

Extension Methods