public class RedisClusterClient extends AbstractRedisClient
channels, clientOptions, closeableResources, connectionEvents, eventLoopGroup, eventLoopGroups, timeout, timer, unit
Constructor and Description |
---|
RedisClusterClient(List<RedisURI> initialUris)
Initialize the client with a list of cluster URI's.
|
RedisClusterClient(RedisURI initialUri)
Initialize the client with an initial cluster URI.
|
Modifier and Type | Method and Description |
---|---|
protected RedisAsyncConnectionImpl<String,String> |
connectAsyncImpl(SocketAddress socketAddress) |
RedisClusterConnection<String,String> |
connectCluster()
Open a new synchronous connection to the redis cluster that treats keys and values as UTF-8 strings.
|
<K,V> RedisClusterConnection<K,V> |
connectCluster(RedisCodec<K,V> codec)
Open a new synchronous connection to the redis server.
|
RedisClusterAsyncConnection<String,String> |
connectClusterAsync()
Creates a connection to the redis cluster.
|
<K,V> RedisClusterAsyncConnection<K,V> |
connectClusterAsync(RedisCodec<K,V> codec)
Creates a connection to the redis cluster.
|
protected RedisURI |
getFirstUri() |
protected Partitions |
getPartitions() |
protected void |
initializePartitions() |
protected Partitions |
loadPartitions()
Retrieve partitions.
|
protected <K,V> RedisAsyncConnectionImpl<K,V> |
newRedisAsyncConnectionImpl(RedisChannelWriter<K,V> channelWriter,
RedisCodec<K,V> codec,
long timeout,
TimeUnit unit)
Construct a new
RedisAsyncConnectionImpl . |
void |
reloadPartitions()
Reload partitions and re-initialize the distribution table.
|
addListener, channelType, connectAsyncImpl, connectionBuilder, getChannelCount, getOptions, getResourceCount, initializeChannel, removeListener, setDefaultTimeout, setOptions, shutdown, shutdown, syncHandler
public RedisClusterClient(RedisURI initialUri)
initialUri
- initial cluster URIpublic RedisClusterClient(List<RedisURI> initialUris)
initialUris
- list of initial cluster URIspublic RedisClusterConnection<String,String> connectCluster()
public <K,V> RedisClusterConnection<K,V> connectCluster(RedisCodec<K,V> codec)
codec
to encode/decode keys
and values.K
- Key type.V
- Value type.codec
- Use this codec to encode/decode keys and values.public RedisClusterAsyncConnection<String,String> connectClusterAsync()
public <K,V> RedisClusterAsyncConnection<K,V> connectClusterAsync(RedisCodec<K,V> codec)
K
- Key type.V
- Value type.codec
- Use this codec to encode/decode keys and values.protected RedisAsyncConnectionImpl<String,String> connectAsyncImpl(SocketAddress socketAddress)
public void reloadPartitions()
protected void initializePartitions()
protected Partitions getPartitions()
protected Partitions loadPartitions()
protected <K,V> RedisAsyncConnectionImpl<K,V> newRedisAsyncConnectionImpl(RedisChannelWriter<K,V> channelWriter, RedisCodec<K,V> codec, long timeout, TimeUnit unit)
RedisAsyncConnectionImpl
. Can be overridden in order to construct a subclass of
RedisAsyncConnectionImpl
K
- Key type.V
- Value type.channelWriter
- the channel writercodec
- the codec to usetimeout
- Timeout valueunit
- Timeout unitprotected RedisURI getFirstUri()
Copyright © 2015. All rights reserved.