public abstract class ConnectionPoolSettings extends ConnectionPoolSettings
Constructor and Description |
---|
ConnectionPoolSettings() |
Modifier and Type | Method and Description |
---|---|
ConnectionPoolSettings |
appendHostOverride(java.lang.String hostPattern,
ConnectionPoolSettings settings) |
static ConnectionPoolSettingsImpl |
apply(com.typesafe.config.Config config) |
static ConnectionPoolSettingsImpl |
apply(java.lang.String configOverrides) |
abstract scala.concurrent.duration.FiniteDuration |
baseConnectionBackoff() |
abstract ClientConnectionSettings |
connectionSettings() |
ConnectionPoolSettings |
forHost(java.lang.String host)
This checks to see if there's a matching host override.
|
abstract scala.collection.immutable.Seq<scala.Tuple2<scala.util.matching.Regex,ConnectionPoolSettings>> |
hostOverrides() |
abstract scala.concurrent.duration.Duration |
idleTimeout() |
abstract scala.concurrent.duration.Duration |
keepAliveTimeout() |
abstract scala.concurrent.duration.FiniteDuration |
maxConnectionBackoff() |
abstract scala.concurrent.duration.Duration |
maxConnectionLifetime() |
abstract int |
maxConnections() |
abstract int |
maxOpenRequests() |
abstract int |
maxRetries() |
abstract int |
minConnections() |
abstract int |
pipeliningLimit() |
abstract scala.concurrent.duration.Duration |
responseEntitySubscriptionTimeout()
The time after which the pool will drop an entity automatically if it wasn't read or discarded
|
ClientTransport |
transport()
Deprecated.
Deprecated in favor of connectionSettings.transport. Since Akka HTTP 10.1.0.
|
ConnectionPoolSettings |
withBaseConnectionBackoff(scala.concurrent.duration.FiniteDuration newValue) |
ConnectionPoolSettings |
withConnectionSettings(ClientConnectionSettings newValue) |
ConnectionPoolSettings |
withHostOverrides(scala.collection.immutable.Seq<scala.Tuple2<java.lang.String,ConnectionPoolSettings>> hostOverrides) |
ConnectionPoolSettings |
withIdleTimeout(scala.concurrent.duration.Duration newValue) |
ConnectionPoolSettings |
withKeepAliveTimeout(scala.concurrent.duration.Duration newValue) |
ConnectionPoolSettings |
withMaxConnectionBackoff(scala.concurrent.duration.FiniteDuration newValue) |
ConnectionPoolSettings |
withMaxConnectionLifetime(scala.concurrent.duration.Duration newValue) |
ConnectionPoolSettings |
withMaxConnections(int n) |
ConnectionPoolSettings |
withMaxOpenRequests(int newValue) |
ConnectionPoolSettings |
withMaxRetries(int n) |
ConnectionPoolSettings |
withMinConnections(int n) |
ConnectionPoolSettings |
withPipeliningLimit(int newValue)
Client-side pipelining is not currently supported, see https://github.com/akka/akka-http/issues/32
|
ConnectionPoolSettings |
withResponseEntitySubscriptionTimeout(scala.concurrent.duration.Duration newValue) |
ConnectionPoolSettings |
withTransport(ClientTransport newValue)
Since Akka HTTP 10.1.0, the transport is configured in
ClientConnectionSettings . |
abstract ConnectionPoolSettings |
withUpdatedConnectionSettings(scala.Function1<ClientConnectionSettings,ClientConnectionSettings> f) |
appendHostOverride, create, create, create, getBaseConnectionBackoff, getConnectionSettings, getIdleTimeout, getKeepAliveTimeout, getMaxConnectionBackoff, getMaxConnectionLifetime, getMaxConnections, getMaxOpenRequests, getMaxRetries, getMinConnections, getPipeliningLimit, getResponseEntitySubscriptionTimeout, withConnectionSettings, withHostOverrides, withTransport
public static ConnectionPoolSettingsImpl apply(com.typesafe.config.Config config)
public static ConnectionPoolSettingsImpl apply(java.lang.String configOverrides)
public abstract int maxConnections()
public abstract int minConnections()
public abstract int maxRetries()
public abstract int maxOpenRequests()
public abstract int pipeliningLimit()
public abstract scala.concurrent.duration.FiniteDuration baseConnectionBackoff()
public abstract scala.concurrent.duration.FiniteDuration maxConnectionBackoff()
public abstract scala.concurrent.duration.Duration idleTimeout()
public abstract scala.concurrent.duration.Duration keepAliveTimeout()
public abstract ClientConnectionSettings connectionSettings()
public abstract scala.concurrent.duration.Duration maxConnectionLifetime()
public abstract scala.collection.immutable.Seq<scala.Tuple2<scala.util.matching.Regex,ConnectionPoolSettings>> hostOverrides()
public ConnectionPoolSettings forHost(java.lang.String host)
host
- (undocumented)public ClientTransport transport()
ClientTransport.TCP
is used.public abstract scala.concurrent.duration.Duration responseEntitySubscriptionTimeout()
public ConnectionPoolSettings withHostOverrides(scala.collection.immutable.Seq<scala.Tuple2<java.lang.String,ConnectionPoolSettings>> hostOverrides)
public ConnectionPoolSettings appendHostOverride(java.lang.String hostPattern, ConnectionPoolSettings settings)
public ConnectionPoolSettings withMaxConnections(int n)
withMaxConnections
in class ConnectionPoolSettings
public ConnectionPoolSettings withMinConnections(int n)
withMinConnections
in class ConnectionPoolSettings
public ConnectionPoolSettings withMaxRetries(int n)
withMaxRetries
in class ConnectionPoolSettings
public ConnectionPoolSettings withMaxOpenRequests(int newValue)
withMaxOpenRequests
in class ConnectionPoolSettings
public ConnectionPoolSettings withBaseConnectionBackoff(scala.concurrent.duration.FiniteDuration newValue)
withBaseConnectionBackoff
in class ConnectionPoolSettings
public ConnectionPoolSettings withMaxConnectionBackoff(scala.concurrent.duration.FiniteDuration newValue)
withMaxConnectionBackoff
in class ConnectionPoolSettings
public ConnectionPoolSettings withPipeliningLimit(int newValue)
ConnectionPoolSettings
withPipeliningLimit
in class ConnectionPoolSettings
public ConnectionPoolSettings withIdleTimeout(scala.concurrent.duration.Duration newValue)
withIdleTimeout
in class ConnectionPoolSettings
public ConnectionPoolSettings withKeepAliveTimeout(scala.concurrent.duration.Duration newValue)
withKeepAliveTimeout
in class ConnectionPoolSettings
public ConnectionPoolSettings withMaxConnectionLifetime(scala.concurrent.duration.Duration newValue)
withMaxConnectionLifetime
in class ConnectionPoolSettings
public ConnectionPoolSettings withConnectionSettings(ClientConnectionSettings newValue)
public ConnectionPoolSettings withResponseEntitySubscriptionTimeout(scala.concurrent.duration.Duration newValue)
withResponseEntitySubscriptionTimeout
in class ConnectionPoolSettings
public ConnectionPoolSettings withTransport(ClientTransport newValue)
ClientConnectionSettings
. This method is a shortcut for
withUpdatedConnectionSettings(_.withTransport(newTransport))
.newValue
- (undocumented)public abstract ConnectionPoolSettings withUpdatedConnectionSettings(scala.Function1<ClientConnectionSettings,ClientConnectionSettings> f)