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.protocol |
Redis protocol layer abstraction.
|
com.lambdaworks.redis.pubsub |
Pub/Sub connection classes.
|
com.lambdaworks.redis.sentinel |
Redis Sentinel connection classes.
|
Modifier and Type | Class and Description |
---|---|
class |
StatefulRedisConnectionImpl<K,V>
A thread-safe connection to a Redis server.
|
Modifier and Type | Method and Description |
---|---|
protected <K,V,T extends RedisChannelHandler<K,V>> |
AbstractRedisClient.connectAsyncImpl(CommandHandler<K,V> handler,
T connection,
Supplier<SocketAddress> socketAddressSupplier) |
protected <K,V,T extends RedisChannelHandler<K,V>> |
AbstractRedisClient.initializeChannel(ConnectionBuilder connectionBuilder) |
Modifier and Type | Method and Description |
---|---|
RedisChannelHandler<?,?> |
ConnectionBuilder.connection() |
Modifier and Type | Method and Description |
---|---|
ConnectionBuilder |
ConnectionBuilder.connection(RedisChannelHandler<?,?> connection) |
protected void |
AbstractRedisClient.connectionBuilder(CommandHandler<?,?> handler,
RedisChannelHandler<?,?> connection,
Supplier<SocketAddress> socketAddressSupplier,
ConnectionBuilder connectionBuilder,
RedisURI redisURI)
Populate connection builder with necessary resources.
|
protected void |
ConnectionEvents.fireEventRedisConnected(RedisChannelHandler<?,?> connection) |
protected void |
ConnectionEvents.fireEventRedisDisconnected(RedisChannelHandler<?,?> connection) |
protected void |
ConnectionEvents.fireEventRedisExceptionCaught(RedisChannelHandler<?,?> connection,
Throwable cause) |
void |
RedisConnectionStateListener.onRedisConnected(RedisChannelHandler<?,?> connection)
Event handler for successful connection event.
|
void |
RedisConnectionStateListener.onRedisDisconnected(RedisChannelHandler<?,?> connection)
Event handler for disconnection event.
|
void |
RedisConnectionStateListener.onRedisExceptionCaught(RedisChannelHandler<?,?> connection,
Throwable cause)
Event handler for exceptions.
|
void |
RedisChannelWriter.setRedisChannelHandler(RedisChannelHandler<K,V> redisChannelHandler)
Set the corresponding connection instance in order to notify it about channel active/inactive state.
|
Modifier and Type | Class and Description |
---|---|
class |
StatefulRedisClusterConnectionImpl<K,V>
A thread-safe connection to a Redis Cluster.
|
Modifier and Type | Method and Description |
---|---|
void |
CommandHandler.setRedisChannelHandler(RedisChannelHandler<K,V> redisChannelHandler) |
Modifier and Type | Class and Description |
---|---|
class |
StatefulRedisPubSubConnectionImpl<K,V>
An thread-safe pub/sub connection to a Redis server.
|
Modifier and Type | Class and Description |
---|---|
class |
StatefulRedisSentinelConnectionImpl<K,V> |
Copyright © 2016. All rights reserved.