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.codec |
Codecs for key/value type conversion.
|
com.lambdaworks.redis.output |
Implementation of different output protocols including the Streaming API.
|
com.lambdaworks.redis.protocol |
Redis protocol layer abstraction.
|
com.lambdaworks.redis.pubsub |
Pub/Sub connection classes.
|
Modifier and Type | Field and Description |
---|---|
protected RedisCodec<K,V> |
RedisAsyncConnectionImpl.codec |
Modifier and Type | Method and Description |
---|---|
<K,V> RedisConnectionPool<RedisAsyncConnection<K,V>> |
RedisClient.asyncPool(RedisCodec<K,V> codec,
int maxIdle,
int maxActive)
Creates a connection pool for asynchronous connections.
|
<K,V> RedisConnection<K,V> |
RedisClient.connect(RedisCodec<K,V> codec)
Open a new synchronous connection to a Redis server.
|
<K,V> RedisConnection |
RedisClient.connect(RedisCodec<K,V> codec,
RedisURI redisURI)
|
<K,V> RedisAsyncConnection<K,V> |
RedisClient.connectAsync(RedisCodec<K,V> codec)
Open a new asynchronous connection to a Redis server.
|
<K,V> RedisAsyncConnection<K,V> |
RedisClient.connectAsync(RedisCodec<K,V> codec,
RedisURI redisURI)
|
<K,V> RedisPubSubConnection<K,V> |
RedisClient.connectPubSub(RedisCodec<K,V> codec)
|
<K,V> RedisPubSubConnection<K,V> |
RedisClient.connectPubSub(RedisCodec<K,V> codec,
RedisURI redisURI)
|
<K,V> RedisSentinelAsyncConnection<K,V> |
RedisClient.connectSentinelAsync(RedisCodec<K,V> codec)
Open a new asynchronous connection to a Redis Sentinela nd use the supplied
codec to encode/decode
keys and values. |
<K,V> RedisSentinelAsyncConnection<K,V> |
RedisClient.connectSentinelAsync(RedisCodec<K,V> codec,
RedisURI redisURI)
|
protected <K,V> RedisAsyncConnectionImpl<K,V> |
RedisClient.newRedisAsyncConnectionImpl(RedisChannelWriter<K,V> channelWriter,
RedisCodec<K,V> codec,
long timeout,
TimeUnit unit)
Construct a new
RedisAsyncConnectionImpl . |
protected <K,V> RedisPubSubConnectionImpl<K,V> |
RedisClient.newRedisPubSubConnectionImpl(RedisChannelWriter<K,V> channelWriter,
RedisCodec<K,V> codec,
long timeout,
TimeUnit unit)
Construct a new
RedisPubSubConnectionImpl . |
protected <K,V> com.lambdaworks.redis.RedisSentinelAsyncConnectionImpl<K,V> |
RedisClient.newRedisSentinelAsyncConnectionImpl(RedisChannelWriter<K,V> channelWriter,
RedisCodec<K,V> codec,
long timeout,
TimeUnit unit)
Construct a new
RedisSentinelAsyncConnectionImpl . |
<K,V> RedisConnectionPool<RedisConnection<K,V>> |
RedisClient.pool(RedisCodec<K,V> codec,
int maxIdle,
int maxActive)
Creates a connection pool for synchronous connections.
|
Constructor and Description |
---|
RedisAsyncConnectionImpl(RedisChannelWriter<K,V> writer,
RedisCodec<K,V> codec,
long timeout,
TimeUnit unit)
Initialize a new connection.
|
Modifier and Type | Method and Description |
---|---|
<K,V> RedisAdvancedClusterConnection<K,V> |
RedisClusterClient.connectCluster(RedisCodec<K,V> codec)
Open a new synchronous connection to a Redis Cluster.
|
<K,V> RedisAdvancedClusterAsyncConnection<K,V> |
RedisClusterClient.connectClusterAsync(RedisCodec<K,V> codec)
Open a new asynchronous connection to a Redis Cluster.
|
protected <K,V> RedisAdvancedClusterAsyncConnectionImpl<K,V> |
RedisClusterClient.newRedisAdvancedClusterAsyncConnectionImpl(RedisChannelWriter<K,V> channelWriter,
RedisCodec<K,V> codec,
long timeout,
TimeUnit unit)
Construct a new
RedisAdvancedClusterAsyncConnectionImpl . |
protected <K,V> RedisAsyncConnectionImpl<K,V> |
RedisClusterClient.newRedisAsyncConnectionImpl(RedisChannelWriter<K,V> channelWriter,
RedisCodec<K,V> codec,
long timeout,
TimeUnit unit)
Construct a new
RedisAsyncConnectionImpl . |
Constructor and Description |
---|
RedisAdvancedClusterAsyncConnectionImpl(RedisChannelWriter<K,V> writer,
RedisCodec<K,V> codec,
long timeout,
TimeUnit unit)
Initialize a new connection.
|
Modifier and Type | Class and Description |
---|---|
class |
ByteArrayCodec
A
RedisCodec that uses plain byte arrays. |
class |
Utf8StringCodec
A
RedisCodec that handles UTF-8 encoded keys and values. |
Modifier and Type | Method and Description |
---|---|
static <K,V> RedisCodec<K,V> |
CompressionCodec.valueCompressor(RedisCodec<K,V> delegate,
CompressionCodec.CompressionType compressionType)
A
RedisCodec that compresses values from a delegating RedisCodec . |
Modifier and Type | Method and Description |
---|---|
static <K,V> RedisCodec<K,V> |
CompressionCodec.valueCompressor(RedisCodec<K,V> delegate,
CompressionCodec.CompressionType compressionType)
A
RedisCodec that compresses values from a delegating RedisCodec . |
Modifier and Type | Field and Description |
---|---|
protected RedisCodec<K,V> |
CommandOutput.codec |
Constructor and Description |
---|
CommandArgs(RedisCodec<K,V> codec) |
CommandOutput(RedisCodec<K,V> codec,
T output)
Initialize a new instance that encodes and decodes keys and values using the supplied codec.
|
Constructor and Description |
---|
PubSubCommandHandler(ClientOptions clientOptions,
ClientResources clientResources,
Queue<RedisCommand<K,V,?>> queue,
RedisCodec<K,V> codec)
Initialize a new instance.
|
PubSubOutput(RedisCodec<K,V> codec) |
RedisPubSubConnectionImpl(RedisChannelWriter<K,V> writer,
RedisCodec<K,V> codec,
long timeout,
TimeUnit unit)
Initialize a new connection.
|
Copyright © 2016. All rights reserved.