public final class ConnectionPoolSettingsImpl extends ConnectionPoolSettings implements scala.Product, java.io.Serializable
| Constructor and Description |
|---|
ConnectionPoolSettingsImpl(int maxConnections,
int minConnections,
int maxRetries,
int maxOpenRequests,
int pipeliningLimit,
scala.concurrent.duration.Duration maxConnectionLifetime,
scala.concurrent.duration.FiniteDuration baseConnectionBackoff,
scala.concurrent.duration.FiniteDuration maxConnectionBackoff,
scala.concurrent.duration.Duration idleTimeout,
scala.concurrent.duration.Duration keepAliveTimeout,
ClientConnectionSettings connectionSettings,
scala.concurrent.duration.Duration responseEntitySubscriptionTimeout,
scala.collection.immutable.Seq<scala.Tuple2<scala.util.matching.Regex,ConnectionPoolSettings>> hostOverrides) |
| Modifier and Type | Method and Description |
|---|---|
static T |
apply(org.apache.pekko.actor.ActorSystem system) |
static T |
apply(com.typesafe.config.Config config) |
static T |
apply(java.lang.String configOverrides) |
scala.concurrent.duration.FiniteDuration |
baseConnectionBackoff() |
ClientConnectionSettings |
connectionSettings() |
ConnectionPoolSettings |
copyDeep(scala.Function1<ConnectionPoolSettings,ConnectionPoolSettings> mapHostOverrides,
int maxConnections,
int minConnections,
int maxRetries,
int maxOpenRequests,
int pipeliningLimit,
scala.concurrent.duration.Duration maxConnectionLifetime,
scala.concurrent.duration.FiniteDuration baseConnectionBackoff,
scala.concurrent.duration.FiniteDuration maxConnectionBackoff,
scala.concurrent.duration.Duration idleTimeout,
scala.concurrent.duration.Duration keepAliveTimeout,
ClientConnectionSettings connectionSettings,
scala.concurrent.duration.Duration responseEntitySubscriptionTimeout)
INTERNAL API
|
static ConnectionPoolSettingsImpl |
fromSubConfig(com.typesafe.config.Config root,
com.typesafe.config.Config c) |
scala.collection.immutable.Seq<scala.Tuple2<scala.util.matching.Regex,ConnectionPoolSettings>> |
hostOverrides() |
static scala.util.matching.Regex |
hostRegex(java.lang.String pattern) |
scala.concurrent.duration.Duration |
idleTimeout() |
scala.concurrent.duration.Duration |
keepAliveTimeout() |
scala.concurrent.duration.FiniteDuration |
maxConnectionBackoff() |
scala.concurrent.duration.Duration |
maxConnectionLifetime() |
int |
maxConnections() |
int |
maxOpenRequests() |
int |
maxRetries() |
int |
minConnections() |
int |
pipeliningLimit() |
protected static java.lang.String |
prefix() |
java.lang.String |
productPrefix() |
scala.concurrent.duration.Duration |
responseEntitySubscriptionTimeout()
The time after which the pool will drop an entity automatically if it wasn't read or discarded
|
ConnectionPoolSettingsImpl |
withUpdatedConnectionSettings(scala.Function1<ClientConnectionSettings,ClientConnectionSettings> f) |
appendHostOverride, forHost, transport, withBaseConnectionBackoff, withConnectionSettings, withHostOverrides, withIdleTimeout, withKeepAliveTimeout, withMaxConnectionBackoff, withMaxConnectionLifetime, withMaxConnections, withMaxOpenRequests, withMaxRetries, withMinConnections, withPipeliningLimit, withResponseEntitySubscriptionTimeout, withTransportappendHostOverride, create, create, create, getBaseConnectionBackoff, getConnectionSettings, getIdleTimeout, getKeepAliveTimeout, getMaxConnectionBackoff, getMaxConnectionLifetime, getMaxConnections, getMaxOpenRequests, getMaxRetries, getMinConnections, getPipeliningLimit, getResponseEntitySubscriptionTimeout, withConnectionSettings, withHostOverrides, withTransportclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitpublic ConnectionPoolSettingsImpl(int maxConnections,
int minConnections,
int maxRetries,
int maxOpenRequests,
int pipeliningLimit,
scala.concurrent.duration.Duration maxConnectionLifetime,
scala.concurrent.duration.FiniteDuration baseConnectionBackoff,
scala.concurrent.duration.FiniteDuration maxConnectionBackoff,
scala.concurrent.duration.Duration idleTimeout,
scala.concurrent.duration.Duration keepAliveTimeout,
ClientConnectionSettings connectionSettings,
scala.concurrent.duration.Duration responseEntitySubscriptionTimeout,
scala.collection.immutable.Seq<scala.Tuple2<scala.util.matching.Regex,ConnectionPoolSettings>> hostOverrides)
public static ConnectionPoolSettingsImpl fromSubConfig(com.typesafe.config.Config root, com.typesafe.config.Config c)
public static scala.util.matching.Regex hostRegex(java.lang.String pattern)
protected static java.lang.String prefix()
public static T apply(org.apache.pekko.actor.ActorSystem system)
public static T apply(java.lang.String configOverrides)
public static T apply(com.typesafe.config.Config config)
public int maxConnections()
maxConnections in class ConnectionPoolSettingspublic int minConnections()
minConnections in class ConnectionPoolSettingspublic int maxRetries()
maxRetries in class ConnectionPoolSettingspublic int maxOpenRequests()
maxOpenRequests in class ConnectionPoolSettingspublic int pipeliningLimit()
pipeliningLimit in class ConnectionPoolSettingspublic scala.concurrent.duration.Duration maxConnectionLifetime()
maxConnectionLifetime in class ConnectionPoolSettingspublic scala.concurrent.duration.FiniteDuration baseConnectionBackoff()
baseConnectionBackoff in class ConnectionPoolSettingspublic scala.concurrent.duration.FiniteDuration maxConnectionBackoff()
maxConnectionBackoff in class ConnectionPoolSettingspublic scala.concurrent.duration.Duration idleTimeout()
idleTimeout in class ConnectionPoolSettingspublic scala.concurrent.duration.Duration keepAliveTimeout()
keepAliveTimeout in class ConnectionPoolSettingspublic ClientConnectionSettings connectionSettings()
connectionSettings in class ConnectionPoolSettingspublic scala.concurrent.duration.Duration responseEntitySubscriptionTimeout()
ConnectionPoolSettingsresponseEntitySubscriptionTimeout in class ConnectionPoolSettingspublic scala.collection.immutable.Seq<scala.Tuple2<scala.util.matching.Regex,ConnectionPoolSettings>> hostOverrides()
hostOverrides in class ConnectionPoolSettingspublic java.lang.String productPrefix()
productPrefix in interface scala.Productpublic ConnectionPoolSettingsImpl withUpdatedConnectionSettings(scala.Function1<ClientConnectionSettings,ClientConnectionSettings> f)
withUpdatedConnectionSettings in class ConnectionPoolSettingspublic ConnectionPoolSettings copyDeep(scala.Function1<ConnectionPoolSettings,ConnectionPoolSettings> mapHostOverrides, int maxConnections, int minConnections, int maxRetries, int maxOpenRequests, int pipeliningLimit, scala.concurrent.duration.Duration maxConnectionLifetime, scala.concurrent.duration.FiniteDuration baseConnectionBackoff, scala.concurrent.duration.FiniteDuration maxConnectionBackoff, scala.concurrent.duration.Duration idleTimeout, scala.concurrent.duration.Duration keepAliveTimeout, ClientConnectionSettings connectionSettings, scala.concurrent.duration.Duration responseEntitySubscriptionTimeout)