Package org.apache.pekko.http.impl.settings

Class ClientConnectionSettingsImpl

java.lang.Object

org.apache.pekko.http.javadsl.settings.ClientConnectionSettings

org.apache.pekko.http.scaladsl.settings.ClientConnectionSettings

org.apache.pekko.http.impl.settings.ClientConnectionSettingsImpl

All Implemented Interfaces:

Serializable, scala.Equals, scala.Product

public final class ClientConnectionSettingsImpl
extends ClientConnectionSettings
implements scala.Product, Serializable

INTERNAL API

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pekko.http.scaladsl.settings.ClientConnectionSettings

ClientConnectionSettings.LogUnencryptedNetworkBytes$

Constructor Summary

Constructors

Constructor

Description

ClientConnectionSettingsImpl(scala.Option<User$minusAgent> userAgentHeader, scala.concurrent.duration.FiniteDuration connectingTimeout, scala.concurrent.duration.Duration idleTimeout, int requestHeaderSizeHint, scala.Option<Object> logUnencryptedNetworkBytes, WebSocketSettings websocketSettings, scala.collection.immutable.Seq<org.apache.pekko.io.Inet.SocketOption> socketOptions, ParserSettings parserSettings, scala.concurrent.duration.FiniteDuration streamCancellationDelay, scala.Option<InetSocketAddress> localAddress, Http2ClientSettings http2Settings, ClientTransport transport)

Method Summary

Modifier and Type	Method	Description
static T	apply(com.typesafe.config.Config config)
static T	apply(String configOverrides)
static T	apply(org.apache.pekko.actor.ActorSystem system)
scala.concurrent.duration.FiniteDuration	connectingTimeout()
static ClientConnectionSettingsImpl	fromSubConfig(com.typesafe.config.Config root, com.typesafe.config.Config inner)
Http2ClientSettings	http2Settings()
scala.concurrent.duration.Duration	idleTimeout()
scala.Option<InetSocketAddress>	localAddress()
scala.Option<Object>	logUnencryptedNetworkBytes()
ParserSettings	parserSettings()
protected static String	prefix()
String	productPrefix()
int	requestHeaderSizeHint()
scala.collection.immutable.Seq<org.apache.pekko.io.Inet.SocketOption>	socketOptions()
scala.concurrent.duration.FiniteDuration	streamCancellationDelay()
ClientTransport	transport()	The underlying transport used to connect to hosts.
scala.Option<User$minusAgent>	userAgentHeader()
scala.Function0<Random>	websocketRandomFactory()
WebSocketSettings	websocketSettings()
ClientConnectionSettings	withConnectingTimeout(Duration newValue)	Java API
ClientConnectionSettings	withIdleTimeout(Duration newValue)	Java API
ClientConnectionSettings	withStreamCancellationDelay(Duration newValue)	Java API

Methods inherited from class org.apache.pekko.http.scaladsl.settings.ClientConnectionSettings

mapHttp2Settings, withConnectingTimeout, withHttp2Settings, withIdleTimeout, withLocalAddress, withLocalAddressOverride, withLogUnencryptedNetworkBytes, withParserSettings, withRequestHeaderSizeHint, withSocketOptions, withStreamCancellationDelay, withTransport, withUserAgentHeader, withWebsocketRandomFactory, withWebsocketSettings

Methods inherited from class org.apache.pekko.http.javadsl.settings.ClientConnectionSettings

create, create, create, getConnectingTimeout, getIdleTimeout, getLocalAddress, getLogUnencryptedNetworkBytes, getParserSettings, getRequestHeaderSizeHint, getSocketOptions, getStreamCancellationDelay, getTransport, getUserAgentHeader, getWebsocketRandomFactory, getWebsocketSettings, withLocalAddress, withLogUnencryptedNetworkBytes, withParserSettings, withSocketOptions, withTransport, withUserAgentHeader, withWebsocketRandomFactory, withWebsocketSettings

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface scala.Equals

canEqual, equals

Methods inherited from interface scala.Product

productArity, productElement, productElementName, productElementNames, productIterator

Constructor Details

ClientConnectionSettingsImpl

public ClientConnectionSettingsImpl(scala.Option<User$minusAgent> userAgentHeader,
 scala.concurrent.duration.FiniteDuration connectingTimeout,
 scala.concurrent.duration.Duration idleTimeout,
 int requestHeaderSizeHint,
 scala.Option<Object> logUnencryptedNetworkBytes,
 WebSocketSettings websocketSettings,
 scala.collection.immutable.Seq<org.apache.pekko.io.Inet.SocketOption> socketOptions,
 ParserSettings parserSettings,
 scala.concurrent.duration.FiniteDuration streamCancellationDelay,
 scala.Option<InetSocketAddress> localAddress,
 Http2ClientSettings http2Settings,
 ClientTransport transport)

Method Details

fromSubConfig

public static ClientConnectionSettingsImpl fromSubConfig(com.typesafe.config.Config root,
 com.typesafe.config.Config inner)

prefix

protected static String prefix()

apply

public static T apply(org.apache.pekko.actor.ActorSystem system)

apply

public static T apply(String configOverrides)

apply

public static T apply(com.typesafe.config.Config config)

userAgentHeader

public scala.Option<User$minusAgent> userAgentHeader()

Specified by:

userAgentHeader in class ClientConnectionSettings

connectingTimeout

public scala.concurrent.duration.FiniteDuration connectingTimeout()

Specified by:

connectingTimeout in class ClientConnectionSettings

idleTimeout

public scala.concurrent.duration.Duration idleTimeout()

Specified by:

idleTimeout in class ClientConnectionSettings

requestHeaderSizeHint

public int requestHeaderSizeHint()

Specified by:

requestHeaderSizeHint in class ClientConnectionSettings

logUnencryptedNetworkBytes

public scala.Option<Object> logUnencryptedNetworkBytes()

Specified by:

logUnencryptedNetworkBytes in class ClientConnectionSettings

websocketSettings

public WebSocketSettings websocketSettings()

Specified by:

websocketSettings in class ClientConnectionSettings

socketOptions

public scala.collection.immutable.Seq<org.apache.pekko.io.Inet.SocketOption> socketOptions()

Specified by:

socketOptions in class ClientConnectionSettings

parserSettings

public ParserSettings parserSettings()

Specified by:

parserSettings in class ClientConnectionSettings

streamCancellationDelay

public scala.concurrent.duration.FiniteDuration streamCancellationDelay()

Specified by:

streamCancellationDelay in class ClientConnectionSettings

localAddress

public scala.Option<InetSocketAddress> localAddress()

Specified by:

localAddress in class ClientConnectionSettings

http2Settings

public Http2ClientSettings http2Settings()

Specified by:

http2Settings in class ClientConnectionSettings

transport

public ClientTransport transport()

Description copied from class: ClientConnectionSettings

The underlying transport used to connect to hosts. By default ClientTransport.TCP is used.

Specified by:

transport in class ClientConnectionSettings

productPrefix

public String productPrefix()

Specified by:

productPrefix in interface scala.Product

withConnectingTimeout

public ClientConnectionSettings withConnectingTimeout(Duration newValue)

Description copied from class: ClientConnectionSettings

Java API

Specified by:

withConnectingTimeout in class ClientConnectionSettings

Parameters:

newValue - (undocumented)

Returns:

(undocumented)

withIdleTimeout

public ClientConnectionSettings withIdleTimeout(Duration newValue)

Description copied from class: ClientConnectionSettings

Java API

Specified by:

withIdleTimeout in class ClientConnectionSettings

Parameters:

newValue - (undocumented)

Returns:

(undocumented)

withStreamCancellationDelay

public ClientConnectionSettings withStreamCancellationDelay(Duration newValue)

Description copied from class: ClientConnectionSettings

Java API

Specified by:

withStreamCancellationDelay in class ClientConnectionSettings

Parameters:

newValue - (undocumented)

Returns:

(undocumented)

websocketRandomFactory

public scala.Function0<Random> websocketRandomFactory()

Specified by:

websocketRandomFactory in class ClientConnectionSettings