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.masterslave | |
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.
|
com.lambdaworks.redis.sentinel |
Redis Sentinel connection classes.
|
Modifier and Type | Field and Description |
---|---|
protected RedisCodec<K,V> |
StatefulRedisConnectionImpl.codec |
protected RedisCodec<K,V> |
AbstractRedisReactiveCommands.codec |
protected RedisCodec<K,V> |
AbstractRedisAsyncCommands.codec |
Modifier and Type | Method and Description |
---|---|
<K,V> RedisConnectionPool<RedisAsyncCommands<K,V>> |
RedisClient.asyncPool(RedisCodec<K,V> codec,
int maxIdle,
int maxActive)
Creates a connection pool for asynchronous connections.
|
<K,V> StatefulRedisConnection<K,V> |
RedisClient.connect(RedisCodec<K,V> codec)
Open a new connection to a Redis server.
|
<K,V> StatefulRedisConnection<K,V> |
RedisClient.connect(RedisCodec<K,V> codec,
RedisURI redisURI)
|
<K,V> RedisAsyncCommands<K,V> |
RedisClient.connectAsync(RedisCodec<K,V> codec)
Deprecated.
Use
connect(codec).async() |
<K,V> RedisAsyncCommands<K,V> |
RedisClient.connectAsync(RedisCodec<K,V> codec,
RedisURI redisURI)
Deprecated.
Use
connect(codec, redisURI).async() |
<K,V> StatefulRedisPubSubConnection<K,V> |
RedisClient.connectPubSub(RedisCodec<K,V> codec)
|
<K,V> StatefulRedisPubSubConnection<K,V> |
RedisClient.connectPubSub(RedisCodec<K,V> codec,
RedisURI redisURI)
|
<K,V> StatefulRedisSentinelConnection<K,V> |
RedisClient.connectSentinel(RedisCodec<K,V> codec)
Open a connection to a Redis Sentinel that treats keys and use the supplied
codec to encode/decode
keys and values. |
<K,V> StatefulRedisSentinelConnection<K,V> |
RedisClient.connectSentinel(RedisCodec<K,V> codec,
RedisURI redisURI)
|
<K,V> RedisSentinelAsyncCommands<K,V> |
RedisClient.connectSentinelAsync(RedisCodec<K,V> codec)
Deprecated.
Use
connectSentinel(codec).async() |
<K,V> RedisSentinelAsyncCommands<K,V> |
RedisClient.connectSentinelAsync(RedisCodec<K,V> codec,
RedisURI redisURI)
Deprecated.
Use
connectSentinel(codec, redisURI).async() |
protected <K,V> StatefulRedisConnectionImpl<K,V> |
RedisClient.newStatefulRedisConnection(CommandHandler<K,V> commandHandler,
RedisCodec<K,V> codec)
Create a new instance of
StatefulRedisConnectionImpl or a subclass. |
protected <K,V> StatefulRedisPubSubConnectionImpl<K,V> |
RedisClient.newStatefulRedisPubSubConnection(PubSubCommandHandler<K,V> commandHandler,
RedisCodec<K,V> codec)
Create a new instance of
StatefulRedisPubSubConnectionImpl or a subclass. |
protected <K,V> StatefulRedisSentinelConnectionImpl<K,V> |
RedisClient.newStatefulRedisSentinelConnection(CommandHandler<K,V> commandHandler,
RedisCodec<K,V> codec)
Create a new instance of
StatefulRedisSentinelConnectionImpl or a subclass. |
<K,V> RedisConnectionPool<RedisCommands<K,V>> |
RedisClient.pool(RedisCodec<K,V> codec,
int maxIdle,
int maxActive)
Creates a connection pool for synchronous connections.
|
Constructor and Description |
---|
AbstractRedisAsyncCommands(StatefulConnection<K,V> connection,
RedisCodec<K,V> codec)
Initialize a new instance.
|
AbstractRedisReactiveCommands(StatefulConnection<K,V> connection,
RedisCodec<K,V> codec)
Initialize a new instance.
|
RedisAsyncCommandsImpl(StatefulRedisConnection<K,V> connection,
RedisCodec<K,V> codec)
Initialize a new instance.
|
RedisReactiveCommandsImpl(StatefulRedisConnection<K,V> connection,
RedisCodec<K,V> codec)
Initialize a new instance.
|
StatefulRedisConnectionImpl(RedisChannelWriter<K,V> writer,
RedisCodec<K,V> codec,
long timeout,
TimeUnit unit)
Initialize a new connection.
|
Modifier and Type | Field and Description |
---|---|
protected RedisCodec<K,V> |
StatefulRedisClusterConnectionImpl.codec |
Modifier and Type | Method and Description |
---|---|
<K,V> StatefulRedisClusterConnection<K,V> |
RedisClusterClient.connect(RedisCodec<K,V> codec)
Connect to a Redis Cluster.
|
<K,V> RedisAdvancedClusterCommands<K,V> |
RedisClusterClient.connectCluster(RedisCodec<K,V> codec)
Deprecated.
@deprecated Use
connect(codec).sync() |
<K,V> RedisAdvancedClusterAsyncCommands<K,V> |
RedisClusterClient.connectClusterAsync(RedisCodec<K,V> codec)
Deprecated.
@deprecated Use
connect(codec).async() |
Constructor and Description |
---|
RedisAdvancedClusterAsyncCommandsImpl(StatefulRedisClusterConnectionImpl<K,V> connection,
RedisCodec<K,V> codec)
Initialize a new connection.
|
RedisAdvancedClusterReactiveCommandsImpl(StatefulRedisClusterConnectionImpl<K,V> connection,
RedisCodec<K,V> codec)
Initialize a new connection.
|
StatefulRedisClusterConnectionImpl(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 | 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) |
Modifier and Type | Field and Description |
---|---|
protected RedisCodec<K,V> |
CommandOutput.codec |
Modifier and Type | Field and Description |
---|---|
protected RedisCodec<K,V> |
BaseRedisCommandBuilder.codec |
Modifier and Type | Method and Description |
---|---|
protected <T> CommandOutput<K,V,T> |
BaseRedisCommandBuilder.newScriptOutput(RedisCodec<K,V> codec,
ScriptOutputType type) |
Constructor and Description |
---|
BaseRedisCommandBuilder(RedisCodec<K,V> codec) |
CommandArgs(RedisCodec<K,V> 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) |
RedisPubSubAsyncCommandsImpl(StatefulRedisPubSubConnection<K,V> connection,
RedisCodec<K,V> codec)
Initialize a new connection.
|
RedisPubSubReactiveCommandsImpl(StatefulRedisPubSubConnection<K,V> connection,
RedisCodec<K,V> codec)
Initialize a new connection.
|
StatefulRedisPubSubConnectionImpl(RedisChannelWriter<K,V> writer,
RedisCodec<K,V> codec,
long timeout,
TimeUnit unit)
Initialize a new connection.
|
Modifier and Type | Field and Description |
---|---|
protected RedisCodec<K,V> |
StatefulRedisSentinelConnectionImpl.codec |
Constructor and Description |
---|
RedisSentinelAsyncCommandsImpl(StatefulConnection<K,V> connection,
RedisCodec<K,V> codec) |
RedisSentinelReactiveCommandsImpl(StatefulConnection<K,V> connection,
RedisCodec<K,V> codec) |
StatefulRedisSentinelConnectionImpl(RedisChannelWriter<K,V> writer,
RedisCodec<K,V> codec,
long timeout,
TimeUnit unit) |
Copyright © 2016. All rights reserved.