Class Configuration

java.lang.Object

org.infinispan.client.hotrod.configuration.Configuration

All Implemented Interfaces:

org.infinispan.api.configuration.Configuration

public class Configuration
extends Object
implements org.infinispan.api.configuration.Configuration

Configuration.

Since:

5.3

Author:

Tristan Tarrant

Constructor Summary

Constructors

Constructor

Description

Configuration(ExecutorFactoryConfiguration asyncExecutorFactory, Supplier<FailoverRequestBalancingStrategy> balancingStrategyFactory, ClassLoader classLoader, ClientIntelligence clientIntelligence, ConnectionPoolConfiguration connectionPool, int connectionTimeout, Class<? extends org.infinispan.client.hotrod.impl.consistenthash.ConsistentHash>[] consistentHashImpl, int dnsResolverMinTTL, int dnsResolverMaxTTL, int dnsResolverNegativeTTL, boolean forceReturnValues, Marshaller marshaller, Class<? extends Marshaller> marshallerClass, ProtocolVersion protocolVersion, List<ServerConfiguration> servers, int socketTimeout, SecurityConfiguration security, boolean tcpNoDelay, boolean tcpKeepAlive, int maxRetries, List<ClusterConfiguration> clusters, List<String> serialAllowList, int batchSize, long transactionTimeout, StatisticsConfiguration statistics, Features features, List<org.infinispan.protostream.SerializationContextInitializer> contextInitializers, Map<String, RemoteCacheConfiguration> remoteCaches, TransportFactory transportFactory, boolean tracingPropagationEnabled, RemoteCacheManagerMetricsRegistry metricRegistry, int serverFailureTimeout)

Method Summary

Modifier and Type	Method	Description
RemoteCacheConfiguration	addRemoteCache(String name, Consumer<RemoteCacheConfigurationBuilder> builderConsumer)	Create a new RemoteCacheConfiguration.
ExecutorFactoryConfiguration	asyncExecutorFactory()
Supplier<FailoverRequestBalancingStrategy>	balancingStrategyFactory()
int	batchSize()
ClassLoader	classLoader()	Deprecated, for removal: This API element is subject to removal in a future version.
ClientIntelligence	clientIntelligence()
List<ClusterConfiguration>	clusters()
ConnectionPoolConfiguration	connectionPool()
int	connectionTimeout()
Class<? extends org.infinispan.client.hotrod.impl.consistenthash.ConsistentHash>[]	consistentHashImpl()
Class<? extends org.infinispan.client.hotrod.impl.consistenthash.ConsistentHash>	consistentHashImpl(int version)
int	dnsResolverMaxTTL()
int	dnsResolverMinTTL()
int	dnsResolverNegativeTTL()
Features	features()
boolean	forceReturnValues()
ClassAllowList	getClassAllowList()
List<org.infinispan.protostream.SerializationContextInitializer>	getContextInitializers()
Marshaller	marshaller()
Class<? extends Marshaller>	marshallerClass()
int	maxRetries()
RemoteCacheManagerMetricsRegistry	metricRegistry()
Properties	properties()
Map<String, RemoteCacheConfiguration>	remoteCaches()
void	removeRemoteCache(String name)	Remove a RemoteCacheConfiguration from this Configuration.
SecurityConfiguration	security()
List<String>	serialAllowList()
int	serverFailureTimeout()	Controls how long a server is marked as failed in milliseconds.
List<ServerConfiguration>	servers()
int	socketTimeout()
StatisticsConfiguration	statistics()
boolean	tcpKeepAlive()
boolean	tcpNoDelay()
String	toString()
boolean	tracingPropagationEnabled()	OpenTelemetry tracing propagation will be activated if this property is true and if the OpenTelemetry API jar is detected on the classpath.
long	transactionTimeout()	see ConfigurationBuilder.transactionTimeout(long, TimeUnit),
TransportFactory	transportFactory()
ProtocolVersion	version()

Methods inherited from class Object

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

Constructor Details

Configuration

public Configuration(ExecutorFactoryConfiguration asyncExecutorFactory,
 Supplier<FailoverRequestBalancingStrategy> balancingStrategyFactory,
 ClassLoader classLoader,
 ClientIntelligence clientIntelligence,
 ConnectionPoolConfiguration connectionPool,
 int connectionTimeout,
 Class<? extends org.infinispan.client.hotrod.impl.consistenthash.ConsistentHash>[] consistentHashImpl,
 int dnsResolverMinTTL,
 int dnsResolverMaxTTL,
 int dnsResolverNegativeTTL,
 boolean forceReturnValues,
 Marshaller marshaller,
 Class<? extends Marshaller> marshallerClass,
 ProtocolVersion protocolVersion,
 List<ServerConfiguration> servers,
 int socketTimeout,
 SecurityConfiguration security,
 boolean tcpNoDelay,
 boolean tcpKeepAlive,
 int maxRetries,
 List<ClusterConfiguration> clusters,
 List<String> serialAllowList,
 int batchSize,
 long transactionTimeout,
 StatisticsConfiguration statistics,
 Features features,
 List<org.infinispan.protostream.SerializationContextInitializer> contextInitializers,
 Map<String, RemoteCacheConfiguration> remoteCaches,
 TransportFactory transportFactory,
 boolean tracingPropagationEnabled,
 RemoteCacheManagerMetricsRegistry metricRegistry,
 int serverFailureTimeout)

Method Details

asyncExecutorFactory

public ExecutorFactoryConfiguration asyncExecutorFactory()

balancingStrategyFactory

public Supplier<FailoverRequestBalancingStrategy> balancingStrategyFactory()

classLoader

@Deprecated(forRemoval=true)
public ClassLoader classLoader()

Deprecated, for removal: This API element is subject to removal in a future version.

clientIntelligence

public ClientIntelligence clientIntelligence()

connectionPool

public ConnectionPoolConfiguration connectionPool()

connectionTimeout

public int connectionTimeout()

consistentHashImpl

public Class<? extends org.infinispan.client.hotrod.impl.consistenthash.ConsistentHash>[] consistentHashImpl()

consistentHashImpl

public Class<? extends org.infinispan.client.hotrod.impl.consistenthash.ConsistentHash> consistentHashImpl(int version)

dnsResolverMinTTL

public int dnsResolverMinTTL()

dnsResolverMaxTTL

public int dnsResolverMaxTTL()

dnsResolverNegativeTTL

public int dnsResolverNegativeTTL()

forceReturnValues

public boolean forceReturnValues()

marshaller

public Marshaller marshaller()

marshallerClass

public Class<? extends Marshaller> marshallerClass()

version

public ProtocolVersion version()

servers

public List<ServerConfiguration> servers()

clusters

public List<ClusterConfiguration> clusters()

socketTimeout

public int socketTimeout()

security

public SecurityConfiguration security()

tcpNoDelay

public boolean tcpNoDelay()

tcpKeepAlive

public boolean tcpKeepAlive()

maxRetries

public int maxRetries()

serialAllowList

public List<String> serialAllowList()

getClassAllowList

public ClassAllowList getClassAllowList()

batchSize

public int batchSize()

remoteCaches

public Map<String, RemoteCacheConfiguration> remoteCaches()

addRemoteCache

public RemoteCacheConfiguration addRemoteCache(String name,
 Consumer<RemoteCacheConfigurationBuilder> builderConsumer)

Create a new RemoteCacheConfiguration. This can be used to create additional configurations after a RemoteCacheManager has been initialized.

Parameters:

name - the name of the cache configuration to create

builderConsumer - a Consumer which receives a RemoteCacheConfigurationBuilder and can apply the necessary configurations on it.

Returns:

the RemoteCacheConfiguration

Throws:

IllegalArgumentException - if a cache configuration with the same name already exists

removeRemoteCache

public void removeRemoteCache(String name)

Remove a RemoteCacheConfiguration from this Configuration. If the cache configuration doesn't exist, this method has no effect.

Parameters:

name - the name of the RemoteCacheConfiguration to remove.

statistics

public StatisticsConfiguration statistics()

transactionTimeout

public long transactionTimeout()

see ConfigurationBuilder.transactionTimeout(long, TimeUnit),

features

public Features features()

getContextInitializers

public List<org.infinispan.protostream.SerializationContextInitializer> getContextInitializers()

transportFactory

public TransportFactory transportFactory()

tracingPropagationEnabled

public boolean tracingPropagationEnabled()

OpenTelemetry tracing propagation will be activated if this property is true and if the OpenTelemetry API jar is detected on the classpath. By default, the property is true.

Returns:

if the tracing propagation is enabled

metricRegistry

public RemoteCacheManagerMetricsRegistry metricRegistry()

Returns:

The RemoteCacheManagerMetricsRegistry implementation to use for metrics.

serverFailureTimeout

public int serverFailureTimeout()

Controls how long a server is marked as failed in milliseconds. Default is 30_000 milliseconds or 30 seconds.

Returns:

time in milliseconds

toString

public String toString()

Overrides:

toString in class Object

properties

public Properties properties()