Package org.apache.pekko.http.scaladsl.settings

Class ClientConnectionSettings

java.lang.Object

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

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

Direct Known Subclasses:

ClientConnectionSettingsImpl

public abstract class ClientConnectionSettings
extends ClientConnectionSettings

Public API but not intended for subclassing

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ClientConnectionSettings.LogUnencryptedNetworkBytes$

Constructor Summary

Constructors

Constructor	Description
ClientConnectionSettings()

Method Summary

Modifier and Type	Method	Description
static ClientConnectionSettings	apply(com.typesafe.config.Config config)
static ClientConnectionSettings	apply(String configOverrides)
abstract scala.concurrent.duration.FiniteDuration	connectingTimeout()
abstract Http2ClientSettings	http2Settings()
abstract scala.concurrent.duration.Duration	idleTimeout()
abstract scala.Option<InetSocketAddress>	localAddress()
abstract scala.Option<Object>	logUnencryptedNetworkBytes()
ClientConnectionSettings	mapHttp2Settings(scala.Function1<Http2ClientSettings,Http2ClientSettings> f)
abstract ParserSettings	parserSettings()
abstract int	requestHeaderSizeHint()
abstract scala.collection.immutable.Seq<org.apache.pekko.io.Inet.SocketOption>	socketOptions()
abstract scala.concurrent.duration.FiniteDuration	streamCancellationDelay()
abstract ClientTransport	transport()	The underlying transport used to connect to hosts.
abstract scala.Option<User$minusAgent>	userAgentHeader()
abstract scala.Function0<Random>	websocketRandomFactory()
abstract WebSocketSettings	websocketSettings()
ClientConnectionSettings	withConnectingTimeout(scala.concurrent.duration.FiniteDuration newValue)
ClientConnectionSettings	withHttp2Settings(Http2ClientSettings newValue)
ClientConnectionSettings	withIdleTimeout(scala.concurrent.duration.Duration newValue)
ClientConnectionSettings	withLocalAddress(scala.Option<InetSocketAddress> newValue)
ClientConnectionSettings	withLocalAddressOverride(scala.Option<InetSocketAddress> overrideLocalAddressOption)	Returns a new instance with the given local address set if the given override is Some(address), otherwise return this instance unchanged.
ClientConnectionSettings	withLogUnencryptedNetworkBytes(scala.Option<Object> newValue)
ClientConnectionSettings	withParserSettings(ParserSettings newValue)
ClientConnectionSettings	withRequestHeaderSizeHint(int newValue)
ClientConnectionSettings	withSocketOptions(scala.collection.immutable.Seq<org.apache.pekko.io.Inet.SocketOption> newValue)
ClientConnectionSettings	withStreamCancellationDelay(scala.concurrent.duration.FiniteDuration newValue)
ClientConnectionSettings	withTransport(ClientTransport newTransport)
ClientConnectionSettings	withUserAgentHeader(scala.Option<User$minusAgent> newValue)
ClientConnectionSettings	withWebsocketRandomFactory(scala.Function0<Random> newValue)
ClientConnectionSettings	withWebsocketSettings(WebSocketSettings newValue)

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, withConnectingTimeout, withIdleTimeout, withLocalAddress, withLogUnencryptedNetworkBytes, withParserSettings, withSocketOptions, withStreamCancellationDelay, withTransport, withUserAgentHeader, withWebsocketRandomFactory, withWebsocketSettings

Methods inherited from class java.lang.Object

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

Constructor Details

ClientConnectionSettings

public ClientConnectionSettings()

Method Details

apply

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

apply

public static ClientConnectionSettings apply(String configOverrides)

userAgentHeader

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

connectingTimeout

public abstract scala.concurrent.duration.FiniteDuration connectingTimeout()

idleTimeout

public abstract scala.concurrent.duration.Duration idleTimeout()

requestHeaderSizeHint

public abstract int requestHeaderSizeHint()

websocketSettings

public abstract WebSocketSettings websocketSettings()

websocketRandomFactory

public abstract scala.Function0<Random> websocketRandomFactory()

socketOptions

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

parserSettings

public abstract ParserSettings parserSettings()

logUnencryptedNetworkBytes

public abstract scala.Option<Object> logUnencryptedNetworkBytes()

streamCancellationDelay

public abstract scala.concurrent.duration.FiniteDuration streamCancellationDelay()

localAddress

public abstract scala.Option<InetSocketAddress> localAddress()

http2Settings

public abstract Http2ClientSettings http2Settings()

transport

public abstract ClientTransport transport()

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

withConnectingTimeout

public ClientConnectionSettings withConnectingTimeout(scala.concurrent.duration.FiniteDuration newValue)

Specified by:

withConnectingTimeout in class ClientConnectionSettings

withIdleTimeout

public ClientConnectionSettings withIdleTimeout(scala.concurrent.duration.Duration newValue)

Specified by:

withIdleTimeout in class ClientConnectionSettings

withRequestHeaderSizeHint

public ClientConnectionSettings withRequestHeaderSizeHint(int newValue)

Specified by:

withRequestHeaderSizeHint in class ClientConnectionSettings

withStreamCancellationDelay

public ClientConnectionSettings withStreamCancellationDelay(scala.concurrent.duration.FiniteDuration newValue)

Specified by:

withStreamCancellationDelay in class ClientConnectionSettings

withWebsocketSettings

public ClientConnectionSettings withWebsocketSettings(WebSocketSettings newValue)

withWebsocketRandomFactory

public ClientConnectionSettings withWebsocketRandomFactory(scala.Function0<Random> newValue)

withUserAgentHeader

public ClientConnectionSettings withUserAgentHeader(scala.Option<User$minusAgent> newValue)

withLogUnencryptedNetworkBytes

public ClientConnectionSettings withLogUnencryptedNetworkBytes(scala.Option<Object> newValue)

withSocketOptions

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

withParserSettings

public ClientConnectionSettings withParserSettings(ParserSettings newValue)

withLocalAddress

public ClientConnectionSettings withLocalAddress(scala.Option<InetSocketAddress> newValue)

withHttp2Settings

public ClientConnectionSettings withHttp2Settings(Http2ClientSettings newValue)

withTransport

public ClientConnectionSettings withTransport(ClientTransport newTransport)

mapHttp2Settings

public ClientConnectionSettings mapHttp2Settings(scala.Function1<Http2ClientSettings,Http2ClientSettings> f)

withLocalAddressOverride

public ClientConnectionSettings withLocalAddressOverride(scala.Option<InetSocketAddress> overrideLocalAddressOption)

Returns a new instance with the given local address set if the given override is Some(address), otherwise return this instance unchanged.

Parameters:

overrideLocalAddressOption - (undocumented)

Returns:

(undocumented)