Package org.apache.pekko.cluster.routing
Interface ClusterRouterActor
public interface ClusterRouterActor
INTERNAL API
The router actor, subscribes to cluster events and
adjusts the routees.
-
Method Summary
Modifier and TypeMethodDescriptionvoidvoidAdds routees based on settingsscala.collection.immutable.SortedSet<Address>cluster()scala.PartialFunction<Object,scala.runtime.BoxedUnit> fullAddress(Routee routee) Fills in self address for local ActorRefbooleanscala.collection.immutable.SortedSet<Address>nodes()voidvoidpostStop()voidpreStart()voidremoveMember(Member member) booleansatisfiesRoles(scala.collection.immutable.Set<String> memberRoles) settings()
-
Method Details
-
addMember
-
addRoutees
void addRoutees()Adds routees based on settings -
availableNodes
scala.collection.immutable.SortedSet<Address> availableNodes() -
cluster
Cluster cluster() -
clusterReceive
scala.PartialFunction<Object,scala.runtime.BoxedUnit> clusterReceive() -
fullAddress
Fills in self address for local ActorRef -
isAvailable
-
nodes
scala.collection.immutable.SortedSet<Address> nodes() -
nodes_$eq
-
postStop
void postStop() -
preStart
void preStart() -
removeMember
-
satisfiesRoles
-
settings
ClusterRouterSettingsBase settings()
-