in management-cluster-bootstrap/src/main/scala/org/apache/pekko/management/cluster/bootstrap/ClusterBootstrapSettings.scala [109:156]
def getContactPointDiscoveryEffectiveName(system: ActorSystem): String = contactPointDiscovery.effectiveName(system)
/** Java API */
def getContactPointDiscoveryMethod: String = contactPointDiscovery.discoveryMethod
/** Java API */
def getContactPointDiscoveryStableMargin: java.time.Duration = contactPointDiscovery.stableMargin.asJava
/** Java API */
def getContactPointDiscoveryInterval: java.time.Duration = contactPointDiscovery.interval.asJava
/** Java API */
def getContactPointDiscoveryExponentialBackoffRandomFactor: Double =
contactPointDiscovery.exponentialBackoffRandomFactor
/** Java API */
def getContactPointDiscoveryExponentialBackoffMax: java.time.Duration =
contactPointDiscovery.exponentialBackoffMax.asJava
/** Java API */
def getContactPointDiscoveryRequiredContactPointsNr: Int = contactPointDiscovery.requiredContactPointsNr
/** Java API */
def getContactPointDiscoveryResolveTimeout: java.time.Duration = contactPointDiscovery.resolveTimeout.asJava
object contactPoint {
private val contactPointConfig = bootConfig.getConfig("contact-point")
val fallbackPort: Int =
contactPointConfig
.optDefinedValue("fallback-port")
.map(_.toInt)
.getOrElse(config.getInt("pekko.management.http.port"))
val filterOnFallbackPort: Boolean =
contactPointConfig.getBoolean("filter-on-fallback-port")
val probingFailureTimeout: FiniteDuration =
contactPointConfig.getDuration("probing-failure-timeout", TimeUnit.MILLISECONDS).millis
val probeInterval: FiniteDuration =
contactPointConfig.getDuration("probe-interval", TimeUnit.MILLISECONDS).millis
val probeIntervalJitter: Double =
contactPointConfig.getDouble("probe-interval-jitter")
val httpMaxSeedNodesToExpose: Int = 5
}