public interface TransportFactory
Transport
objects.Transport getTransport(Set<SocketAddress> failedServers, byte[] cacheName)
Transport getAddressTransport(SocketAddress server)
SocketAddress getSocketAddress(Object key, byte[] cacheName)
void releaseTransport(Transport transport)
void start(Codec codec, Configuration configuration, AtomicInteger topologyId, ClientListenerNotifier listenerNotifier)
void updateServers(Collection<SocketAddress> newServers, byte[] cacheName, boolean quiet)
void destroy()
CacheTopologyInfo getCacheTopologyInfo(byte[] cacheName)
@Deprecated void updateHashFunction(Map<SocketAddress,Set<Integer>> servers2Hash, int numKeyOwners, short hashFunctionVersion, int hashSpace, byte[] cacheName, AtomicInteger topologyId)
void updateHashFunction(SocketAddress[][] segmentOwners, int numSegments, short hashFunctionVersion, byte[] cacheName, AtomicInteger topologyId)
ConsistentHash getConsistentHash(byte[] cacheName)
ConsistentHashFactory getConsistentHashFactory()
Transport getTransport(Object key, Set<SocketAddress> failedServers, byte[] cacheName)
boolean isTcpNoDelay()
boolean isTcpKeepAlive()
int getMaxRetries()
int getSoTimeout()
int getConnectTimeout()
void invalidateTransport(SocketAddress serverAddress, Transport transport)
SSLContext getSSLContext()
void reset(byte[] cacheName)
AtomicInteger createTopologyId(byte[] cacheName)
int getTopologyId(byte[] cacheName)
TcpTransportFactory.ClusterSwitchStatus trySwitchCluster(String failedClusterName, byte[] cacheName)
Marshaller getMarshaller()
boolean switchToCluster(String clusterName)
String getCurrentClusterName()
int getTopologyAge()
Copyright © 2023 JBoss, a division of Red Hat. All rights reserved.