Package org.apache.pekko.cluster.sharding.typed.internal

Class ShardedDaemonProcessCoordinator

java.lang.Object

org.apache.pekko.cluster.sharding.typed.internal.ShardedDaemonProcessCoordinator

public final class ShardedDaemonProcessCoordinator
extends Object

Rescaling workflow overview:

1. stop pinging workers 2. Write to ddata new size and revision, in progress/not complete 3. Stop shards for all workers via shard coordinator 4. Update ddata state, mark rescaling completed 5. start pinging workers again

If coordinator moved before completing it will re-trigger workflow from step 2 on start, worst case stopping all workers before starting them again.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	ShardedDaemonProcessCoordinator.GetNumberOfProcessesReply
static class	ShardedDaemonProcessCoordinator.GetNumberOfProcessesReply$
static interface	ShardedDaemonProcessCoordinator.InternalMessage

Constructor Summary

Constructors

Constructor	Description
ShardedDaemonProcessCoordinator()

Method Summary

Modifier and Type	Method	Description
static <T> Behavior<ShardedDaemonProcessCommand>	apply(ShardedDaemonProcessSettings settings, ClusterShardingSettings shardingSettings, int initialNumberOfProcesses, String daemonProcessName, ActorRef<ShardingEnvelope<T>> shardingRef)
Behavior<ShardedDaemonProcessCommand>	start()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ShardedDaemonProcessCoordinator

public ShardedDaemonProcessCoordinator()

Method Details

apply

public static <T>
Behavior<ShardedDaemonProcessCommand> apply(ShardedDaemonProcessSettings settings,
 ClusterShardingSettings shardingSettings,
 int initialNumberOfProcesses,
 String daemonProcessName,
 ActorRef<ShardingEnvelope<T>> shardingRef)

start

public Behavior<ShardedDaemonProcessCommand> start()