Class ExternalShardAllocationStrategy

Inheritance
Object
ExternalShardAllocationStrategy
Implements
Inherited Members
Namespace: Akka.Cluster.Sharding.External
Assembly: Akka.Cluster.Sharding.dll
Syntax
public class ExternalShardAllocationStrategy : IStartableAllocationStrategy, IShardAllocationStrategy, INoSerializationVerificationNeeded

Constructors

| Improve this Doc View Source

ExternalShardAllocationStrategy(ActorSystem, String)

Declaration
public ExternalShardAllocationStrategy(ActorSystem system, string typeName)
Parameters
Type Name Description
ActorSystem system
String typeName

Properties

| Improve this Doc View Source

Timeout

Declaration
protected virtual TimeSpan Timeout { get; }
Property Value
Type Description
TimeSpan

Methods

| Improve this Doc View Source

AllocateShard(IActorRef, String, IImmutableDictionary<IActorRef, IImmutableList<String>>)

Declaration
public async Task<IActorRef> AllocateShard(IActorRef requester, string shardId, IImmutableDictionary<IActorRef, IImmutableList<string>> currentShardAllocations)
Parameters
Type Name Description
IActorRef requester
String shardId
System.Collections.Immutable.IImmutableDictionary<IActorRef, System.Collections.Immutable.IImmutableList<String>> currentShardAllocations
Returns
Type Description
Task<IActorRef>
| Improve this Doc View Source

CreateShardStateActor()

Declaration
protected virtual IActorRef CreateShardStateActor()
Returns
Type Description
IActorRef
| Improve this Doc View Source

Rebalance(IImmutableDictionary<IActorRef, IImmutableList<String>>, IImmutableSet<String>)

Declaration
public async Task<IImmutableSet<string>> Rebalance(IImmutableDictionary<IActorRef, IImmutableList<string>> currentShardAllocations, IImmutableSet<string> rebalanceInProgress)
Parameters
Type Name Description
System.Collections.Immutable.IImmutableDictionary<IActorRef, System.Collections.Immutable.IImmutableList<String>> currentShardAllocations
System.Collections.Immutable.IImmutableSet<String> rebalanceInProgress
Returns
Type Description
Task<System.Collections.Immutable.IImmutableSet<String>>
| Improve this Doc View Source

Start()

Declaration
public void Start()

Implements

Extension Methods