akka.contrib.pattern
Class ShardCoordinator.RebalanceWorker
java.lang.Object
akka.contrib.pattern.ShardCoordinator.RebalanceWorker
- All Implemented Interfaces:
- Actor
- Enclosing class:
- ShardCoordinator
public static class ShardCoordinator.RebalanceWorker
- extends java.lang.Object
- implements Actor
INTERNAL API. Rebalancing process is performed by this actor.
It sends ShardCoordinator.Internal$.BeginHandOff
to all ShardRegion
actors followed by
ShardCoordinator.Internal$.BeginHandOff
to the ShardRegion
responsible for the shard.
When the handoff is completed it sends RebalanceDone
to its
parent ShardCoordinator
. If the process takes longer than the
handOffTimeout
it also sends RebalanceDone
.
Method Summary |
void |
done(boolean ok)
|
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive()
This defines the initial actor behavior, it must return a partial function
with the actor logic. |
scala.collection.immutable.Set<ActorRef> |
remaining()
|
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
stoppingShard()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface akka.actor.Actor |
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, postStop, preRestart, preStart, self, sender, supervisorStrategy, unhandled |
ShardCoordinator.RebalanceWorker
public ShardCoordinator.RebalanceWorker(java.lang.String shard,
ActorRef from,
scala.concurrent.duration.FiniteDuration handOffTimeout,
scala.collection.immutable.Set<ActorRef> regions)
remaining
public scala.collection.immutable.Set<ActorRef> remaining()
receive
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
- Description copied from interface:
Actor
- This defines the initial actor behavior, it must return a partial function
with the actor logic.
- Specified by:
receive
in interface Actor
- Returns:
- (undocumented)
stoppingShard
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> stoppingShard()
done
public void done(boolean ok)