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 Detail

      • addMember

        void addMember​(Member member)

      • addRoutees

        void addRoutees()
        Adds routees based on settings

      • availableNodes

        scala.collection.immutable.SortedSet<Address> availableNodes()

      • clusterReceive

        scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> clusterReceive()

      • fullAddress

        Address fullAddress​(Routee routee)
        Fills in self address for local ActorRef

      • isAvailable

        boolean isAvailable​(Member m)

      • nodes

        scala.collection.immutable.SortedSet<Address> nodes()

      • nodes_$eq

        void nodes_$eq​(scala.collection.immutable.SortedSet<Address> x$1)

      • postStop

        void postStop()

      • preStart

        void preStart()

      • removeMember

        void removeMember​(Member member)

      • satisfiesRoles

        boolean satisfiesRoles​(scala.collection.immutable.Set<java.lang.String> memberRoles)