Package akka.cluster.sharding.internal
Interface ClusterShardAllocationMixin
-
- All Known Implementing Classes:
ConsistentHashingShardAllocationStrategy
public interface ClusterShardAllocationMixinINTERNAL API
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static classClusterShardAllocationMixin.RegionEntrystatic classClusterShardAllocationMixin.RegionEntry$static classClusterShardAllocationMixin.ShardSuitabilityOrdering$
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description ClusterEvent.CurrentClusterStateclusterState()booleanisAGoodTimeToRebalance(scala.collection.Iterable<ClusterShardAllocationMixin.RegionEntry> regionEntries)scala.collection.Iterable<ClusterShardAllocationMixin.RegionEntry>regionEntriesFor(scala.collection.immutable.Map<ActorRef,scala.collection.immutable.IndexedSeq<java.lang.String>> currentShardAllocations)MemberselfMember()
-
-
-
Method Detail
-
clusterState
ClusterEvent.CurrentClusterState clusterState()
-
selfMember
Member selfMember()
-
isAGoodTimeToRebalance
boolean isAGoodTimeToRebalance(scala.collection.Iterable<ClusterShardAllocationMixin.RegionEntry> regionEntries)
-
regionEntriesFor
scala.collection.Iterable<ClusterShardAllocationMixin.RegionEntry> regionEntriesFor(scala.collection.immutable.Map<ActorRef,scala.collection.immutable.IndexedSeq<java.lang.String>> currentShardAllocations)
-
-