org.infinispan.client.hotrod.configuration

Class Configuration

java.lang.Object

org.infinispan.client.hotrod.configuration.Configuration

public class Configuration
extends Object

Configuration.

Since:

5.3

Author:

Tristan Tarrant

Constructor Summary

Constructors

Constructor and Description

Configuration(ExecutorFactoryConfiguration asyncExecutorFactory, Supplier<FailoverRequestBalancingStrategy> balancingStrategyFactory, ClassLoader classLoader, ClientIntelligence clientIntelligence, ConnectionPoolConfiguration connectionPool, int connectionTimeout, Class<? extends ConsistentHash>[] consistentHashImpl, boolean forceReturnValues, int keySizeEstimate, Marshaller marshaller, Class<? extends Marshaller> marshallerClass, ProtocolVersion protocolVersion, List<ServerConfiguration> servers, int socketTimeout, SecurityConfiguration security, boolean tcpNoDelay, boolean tcpKeepAlive, int valueSizeEstimate, int maxRetries, NearCacheConfiguration nearCache, List<ClusterConfiguration> clusters, List<String> serialWhitelist, int batchSize, TransactionConfiguration transaction, StatisticsConfiguration statistics, Features features, List<org.infinispan.protostream.SerializationContextInitializer> contextInitializers, Map<String,RemoteCacheConfiguration> remoteCaches)

Method Summary

Modifier and Type	Method and Description
RemoteCacheConfiguration	addRemoteCache(String name, Consumer<RemoteCacheConfigurationBuilder> builderConsumer) Create a new RemoteCacheConfiguration.
ExecutorFactoryConfiguration	asyncExecutorFactory()
Supplier<FailoverRequestBalancingStrategy>	balancingStrategyFactory()
int	batchSize()
ClassLoader	classLoader() Deprecated.
ClientIntelligence	clientIntelligence()
List<ClusterConfiguration>	clusters()
ConnectionPoolConfiguration	connectionPool()
int	connectionTimeout()
Class<? extends ConsistentHash>[]	consistentHashImpl()
Class<? extends ConsistentHash>	consistentHashImpl(int version)
Features	features()
boolean	forceReturnValues()
ClassWhiteList	getClassWhiteList()
List<org.infinispan.protostream.SerializationContextInitializer>	getContextInitializers()
int	keySizeEstimate()
Marshaller	marshaller()
Class<? extends Marshaller>	marshallerClass()
int	maxRetries()
NearCacheConfiguration	nearCache() Deprecated.
Properties	properties()
Map<String,RemoteCacheConfiguration>	remoteCaches()
void	removeRemoteCache(String name) Remove a RemoteCacheConfiguration from this Configuration.
SecurityConfiguration	security()
List<String>	serialWhitelist()
List<ServerConfiguration>	servers()
int	socketTimeout()
StatisticsConfiguration	statistics()
boolean	tcpKeepAlive()
boolean	tcpNoDelay()
String	toString()
TransactionConfiguration	transaction()
int	valueSizeEstimate()
ProtocolVersion	version()

Methods inherited from class java.lang.Object

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

Constructor Detail

Configuration

public Configuration(ExecutorFactoryConfiguration asyncExecutorFactory,
                     Supplier<FailoverRequestBalancingStrategy> balancingStrategyFactory,
                     ClassLoader classLoader,
                     ClientIntelligence clientIntelligence,
                     ConnectionPoolConfiguration connectionPool,
                     int connectionTimeout,
                     Class<? extends ConsistentHash>[] consistentHashImpl,
                     boolean forceReturnValues,
                     int keySizeEstimate,
                     Marshaller marshaller,
                     Class<? extends Marshaller> marshallerClass,
                     ProtocolVersion protocolVersion,
                     List<ServerConfiguration> servers,
                     int socketTimeout,
                     SecurityConfiguration security,
                     boolean tcpNoDelay,
                     boolean tcpKeepAlive,
                     int valueSizeEstimate,
                     int maxRetries,
                     NearCacheConfiguration nearCache,
                     List<ClusterConfiguration> clusters,
                     List<String> serialWhitelist,
                     int batchSize,
                     TransactionConfiguration transaction,
                     StatisticsConfiguration statistics,
                     Features features,
                     List<org.infinispan.protostream.SerializationContextInitializer> contextInitializers,
                     Map<String,RemoteCacheConfiguration> remoteCaches)

Method Detail

asyncExecutorFactory

public ExecutorFactoryConfiguration asyncExecutorFactory()

balancingStrategyFactory

public Supplier<FailoverRequestBalancingStrategy> balancingStrategyFactory()

classLoader

@Deprecated
public ClassLoader classLoader()

Deprecated.

clientIntelligence

public ClientIntelligence clientIntelligence()

connectionPool

public ConnectionPoolConfiguration connectionPool()

connectionTimeout

public int connectionTimeout()

consistentHashImpl

public Class<? extends ConsistentHash>[] consistentHashImpl()

consistentHashImpl

public Class<? extends ConsistentHash> consistentHashImpl(int version)

forceReturnValues

public boolean forceReturnValues()

keySizeEstimate

public int keySizeEstimate()

marshaller

public Marshaller marshaller()

marshallerClass

public Class<? extends Marshaller> marshallerClass()

nearCache

@Deprecated
public NearCacheConfiguration nearCache()

Deprecated.

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()

valueSizeEstimate

public int valueSizeEstimate()

maxRetries

public int maxRetries()

serialWhitelist

public List<String> serialWhitelist()

getClassWhiteList

public ClassWhiteList getClassWhiteList()

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()

transaction

public TransactionConfiguration transaction()

features

public Features features()

getContextInitializers

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

toString

public String toString()

Overrides:

toString in class Object

properties

public Properties properties()