Class DDataShardCoordinator

    • Method Detail

      • AllShardsKey

        public GSetKey<java.lang.String> AllShardsKey()
      • CoordinatorStateKey

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

        public void activate()
      • active

        public scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> active()
        Overrides:
        active in class ShardCoordinator
      • getAllShards

        public void getAllShards()
      • getCoordinatorState

        public void getCoordinatorState()
      • getShardHomeRequests

        public scala.collection.immutable.Set<scala.Tuple2<ActorRef,​akka.cluster.sharding.ShardCoordinator.Internal.GetShardHome>> getShardHomeRequests()
      • getShardHomeRequests_$eq

        public void getShardHomeRequests_$eq​(scala.collection.immutable.Set<scala.Tuple2<ActorRef,​akka.cluster.sharding.ShardCoordinator.Internal.GetShardHome>> x$1)
      • 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
        Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.
        Specified by:
        receive in interface Actor
        Returns:
        (undocumented)
      • sendAllShardsUpdate

        public void sendAllShardsUpdate​(java.lang.String newShard)
      • sendCoordinatorStateUpdate

        public void sendCoordinatorStateUpdate​(akka.cluster.sharding.ShardCoordinator.Internal.DomainEvent evt)
      • shards

        public scala.collection.immutable.Set<java.lang.String> shards()
      • shards_$eq

        public void shards_$eq​(scala.collection.immutable.Set<java.lang.String> x$1)
      • terminating

        public boolean terminating()
      • terminating_$eq

        public void terminating_$eq​(boolean x$1)
      • 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
      • waitingForState

        public scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> waitingForState​(scala.collection.immutable.Set<Key<ReplicatedData>> remainingKeys)
      • 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<E,​scala.runtime.BoxedUnit> afterUpdateCallback,
                                                                                                                                                                              scala.collection.immutable.Set<Key<ReplicatedData>> remainingKeys)