Class ShardCoordinator

    • Method Detail

      • props

        public static Props props​(java.lang.String typeName,
                                  ClusterShardingSettings settings,
                                  ShardCoordinator.ShardAllocationStrategy allocationStrategy,
                                  ActorRef replicator,
                                  int majorityMinCap)
        INTERNAL API Factory method for the Props of the ShardCoordinator actor with state based on ddata.
        Parameters:
        typeName - (undocumented)
        settings - (undocumented)
        allocationStrategy - (undocumented)
        replicator - (undocumented)
        majorityMinCap - (undocumented)
        Returns:
        (undocumented)
      • rebalanceWorkerProps

        public static Props rebalanceWorkerProps​(java.lang.String shard,
                                                 ActorRef from,
                                                 scala.concurrent.duration.FiniteDuration handOffTimeout,
                                                 scala.collection.immutable.Set<ActorRef> regions)
      • context

        public ActorContext context()
        Description copied from interface: Actor
        Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.

        WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

        ActorContext is the Scala API. getContext returns a AbstractActor.ActorContext, which is the Java API of the actor context.

        Specified by:
        context in interface Actor
        Returns:
        (undocumented)
      • self

        public final ActorRef self()
        Description copied from interface: Actor
        The 'self' field holds the ActorRef for this actor.

        Can be used to send messages to itself:
         self ! message
         
        Specified by:
        self in interface Actor
        Returns:
        (undocumented)
      • akka$actor$Actor$_setter_$self_$eq

        protected final void akka$actor$Actor$_setter_$self_$eq​(ActorRef x$1)
        Description copied from interface: Actor
        The 'self' field holds the ActorRef for this actor.

        Can be used to send messages to itself:
         self ! message
         
        Specified by:
        akka$actor$Actor$_setter_$self_$eq in interface Actor
        Parameters:
        x$1 - (undocumented)
      • cluster

        public Cluster cluster()
      • removalMargin

        public scala.concurrent.duration.FiniteDuration removalMargin()
      • minMembers

        public int minMembers()
      • allRegionsRegistered

        public boolean allRegionsRegistered()
      • allRegionsRegistered_$eq

        public void allRegionsRegistered_$eq​(boolean x$1)
      • state

        public akka.cluster.sharding.ShardCoordinator.Internal.State state()
      • state_$eq

        public void state_$eq​(akka.cluster.sharding.ShardCoordinator.Internal.State x$1)
      • rebalanceInProgress

        public scala.collection.immutable.Map<java.lang.String,​scala.collection.immutable.Set<ActorRef>> rebalanceInProgress()
      • rebalanceInProgress_$eq

        public void rebalanceInProgress_$eq​(scala.collection.immutable.Map<java.lang.String,​scala.collection.immutable.Set<ActorRef>> x$1)
      • unAckedHostShards

        public scala.collection.immutable.Map<java.lang.String,​Cancellable> unAckedHostShards()
      • unAckedHostShards_$eq

        public void unAckedHostShards_$eq​(scala.collection.immutable.Map<java.lang.String,​Cancellable> x$1)
      • gracefulShutdownInProgress

        public scala.collection.immutable.Set<ActorRef> gracefulShutdownInProgress()
      • gracefulShutdownInProgress_$eq

        public void gracefulShutdownInProgress_$eq​(scala.collection.immutable.Set<ActorRef> x$1)
      • aliveRegions

        public scala.collection.immutable.Set<ActorRef> aliveRegions()
      • aliveRegions_$eq

        public void aliveRegions_$eq​(scala.collection.immutable.Set<ActorRef> x$1)
      • regionTerminationInProgress

        public scala.collection.immutable.Set<ActorRef> regionTerminationInProgress()
      • regionTerminationInProgress_$eq

        public void regionTerminationInProgress_$eq​(scala.collection.immutable.Set<ActorRef> x$1)
      • postStop

        public void postStop()
        Description copied from interface: Actor
        User overridable callback.

        Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.
        Specified by:
        postStop in interface Actor
      • isMember

        public boolean isMember​(ActorRef region)
      • active

        public scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> active()
      • handleGetShardHome

        public boolean handleGetShardHome​(java.lang.String shard)
        Parameters:
        shard - (undocumented)
        Returns:
        true if the message could be handled without state update, i.e. the shard location was known or the request was deferred or ignored
      • receiveTerminated

        public scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receiveTerminated()
      • update

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

        public void watchStateActors()
      • stateInitialized

        public void stateInitialized()
      • hasAllRegionsRegistered

        public boolean hasAllRegionsRegistered()
      • regionTerminated

        public void regionTerminated​(ActorRef ref)
      • regionProxyTerminated

        public void regionProxyTerminated​(ActorRef ref)
      • shuttingDown

        public scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> shuttingDown()
      • sendHostShardMsg

        public void sendHostShardMsg​(java.lang.String shard,
                                     ActorRef region)
      • allocateShardHomesForRememberEntities

        public void allocateShardHomesForRememberEntities()
      • continueGetShardHome

        public void continueGetShardHome​(java.lang.String shard,
                                         ActorRef region,
                                         ActorRef getShardHomeSender)
      • continueRebalance

        public void continueRebalance​(scala.collection.immutable.Set<java.lang.String> shards)