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 the redis server.
|
<K,V> RedisAsyncConnection<K,V> |
RedisClient.connectAsync(RedisCodec<K,V> codec)
Open a new asynchronous connection to the redis server.
|
<K,V> RedisPubSubConnection<K,V> |
RedisClient.connectPubSub(RedisCodec<K,V> codec)
Open a new pub/sub connection to the redis server.
|
protected <K,V> RedisPubSubConnection<K,V> |
RedisClient.connectPubSub(RedisCodec<K,V> codec,
RedisURI redisURI) |
<K,V> RedisSentinelAsyncConnection<K,V> |
RedisClient.connectSentinelAsync(RedisCodec<K,V> codec)
Creates an asynchronous connection to Sentinel.
|
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> RedisClusterConnection<K,V> |
RedisClusterClient.connectCluster(RedisCodec<K,V> codec)
Open a new synchronous connection to the redis server.
|
<K,V> RedisClusterAsyncConnection<K,V> |
RedisClusterClient.connectClusterAsync(RedisCodec<K,V> codec)
Creates a connection to the redis cluster.
|
protected <K,V> RedisAsyncConnectionImpl<K,V> |
RedisClusterClient.newRedisAsyncConnectionImpl(RedisChannelWriter<K,V> channelWriter,
RedisCodec<K,V> codec,
long timeout,
TimeUnit unit)
Construct a new
RedisAsyncConnectionImpl . |
Modifier and Type | Class and Description |
---|---|
class |
Utf8StringCodec
A
RedisCodec that handles UTF-8 encoded keys and values. |
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(BlockingQueue<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 © 2015. All rights reserved.