c

akka.management.cluster.bootstrap

LowestAddressJoinDecider

class LowestAddressJoinDecider extends SelfAwareJoinDecider

The decision of joining "self" is made by deterministically sorting the discovered services and picking the *lowest* address. Only the node with lowest address joins itself.

If any of the contact-points returns a list of seed nodes it joins the existing cluster immediately.

Joining "self" is only done when enough number of contact points have been discovered (required-contact-point-nr) and there have been no changes to the discovered contact points during the stable-margin.

There must also be seed node observations from all discovered contact points before joining "self".

Source
LowestAddressJoinDecider.scala
Linear Supertypes
SelfAwareJoinDecider, JoinDecider, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. LowestAddressJoinDecider
  2. SelfAwareJoinDecider
  3. JoinDecider
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new LowestAddressJoinDecider(system: ActorSystem, settings: ClusterBootstrapSettings)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate() @throws( ... )
  6. def contactPointString(contactPoint: (String, Int)): String

    Returns the current selfContactPoints as a String for logging, e.g.

    Returns the current selfContactPoints as a String for logging, e.g. [127.0.0.1:64714].

    Attributes
    protected
    Definition Classes
    SelfAwareJoinDecider
  7. def decide(info: SeedNodesInformation): Future[JoinDecision]

    Decide if and how to join based on the gathered SeedNodesInformation.

    Decide if and how to join based on the gathered SeedNodesInformation. The returned JoinDecision can be KeepProbing, JoinSelf or JoinOtherSeedNodes.

    Definition Classes
    LowestAddressJoinDecider → JoinDecider
  8. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  9. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  10. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  11. def hasEnoughContactPoints(info: SeedNodesInformation): Boolean

    May be overridden by subclass to decide if enough contact points have been discovered.

    May be overridden by subclass to decide if enough contact points have been discovered. info.contactPoints.size is the number of discovered (e.g. via DNS lookup) contact points and info.seedNodesObservations.size is the number that has been confirmed that they are reachable and running.

    Attributes
    protected
  12. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  13. def hostMatches(host: String, target: ResolvedTarget): Boolean

    Checks for both host name and IP address for discovery mechanisms that return both.

    Checks for both host name and IP address for discovery mechanisms that return both.

    Attributes
    protected
    Definition Classes
    SelfAwareJoinDecider
  14. def isConfirmedCommunicationWithAllContactPointsRequired(info: SeedNodesInformation): Boolean

    May be overridden by subclass to allow joining self even though some of the discovered contact points have not been confirmed (unreachable or not running).

    May be overridden by subclass to allow joining self even though some of the discovered contact points have not been confirmed (unreachable or not running). hasEnoughContactPoints and isPastStableMargin must still be fulfilled.

    Attributes
    protected
  15. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  16. def isPastStableMargin(info: SeedNodesInformation): Boolean

    May be overridden by subclass to decide if the set of discovered contact points is stable.

    May be overridden by subclass to decide if the set of discovered contact points is stable. info.contactPointsChangedAt was the time when the discovered contact points were changed last time. Subsequent lookup attempts after that returned the same contact points.

    Attributes
    protected
  17. def joinOtherSeedNodes(info: SeedNodesInformation): Set[Address]

    May be overridden by subclass to extract the nodes to use as seed nodes when joining existing cluster.

    May be overridden by subclass to extract the nodes to use as seed nodes when joining existing cluster. info.allSeedNodes contains all existing nodes. If the returned Set is empty it will continue probing.

    Attributes
    protected
  18. val log: LoggingAdapter
    Attributes
    protected
    Definition Classes
    SelfAwareJoinDecider
  19. def lowestAddressContactPoint(info: SeedNodesInformation): Option[ResolvedTarget]

    Contact point with the "lowest" contact point address, it is expected to join itself if no other cluster is found in the deployment.

    Contact point with the "lowest" contact point address, it is expected to join itself if no other cluster is found in the deployment.

    May be overridden by subclass for example if another sort order is desired.

    Attributes
    protected
  20. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  21. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  22. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  23. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  24. def toString(): String
    Definition Classes
    AnyRef → Any
  25. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  26. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  27. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @Deprecated @deprecated @throws( classOf[java.lang.Throwable] )
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

Inherited from SelfAwareJoinDecider

Inherited from JoinDecider

Inherited from AnyRef

Inherited from Any

Ungrouped