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

Class Http2ClientSettings.Http2ClientSettingsImpl

java.lang.Object

org.apache.pekko.http.scaladsl.settings.Http2ClientSettings.Http2ClientSettingsImpl

All Implemented Interfaces:

Serializable, Http2ClientSettings, Http2ClientSettings, Http2CommonSettings, scala.Equals, scala.Product

Enclosing interface:

Http2ClientSettings

public static class Http2ClientSettings.Http2ClientSettingsImpl
extends Object
implements Http2ClientSettings, Http2ClientSettings, scala.Product, Serializable

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.pekko.http.scaladsl.settings.Http2ClientSettings

Http2ClientSettings.Http2ClientSettingsImpl, Http2ClientSettings.Http2ClientSettingsImpl$

Constructor Summary

Constructors

Constructor

Description

Http2ClientSettingsImpl(int maxConcurrentStreams, int maxHeaderListSize, int maxFrameSize, int requestEntityChunkSize, int incomingConnectionLevelBufferSize, int incomingStreamLevelBufferSize, int outgoingControlFrameBufferSize, boolean logFrames, scala.concurrent.duration.FiniteDuration pingInterval, scala.concurrent.duration.FiniteDuration pingTimeout, int maxPersistentAttempts, scala.concurrent.duration.Duration persistentConnectionMaxAge, double persistentConnectionMaxAgeJitter, scala.concurrent.duration.FiniteDuration completionTimeout, scala.concurrent.duration.FiniteDuration baseConnectionBackoff, scala.concurrent.duration.FiniteDuration maxConnectionBackoff, scala.Option<Http2InternalClientSettings> internalSettings)

Method Summary

Modifier and Type	Method	Description
scala.concurrent.duration.FiniteDuration	baseConnectionBackoff()
scala.concurrent.duration.FiniteDuration	completionTimeout()
int	incomingConnectionLevelBufferSize()
int	incomingStreamLevelBufferSize()
scala.Option<Http2InternalClientSettings>	internalSettings()
boolean	logFrames()
int	maxConcurrentStreams()
scala.concurrent.duration.FiniteDuration	maxConnectionBackoff()
int	maxFrameSize()	The largest frame payload this endpoint accepts, in bytes.
int	maxHeaderListSize()	The maximum size of a decoded header list that this endpoint is prepared to accept, in bytes.
int	maxPersistentAttempts()
int	outgoingControlFrameBufferSize()
scala.concurrent.duration.Duration	persistentConnectionMaxAge()	The maximum age of a connection created by managedPersistentHttp2 or managedPersistentHttp2WithPriorKnowledge.
double	persistentConnectionMaxAgeJitter()	The jitter applied to Http2ClientSettings.persistentConnectionMaxAge() per connection, as a fraction of the configured age: with the default of 0.1 each connection is retired after between 90% and 110% of the configured age, so that connections that were opened together are not all retired at the same time. 0 disables jitter.
scala.concurrent.duration.FiniteDuration	pingInterval()
scala.concurrent.duration.FiniteDuration	pingTimeout()
int	requestEntityChunkSize()

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 org.apache.pekko.http.javadsl.settings.Http2ClientSettings

getBaseConnectionBackoff, getCompletionTimeout, getMaxConnectionBackoff, getMaxPersistentAttempts, getPersistentConnectionMaxAge, getPersistentConnectionMaxAgeJitter, getPingInterval, getPingTimeout, withBaseConnectionBackoff, withCompletionTimeout, withMaxConnectionBackoff, withPersistentConnectionMaxAge, withPingInterval, withPingTimeout

Methods inherited from interface org.apache.pekko.http.scaladsl.settings.Http2ClientSettings

minCollectStrictEntitySize, withBaseConnectionBackoff, withCompletionTimeout, withIncomingConnectionLevelBufferSize, withIncomingStreamLevelBufferSize, withInternalSettings, withLogFrames, withMaxConcurrentStreams, withMaxConnectionBackoff, withMaxFrameSize, withMaxHeaderListSize, withMaxPersistentAttempts, withOutgoingControlFrameBufferSize, withPersistentConnectionMaxAge, withPersistentConnectionMaxAgeJitter, withPingInterval, withPingTimeout, withRequestEntityChunkSize

Methods inherited from interface scala.Product

productArity, productElement, productElementName, productElementNames, productIterator, productPrefix

Constructor Details

Http2ClientSettingsImpl

public Http2ClientSettingsImpl(int maxConcurrentStreams,
 int maxHeaderListSize,
 int maxFrameSize,
 int requestEntityChunkSize,
 int incomingConnectionLevelBufferSize,
 int incomingStreamLevelBufferSize,
 int outgoingControlFrameBufferSize,
 boolean logFrames,
 scala.concurrent.duration.FiniteDuration pingInterval,
 scala.concurrent.duration.FiniteDuration pingTimeout,
 int maxPersistentAttempts,
 scala.concurrent.duration.Duration persistentConnectionMaxAge,
 double persistentConnectionMaxAgeJitter,
 scala.concurrent.duration.FiniteDuration completionTimeout,
 scala.concurrent.duration.FiniteDuration baseConnectionBackoff,
 scala.concurrent.duration.FiniteDuration maxConnectionBackoff,
 scala.Option<Http2InternalClientSettings> internalSettings)

Method Details

maxConcurrentStreams

public int maxConcurrentStreams()

Specified by:

maxConcurrentStreams in interface Http2ClientSettings

Specified by:

maxConcurrentStreams in interface Http2ClientSettings

Specified by:

maxConcurrentStreams in interface Http2CommonSettings

maxHeaderListSize

public int maxHeaderListSize()

Description copied from interface: Http2ClientSettings

The maximum size of a decoded header list that this endpoint is prepared to accept, in bytes. The value is advertised to the peer via SETTINGS_MAX_HEADER_LIST_SIZE and the same limit is applied to the accumulated header block fragments of a HEADERS frame and its CONTINUATION frames.

Specified by:

maxHeaderListSize in interface Http2ClientSettings

Specified by:

maxHeaderListSize in interface Http2ClientSettings

Specified by:

maxHeaderListSize in interface Http2CommonSettings

Returns:

(undocumented)

maxFrameSize

public int maxFrameSize()

Description copied from interface: Http2ClientSettings

The largest frame payload this endpoint accepts, in bytes. A larger incoming frame is rejected with a FRAME_SIZE_ERROR on its frame header, before the payload is buffered. No larger SETTINGS_MAX_FRAME_SIZE is advertised, so a peer that follows the spec keeps to the 16 KiB default and the extra room is leniency for peers that do not. RFC 9113, section 4.2 constrains it to be between 16 KiB and 16 MiB - 1.

Specified by:

maxFrameSize in interface Http2ClientSettings

Specified by:

maxFrameSize in interface Http2ClientSettings

Specified by:

maxFrameSize in interface Http2CommonSettings

Returns:

(undocumented)

requestEntityChunkSize

public int requestEntityChunkSize()

Specified by:

requestEntityChunkSize in interface Http2ClientSettings

Specified by:

requestEntityChunkSize in interface Http2ClientSettings

Specified by:

requestEntityChunkSize in interface Http2CommonSettings

incomingConnectionLevelBufferSize

public int incomingConnectionLevelBufferSize()

Specified by:

incomingConnectionLevelBufferSize in interface Http2ClientSettings

Specified by:

incomingConnectionLevelBufferSize in interface Http2ClientSettings

Specified by:

incomingConnectionLevelBufferSize in interface Http2CommonSettings

incomingStreamLevelBufferSize

public int incomingStreamLevelBufferSize()

Specified by:

incomingStreamLevelBufferSize in interface Http2ClientSettings

Specified by:

incomingStreamLevelBufferSize in interface Http2ClientSettings

Specified by:

incomingStreamLevelBufferSize in interface Http2CommonSettings

outgoingControlFrameBufferSize

public int outgoingControlFrameBufferSize()

Specified by:

outgoingControlFrameBufferSize in interface Http2ClientSettings

Specified by:

outgoingControlFrameBufferSize in interface Http2ClientSettings

Specified by:

outgoingControlFrameBufferSize in interface Http2CommonSettings

logFrames

public boolean logFrames()

Specified by:

logFrames in interface Http2ClientSettings

Specified by:

logFrames in interface Http2ClientSettings

Specified by:

logFrames in interface Http2CommonSettings

pingInterval

public scala.concurrent.duration.FiniteDuration pingInterval()

Specified by:

pingInterval in interface Http2ClientSettings

Specified by:

pingInterval in interface Http2CommonSettings

pingTimeout

public scala.concurrent.duration.FiniteDuration pingTimeout()

Specified by:

pingTimeout in interface Http2ClientSettings

Specified by:

pingTimeout in interface Http2CommonSettings

maxPersistentAttempts

public int maxPersistentAttempts()

Specified by:

maxPersistentAttempts in interface Http2ClientSettings

persistentConnectionMaxAge

public scala.concurrent.duration.Duration persistentConnectionMaxAge()

Description copied from interface: Http2ClientSettings

The maximum age of a connection created by managedPersistentHttp2 or managedPersistentHttp2WithPriorKnowledge. When the age of a connection exceeds this value, the connection stops accepting new requests, lets requests that are already in flight complete within Http2ClientSettings.completionTimeout(), and is then closed. Later requests are sent on a new connection. The value Duration.Inf disables this mechanism and is the default.

Specified by:

persistentConnectionMaxAge in interface Http2ClientSettings

Returns:

(undocumented)

persistentConnectionMaxAgeJitter

public double persistentConnectionMaxAgeJitter()

Description copied from interface: Http2ClientSettings

The jitter applied to Http2ClientSettings.persistentConnectionMaxAge() per connection, as a fraction of the configured age: with the default of 0.1 each connection is retired after between 90% and 110% of the configured age, so that connections that were opened together are not all retired at the same time. 0 disables jitter.

Specified by:

persistentConnectionMaxAgeJitter in interface Http2ClientSettings

Returns:

(undocumented)

completionTimeout

public scala.concurrent.duration.FiniteDuration completionTimeout()

Specified by:

completionTimeout in interface Http2ClientSettings

baseConnectionBackoff

public scala.concurrent.duration.FiniteDuration baseConnectionBackoff()

Specified by:

baseConnectionBackoff in interface Http2ClientSettings

maxConnectionBackoff

public scala.concurrent.duration.FiniteDuration maxConnectionBackoff()

Specified by:

maxConnectionBackoff in interface Http2ClientSettings

internalSettings

public scala.Option<Http2InternalClientSettings> internalSettings()

Specified by:

internalSettings in interface Http2ClientSettings