Packages

final class SeedNodesInformation extends AnyRef

Full information about discovered contact points and found seed nodes.

contactPoints contains all nodes that were returned from the discovery (e.g. DNS lookup).

seedNodesObservations contains the replies from those contact points when probing them with the HTTP call. It only contains entries for the contact points that actually replied, i.e. were reachable and running. Each such SeedNodesObservation entry has the seedNodes (Pekko Cluster addresses) that were returned from that contact point. That Set will be empty if the node replied but is not part of an existing cluster yet, i.e. it hasn't joined.

There are also some timestamps that can be interesting. Note that currentTime is passed in to facilitate calculation of durations.

contactPointsChangedAt is when the discovered contact points were last changed (e.g. via DNS lookup), e.g. 5 seconds ago means that subsequent lookup attempts (1 per second) after that were successful and returned the same set.

SeedNodesObservation.observedAt was when that reply was received from that contact point. The entry is removed if no reply was received within the probing-failure-timeout meaning that it is unreachable or not running.

Source
JoinDecider.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SeedNodesInformation
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new SeedNodesInformation(currentTime: LocalDateTime, contactPointsChangedAt: LocalDateTime, contactPoints: Set[ResolvedTarget], seedNodesObservations: Set[SeedNodesObservation])

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. def allSeedNodes: Set[Address]
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  7. val contactPoints: Set[ResolvedTarget]
  8. val contactPointsChangedAt: LocalDateTime
  9. val currentTime: LocalDateTime
  10. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  11. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  12. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  13. def getAllSeedNodes: Set[Address]

    Java API

  14. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  15. def getContactPoints: Set[ResolvedTarget]

    Java API

  16. def getSeedNodesObservations: Set[SeedNodesObservation]

    Java API

  17. def hasSeedNodes: Boolean
  18. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  19. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  20. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  21. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  22. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  23. val seedNodesObservations: Set[SeedNodesObservation]
  24. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  25. def toString(): String
    Definition Classes
    AnyRef → Any
  26. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  27. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  28. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped