org.apache.flink.statefun.flink.core.nettyclient

Class NettyRequestReplySpec

java.lang.Object

org.apache.flink.statefun.flink.core.nettyclient.NettyRequestReplySpec

public final class NettyRequestReplySpec
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	NettyRequestReplySpec.Timeouts This is a copy of DefaultHttpRequestReplyClientSpec.Timeouts, to ease the migration from the DefaultHttpRequestReplyClientFactory.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CALL_TIMEOUT_PROPERTY
java.time.Duration	callTimeout
static java.lang.String	CLIENT_CERT_PROPERTY
static java.lang.String	CLIENT_KEY_PASSWORD_PROPERTY
static java.lang.String	CLIENT_KEY_PROPERTY
static java.lang.String	CONNECT_TIMEOUT_PROPERTY
static java.lang.String	CONNECTION_POOL_MAX_SIZE_PROPERTY
int	connectionPoolMaxSize
java.time.Duration	connectTimeout
static java.time.Duration	DEFAULT_CALL_TIMEOUT
static java.time.Duration	DEFAULT_CONNECT_TIMEOUT
static int	DEFAULT_CONNECTION_POOL_MAX_SIZE
static int	DEFAULT_MAX_REQUEST_OR_RESPONSE_SIZE_IN_BYTES
static java.time.Duration	DEFAULT_POOLED_CONNECTION_TTL
static java.lang.String	MAX_REQUEST_OR_RESPONSE_SIZE_IN_BYTES_PROPERTY
int	maxRequestOrResponseSizeInBytes
static java.lang.String	POOLED_CONNECTION_TTL_PROPERTY
java.time.Duration	pooledConnectionTTL
static java.lang.String	TIMEOUTS_PROPERTY
static java.lang.String	TRUST_CA_CERTS_PROPERTY

Constructor Summary

Constructors

Constructor and Description
NettyRequestReplySpec(java.time.Duration callTimeout, java.time.Duration connectTimeout, java.time.Duration pooledConnectionTTL, java.lang.Integer connectionPoolMaxSize, java.lang.Integer maxRequestOrResponseSizeInBytes, java.lang.String trustedCaCerts, java.lang.String clientCerts, java.lang.String clientKey, java.lang.String clientKeyPassword, NettyRequestReplySpec.Timeouts timeouts)

Method Summary

Modifier and Type	Method and Description
java.util.Optional<java.lang.String>	getClientCerts()
java.util.Optional<java.lang.String>	getClientKey()
java.util.Optional<java.lang.String>	getClientKeyPassword()
java.util.Optional<java.lang.String>	getTrustedCaCerts()

Methods inherited from class java.lang.Object

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

Field Detail

CALL_TIMEOUT_PROPERTY

public static final java.lang.String CALL_TIMEOUT_PROPERTY

See Also:

Constant Field Values

CONNECT_TIMEOUT_PROPERTY

public static final java.lang.String CONNECT_TIMEOUT_PROPERTY

See Also:

Constant Field Values

POOLED_CONNECTION_TTL_PROPERTY

public static final java.lang.String POOLED_CONNECTION_TTL_PROPERTY

See Also:

Constant Field Values

CONNECTION_POOL_MAX_SIZE_PROPERTY

public static final java.lang.String CONNECTION_POOL_MAX_SIZE_PROPERTY

See Also:

Constant Field Values

MAX_REQUEST_OR_RESPONSE_SIZE_IN_BYTES_PROPERTY

public static final java.lang.String MAX_REQUEST_OR_RESPONSE_SIZE_IN_BYTES_PROPERTY

See Also:

Constant Field Values

TRUST_CA_CERTS_PROPERTY

public static final java.lang.String TRUST_CA_CERTS_PROPERTY

See Also:

Constant Field Values

CLIENT_CERT_PROPERTY

public static final java.lang.String CLIENT_CERT_PROPERTY

See Also:

Constant Field Values

CLIENT_KEY_PROPERTY

public static final java.lang.String CLIENT_KEY_PROPERTY

See Also:

Constant Field Values

CLIENT_KEY_PASSWORD_PROPERTY

public static final java.lang.String CLIENT_KEY_PASSWORD_PROPERTY

See Also:

Constant Field Values

TIMEOUTS_PROPERTY

public static final java.lang.String TIMEOUTS_PROPERTY

See Also:

Constant Field Values

DEFAULT_CALL_TIMEOUT

@VisibleForTesting
public static final java.time.Duration DEFAULT_CALL_TIMEOUT

DEFAULT_CONNECT_TIMEOUT

@VisibleForTesting
public static final java.time.Duration DEFAULT_CONNECT_TIMEOUT

DEFAULT_POOLED_CONNECTION_TTL

@VisibleForTesting
public static final java.time.Duration DEFAULT_POOLED_CONNECTION_TTL

DEFAULT_CONNECTION_POOL_MAX_SIZE

@VisibleForTesting
public static final int DEFAULT_CONNECTION_POOL_MAX_SIZE

See Also:

Constant Field Values

DEFAULT_MAX_REQUEST_OR_RESPONSE_SIZE_IN_BYTES

@VisibleForTesting
public static final int DEFAULT_MAX_REQUEST_OR_RESPONSE_SIZE_IN_BYTES

See Also:

Constant Field Values

callTimeout

public final java.time.Duration callTimeout

connectTimeout

public final java.time.Duration connectTimeout

pooledConnectionTTL

public final java.time.Duration pooledConnectionTTL

connectionPoolMaxSize

public final int connectionPoolMaxSize

maxRequestOrResponseSizeInBytes

public final int maxRequestOrResponseSizeInBytes

Constructor Detail

NettyRequestReplySpec

public NettyRequestReplySpec(java.time.Duration callTimeout,
                             java.time.Duration connectTimeout,
                             java.time.Duration pooledConnectionTTL,
                             java.lang.Integer connectionPoolMaxSize,
                             java.lang.Integer maxRequestOrResponseSizeInBytes,
                             java.lang.String trustedCaCerts,
                             java.lang.String clientCerts,
                             java.lang.String clientKey,
                             java.lang.String clientKeyPassword,
                             NettyRequestReplySpec.Timeouts timeouts)

Method Detail

getTrustedCaCerts

public java.util.Optional<java.lang.String> getTrustedCaCerts()

getClientCerts

public java.util.Optional<java.lang.String> getClientCerts()

getClientKey

public java.util.Optional<java.lang.String> getClientKey()

getClientKeyPassword

public java.util.Optional<java.lang.String> getClientKeyPassword()