Package | Description |
---|---|
com.lambdaworks.redis |
The redis client package containing
RedisClient for regular and sentinel operations. |
com.lambdaworks.redis.api.rx |
Standalone Redis API for reactive commands.
|
com.lambdaworks.redis.cluster |
Client for Redis Cluster, see
RedisClusterClient . |
com.lambdaworks.redis.cluster.api.rx |
Redis Cluster API for reactive commands.
|
com.lambdaworks.redis.cluster.pubsub.api.rx | |
com.lambdaworks.redis.pubsub |
Pub/Sub connection classes.
|
com.lambdaworks.redis.pubsub.api.rx |
Pub/Sub Redis API for reactive commands.
|
Modifier and Type | Method and Description |
---|---|
Observable<Success> |
AbstractRedisReactiveCommands.debugOom() |
Observable<Success> |
AbstractRedisReactiveCommands.debugSegfault() |
protected <T> Observable<Success> |
AbstractRedisReactiveCommands.getSuccessObservable(Observable<T> observable)
|
Observable<Success> |
AbstractRedisReactiveCommands.shutdown(boolean save) |
Modifier and Type | Method and Description |
---|---|
static Success |
Success.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static Success[] |
Success.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
Observable<Success> |
RedisServerReactiveCommands.debugOom()
Make the server crash: Out of memory.
|
Observable<Success> |
RedisServerReactiveCommands.debugSegfault()
Make the server crash: Invalid pointer access.
|
Observable<Success> |
RedisServerReactiveCommands.shutdown(boolean save)
Synchronously save the dataset to disk and then shut down the server.
|
Modifier and Type | Method and Description |
---|---|
Observable<Success> |
RedisAdvancedClusterReactiveCommandsImpl.shutdown(boolean save) |
Modifier and Type | Method and Description |
---|---|
Observable<Success> |
RedisAdvancedClusterReactiveCommands.shutdown(boolean save)
Synchronously save the dataset to disk and then shut down all nodes of the cluster.
|
Modifier and Type | Method and Description |
---|---|
ReactiveExecutions<Success> |
NodeSelectionPubSubReactiveCommands.psubscribe(K... patterns)
Listen for messages published to channels matching the given patterns.
|
ReactiveExecutions<Success> |
NodeSelectionPubSubReactiveCommands.punsubscribe(K... patterns)
Stop listening for messages posted to channels matching the given patterns.
|
ReactiveExecutions<Success> |
NodeSelectionPubSubReactiveCommands.subscribe(K... channels)
Listen for messages published to the given channels.
|
ReactiveExecutions<Success> |
NodeSelectionPubSubReactiveCommands.unsubscribe(K... channels)
Stop listening for messages posted to the given channels.
|
Modifier and Type | Method and Description |
---|---|
Observable<Success> |
RedisPubSubReactiveCommandsImpl.psubscribe(K... patterns) |
Observable<Success> |
RedisPubSubReactiveCommandsImpl.punsubscribe(K... patterns) |
Observable<Success> |
RedisPubSubReactiveCommandsImpl.subscribe(K... channels) |
Observable<Success> |
RedisPubSubReactiveCommandsImpl.unsubscribe(K... channels) |
Modifier and Type | Method and Description |
---|---|
Observable<Success> |
RedisPubSubReactiveCommands.psubscribe(K... patterns)
Listen for messages published to channels matching the given patterns.
|
Observable<Success> |
RedisPubSubReactiveCommands.punsubscribe(K... patterns)
Stop listening for messages posted to channels matching the given patterns.
|
Observable<Success> |
RedisPubSubReactiveCommands.subscribe(K... channels)
Listen for messages published to the given channels.
|
Observable<Success> |
RedisPubSubReactiveCommands.unsubscribe(K... channels)
Stop listening for messages posted to the given channels.
|
Copyright © 2018 lettuce.io. All rights reserved.