public class DDataShardCoordinator extends ShardCoordinator implements akka.actor.Stash
ClusterSharding extension
ShardCoordinator.AbstractShardAllocationStrategy, ShardCoordinator.Internal$, ShardCoordinator.LeastShardAllocationStrategy, ShardCoordinator.RebalanceWorker, ShardCoordinator.ShardAllocationStrategy
Constructor and Description |
---|
DDataShardCoordinator(java.lang.String typeName,
ClusterShardingSettings settings,
ShardCoordinator.ShardAllocationStrategy allocationStrategy,
akka.actor.ActorRef replicator) |
Modifier and Type | Method and Description |
---|---|
void |
activate() |
scala.Function1<akka.cluster.sharding.ShardCoordinator.Internal.DomainEvent,scala.runtime.BoxedUnit> |
afterUpdateCallback() |
<any> |
CoordinatorStateKey() |
void |
getState() |
akka.cluster.Cluster |
node() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive() |
void |
sendUpdate(akka.cluster.sharding.ShardCoordinator.Internal.DomainEvent evt) |
<E extends akka.cluster.sharding.ShardCoordinator.Internal.DomainEvent> |
update(E evt,
scala.Function1<E,scala.runtime.BoxedUnit> f) |
void |
updateSuccess(akka.cluster.sharding.ShardCoordinator.Internal.DomainEvent evt) |
scala.concurrent.duration.FiniteDuration |
updatingStateTimeout() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
waitingForState() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
waitingForStateInitialized() |
scala.concurrent.duration.FiniteDuration |
waitingForStateTimeout() |
<E extends akka.cluster.sharding.ShardCoordinator.Internal.DomainEvent> |
waitingForUpdate(E evt) |
active, aliveRegions, allocateShardHomes, cluster, continueGetShardHome, continueRebalance, gracefulShutdownInProgress, isMember, postStop, props, props, rebalanceInProgress, rebalanceTask, rebalanceWorkerProps, receiveTerminated, regionProxyTerminated, regionTerminated, regionTerminationInProgress, removalMargin, sendHostShardMsg, shuttingDown, state, stateInitialized, unAckedHostShards, watchStateActors
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, preStart, self, sender, supervisorStrategy, unhandled
akka$actor$StashSupport$_setter_$akka$actor$StashSupport$$capacity_$eq, akka$actor$StashSupport$_setter_$mailbox_$eq, akka$actor$StashSupport$$capacity, akka$actor$StashSupport$$theStash_$eq, akka$actor$StashSupport$$theStash, clearStash, context, mailbox, prepend, self, stash, unstash, unstashAll, unstashAll
public DDataShardCoordinator(java.lang.String typeName, ClusterShardingSettings settings, ShardCoordinator.ShardAllocationStrategy allocationStrategy, akka.actor.ActorRef replicator)
public scala.concurrent.duration.FiniteDuration waitingForStateTimeout()
public scala.concurrent.duration.FiniteDuration updatingStateTimeout()
public akka.cluster.Cluster node()
public <any> CoordinatorStateKey()
public scala.Function1<akka.cluster.sharding.ShardCoordinator.Internal.DomainEvent,scala.runtime.BoxedUnit> afterUpdateCallback()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
receive
in interface akka.actor.Actor
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> waitingForState()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> waitingForStateInitialized()
public <E extends akka.cluster.sharding.ShardCoordinator.Internal.DomainEvent> scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> waitingForUpdate(E evt)
public void activate()
public <E extends akka.cluster.sharding.ShardCoordinator.Internal.DomainEvent> void update(E evt, scala.Function1<E,scala.runtime.BoxedUnit> f)
update
in class ShardCoordinator
public void updateSuccess(akka.cluster.sharding.ShardCoordinator.Internal.DomainEvent evt)
public void getState()
public void sendUpdate(akka.cluster.sharding.ShardCoordinator.Internal.DomainEvent evt)