akka.cluster.sharding

Class DDataShardCoordinator

java.lang.Object

akka.cluster.sharding.ShardCoordinator

akka.cluster.sharding.DDataShardCoordinator

All Implemented Interfaces:

Actor, ActorLogging, Stash, StashSupport, UnrestrictedStash, RequiresMessageQueue<DequeBasedMessageQueueSemantics>

public class DDataShardCoordinator
extends ShardCoordinator
implements Stash

Singleton coordinator (with state based on ddata) that decides where to allocate shards.

See Also:

ClusterSharding extension

Nested Class Summary

Nested classes/interfaces inherited from class akka.cluster.sharding.ShardCoordinator

ShardCoordinator.AbstractShardAllocationStrategy, ShardCoordinator.Internal$, ShardCoordinator.LeastShardAllocationStrategy, ShardCoordinator.RebalanceWorker, ShardCoordinator.ShardAllocationStrategy

Nested classes/interfaces inherited from interface akka.actor.Actor

Actor.emptyBehavior$, Actor.ignoringBehavior$

Constructor Summary

Constructors

Constructor and Description
DDataShardCoordinator(java.lang.String typeName, ClusterShardingSettings settings, ShardCoordinator.ShardAllocationStrategy allocationStrategy, ActorRef replicator)

Method Summary

Modifier and Type	Method and Description
void	activate()
LWWRegisterKey<akka.cluster.sharding.ShardCoordinator.Internal.State>	CoordinatorStateKey()
void	getState()
akka.cluster.sharding.ShardCoordinator.Internal.State	initEmptyState()
DequeBasedMessageQueueSemantics	mailbox()
Cluster	node()
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.
void	sendUpdate(akka.cluster.sharding.ShardCoordinator.Internal.DomainEvent evt)
<E extends akka.cluster.sharding.ShardCoordinator.Internal.DomainEvent> void	update(E evt, scala.Function1<E,scala.runtime.BoxedUnit> f)
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> scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	waitingForUpdate(E evt, scala.Function1<akka.cluster.sharding.ShardCoordinator.Internal.DomainEvent,scala.runtime.BoxedUnit> afterUpdateCallback)

Methods inherited from class akka.cluster.sharding.ShardCoordinator

active, akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, akka$actor$ActorLogging$$_log_$eq, akka$actor$ActorLogging$$_log, aliveRegions, allocateShardHomesForRememberEntities, allRegionsRegistered, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, cluster, context, continueGetShardHome, continueRebalance, gracefulShutdownInProgress, hasAllRegionsRegistered, isMember, log, minMembers, postRestart, postStop, preRestart, preStart, props, props, rebalanceInProgress, rebalanceTask, rebalanceWorkerProps, receiveTerminated, regionProxyTerminated, regionTerminated, regionTerminationInProgress, removalMargin, self, sender, sendHostShardMsg, shuttingDown, state, stateInitialized, supervisorStrategy, unAckedHostShards, unhandled, watchStateActors

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.actor.UnrestrictedStash

postStop, preRestart

Methods inherited from interface akka.actor.Actor

aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, preStart, self, sender, supervisorStrategy, unhandled

Methods inherited from interface akka.actor.StashSupport

actorCell, clearStash, context, enqueueFirst, prepend, self, stash, unstash, unstashAll, unstashAll

Methods inherited from interface akka.actor.ActorLogging

log

Constructor Detail

DDataShardCoordinator

public DDataShardCoordinator(java.lang.String typeName,
                             ClusterShardingSettings settings,
                             ShardCoordinator.ShardAllocationStrategy allocationStrategy,
                             ActorRef replicator)

Method Detail

mailbox

public DequeBasedMessageQueueSemantics mailbox()

Specified by:

mailbox in interface StashSupport

waitingForStateTimeout

public scala.concurrent.duration.FiniteDuration waitingForStateTimeout()

updatingStateTimeout

public scala.concurrent.duration.FiniteDuration updatingStateTimeout()

node

public Cluster node()

CoordinatorStateKey

public LWWRegisterKey<akka.cluster.sharding.ShardCoordinator.Internal.State> CoordinatorStateKey()

initEmptyState

public akka.cluster.sharding.ShardCoordinator.Internal.State initEmptyState()

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

Specified by:

receive in class ShardCoordinator

Returns:

(undocumented)

waitingForState

public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> waitingForState()

waitingForStateInitialized

public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> waitingForStateInitialized()

waitingForUpdate

public <E extends akka.cluster.sharding.ShardCoordinator.Internal.DomainEvent> scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> waitingForUpdate(E evt,
                                                                                                                                                                scala.Function1<akka.cluster.sharding.ShardCoordinator.Internal.DomainEvent,scala.runtime.BoxedUnit> afterUpdateCallback)

activate

public void activate()

update

public <E extends akka.cluster.sharding.ShardCoordinator.Internal.DomainEvent> void update(E evt,
                                                                                           scala.Function1<E,scala.runtime.BoxedUnit> f)

Specified by:

update in class ShardCoordinator

getState

public void getState()

sendUpdate

public void sendUpdate(akka.cluster.sharding.ShardCoordinator.Internal.DomainEvent evt)