Package | Description |
---|---|
com.lambdaworks.redis |
The redis client package containing
RedisClient for regular and sentinel operations. |
com.lambdaworks.redis.cluster |
Client for redis clusters
RedisClusterClient . |
com.lambdaworks.redis.cluster.models.partitions |
Model and parser for the
CLUSTER NODES and CLUSTER SLAVES output. |
com.lambdaworks.redis.masterslave | |
com.lambdaworks.redis.models.role |
Model and parser for the
ROLE output. |
com.lambdaworks.redis.support |
Supportive classes such as
RedisClientCdiBean for CDI support, RedisClientFactoryBean for Spring. |
Modifier and Type | Method and Description |
---|---|
RedisURI |
RedisURI.Builder.build() |
static RedisURI |
RedisURI.create(String uri)
Create a Redis URI from an URI string.
|
static RedisURI |
RedisURI.create(String host,
int port)
Create a Redis URI from host and port.
|
static RedisURI |
RedisURI.create(URI uri)
Create a Redis URI from an URI string:
The uri must follow conventions of
URI |
Modifier and Type | Method and Description |
---|---|
List<RedisURI> |
RedisURI.getSentinels() |
Modifier and Type | Method and Description |
---|---|
<K,V> StatefulRedisConnection<K,V> |
RedisClient.connect(RedisCodec<K,V> codec,
RedisURI redisURI)
|
StatefulRedisConnection<String,String> |
RedisClient.connect(RedisURI redisURI)
Open a new connection to a Redis server using the supplied
RedisURI that treats keys and values as UTF-8 strings. |
<K,V> RedisAsyncCommands<K,V> |
RedisClient.connectAsync(RedisCodec<K,V> codec,
RedisURI redisURI)
Deprecated.
Use
connect(codec, redisURI).async() |
RedisAsyncCommands<String,String> |
RedisClient.connectAsync(RedisURI redisURI)
Deprecated.
Use
connect(redisURI).async() |
protected void |
AbstractRedisClient.connectionBuilder(CommandHandler<?,?> handler,
RedisChannelHandler<?,?> connection,
Supplier<SocketAddress> socketAddressSupplier,
ConnectionBuilder connectionBuilder,
RedisURI redisURI)
Populate connection builder with necessary resources.
|
<K,V> StatefulRedisPubSubConnection<K,V> |
RedisClient.connectPubSub(RedisCodec<K,V> codec,
RedisURI redisURI)
|
StatefulRedisPubSubConnection<String,String> |
RedisClient.connectPubSub(RedisURI redisURI)
Open a new pub/sub connection to a Redis server using the supplied
RedisURI that treats keys and values as UTF-8
strings. |
<K,V> StatefulRedisSentinelConnection<K,V> |
RedisClient.connectSentinel(RedisCodec<K,V> codec,
RedisURI redisURI)
|
StatefulRedisSentinelConnection<String,String> |
RedisClient.connectSentinel(RedisURI redisURI)
Open a connection to a Redis Sentinel using the supplied
RedisURI that treats keys and values as UTF-8 strings. |
<K,V> RedisSentinelAsyncCommands<K,V> |
RedisClient.connectSentinelAsync(RedisCodec<K,V> codec,
RedisURI redisURI)
Deprecated.
Use
connectSentinel(codec, redisURI).async() |
RedisSentinelAsyncCommands<String,String> |
RedisClient.connectSentinelAsync(RedisURI redisURI)
Deprecated.
Use
connectSentinel(redisURI).async() |
static RedisClient |
RedisClient.create(ClientResources clientResources,
RedisURI redisURI)
Create a new client that connects to the supplied
uri with shared ClientResources . |
static RedisClient |
RedisClient.create(RedisURI redisURI)
Create a new client that connects to the supplied
uri with default ClientResources . |
protected SocketAddress |
RedisClient.getSocketAddress(RedisURI redisURI) |
SslConnectionBuilder |
SslConnectionBuilder.ssl(RedisURI redisURI) |
Constructor and Description |
---|
RedisClient(ClientResources clientResources,
RedisURI redisURI) |
RedisClient(RedisURI redisURI)
Deprecated.
Use the factory method
RedisClient.create(RedisURI) |
Modifier and Type | Method and Description |
---|---|
protected RedisURI |
RedisClusterClient.getFirstUri() |
Modifier and Type | Method and Description |
---|---|
static RedisClusterClient |
RedisClusterClient.create(ClientResources clientResources,
RedisURI redisURI)
Create a new client that connects to the supplied
uri with shared ClientResources . |
static RedisClusterClient |
RedisClusterClient.create(RedisURI redisURI)
Create a new client that connects to the supplied
uri with default ClientResources . |
Modifier and Type | Method and Description |
---|---|
static RedisClusterClient |
RedisClusterClient.create(ClientResources clientResources,
Iterable<RedisURI> redisURIs)
Create a new client that connects to the supplied
uri with shared ClientResources . |
static RedisClusterClient |
RedisClusterClient.create(Iterable<RedisURI> redisURIs)
Create a new client that connects to the supplied
uri with default ClientResources . |
Constructor and Description |
---|
RedisClusterClient(RedisURI initialUri)
Deprecated.
|
Constructor and Description |
---|
RedisClusterClient(ClientResources clientResources,
Iterable<RedisURI> redisURIs)
Initialize the client with a list of cluster URI's.
|
RedisClusterClient(List<RedisURI> redisURIs)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
RedisURI |
RedisClusterNode.getUri() |
Modifier and Type | Method and Description |
---|---|
void |
RedisClusterNode.setUri(RedisURI uri)
Sets thhe connection point details.
|
Constructor and Description |
---|
RedisClusterNode(RedisURI uri,
String nodeId,
boolean connected,
String slaveOf,
long pingSentTimestamp,
long pongReceivedTimestamp,
long configEpoch,
List<Integer> slots,
Set<RedisClusterNode.NodeFlag> flags) |
Modifier and Type | Method and Description |
---|---|
static <K,V> StatefulRedisMasterSlaveConnection<K,V> |
MasterSlave.connect(RedisClient redisClient,
RedisCodec<K,V> codec,
RedisURI redisURI)
|
Constructor and Description |
---|
MasterSlaveConnectionProvider(RedisClient redisClient,
RedisCodec<K,V> redisCodec,
StatefulRedisConnection<K,V> masterConnection,
RedisURI initialRedisUri) |
MasterSlaveTopologyProvider(StatefulRedisConnection<?,?> masterConnection,
RedisURI masterURI) |
SentinelTopologyProvider(String masterId,
RedisClient redisClient,
RedisURI sentinelUri) |
Modifier and Type | Method and Description |
---|---|
RedisURI |
RedisNodeDescription.getUri() |
Modifier and Type | Method and Description |
---|---|
RedisURI |
LettuceFactoryBeanSupport.getRedisURI() |
Modifier and Type | Method and Description |
---|---|
void |
LettuceFactoryBeanSupport.setRedisURI(RedisURI redisURI)
Set the RedisURI for connecting Redis.
|
Copyright © 2016. All rights reserved.