Uses of Interface
com.lambdaworks.redis.cluster.api.rx.RedisClusterReactiveCommands

Packages that use RedisClusterReactiveCommands

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 clusters RedisClusterClient.
com.lambdaworks.redis.cluster.api.rx	Redis Cluster API for reactive commands.
com.lambdaworks.redis.pubsub	Pub/Sub connection classes.
com.lambdaworks.redis.pubsub.api.rx	PubSub Redis API for reactive commands.

Uses of RedisClusterReactiveCommands in com.lambdaworks.redis

Classes in com.lambdaworks.redis that implement RedisClusterReactiveCommands

Modifier and Type	Class and Description
class	AbstractRedisReactiveCommands<K,V> A reactive and thread-safe API for a Redis connection.
class	RedisReactiveCommandsImpl<K,V> A reactive and thread-safe API for a Redis Sentinel connection.

Uses of RedisClusterReactiveCommands in com.lambdaworks.redis.api.rx

Subinterfaces of RedisClusterReactiveCommands in com.lambdaworks.redis.api.rx

Modifier and Type	Interface and Description
interface	RedisReactiveCommands<K,V> A complete reactive and thread-safe Redis API with 400+ Methods.

Uses of RedisClusterReactiveCommands in com.lambdaworks.redis.cluster

Classes in com.lambdaworks.redis.cluster that implement RedisClusterReactiveCommands

Modifier and Type	Class and Description
class	RedisAdvancedClusterReactiveCommandsImpl<K,V> An advanced reactive and thread-safe API to a Redis Cluster connection.

Methods in com.lambdaworks.redis.cluster that return RedisClusterReactiveCommands

Modifier and Type	Method and Description
RedisClusterReactiveCommands<K,V>	RedisAdvancedClusterReactiveCommandsImpl.getConnection(String nodeId)
RedisClusterReactiveCommands<K,V>	RedisAdvancedClusterReactiveCommandsImpl.getConnection(String host, int port)

Method parameters in com.lambdaworks.redis.cluster with type arguments of type RedisClusterReactiveCommands

Modifier and Type	Method and Description
protected <T> Map<String,Observable<T>>	RedisAdvancedClusterReactiveCommandsImpl.executeOnMasters(java.util.function.Function<RedisClusterReactiveCommands<K,V>,Observable<T>> function) Run a command on all available masters,
protected <T> Map<String,Observable<T>>	RedisAdvancedClusterReactiveCommandsImpl.executeOnNodes(java.util.function.Function<RedisClusterReactiveCommands<K,V>,Observable<T>> function, java.util.function.Function<RedisClusterNode,Boolean> filter) Run a command on all available nodes that match filter.

Uses of RedisClusterReactiveCommands in com.lambdaworks.redis.cluster.api.rx

Subinterfaces of RedisClusterReactiveCommands in com.lambdaworks.redis.cluster.api.rx

Modifier and Type	Interface and Description
interface	RedisAdvancedClusterReactiveCommands<K,V> Advanced reactive and thread-safe Redis Cluster API.

Methods in com.lambdaworks.redis.cluster.api.rx that return RedisClusterReactiveCommands

Modifier and Type	Method and Description
RedisClusterReactiveCommands<K,V>	RedisAdvancedClusterReactiveCommands.getConnection(String nodeId) Retrieve a connection to the specified cluster node using the nodeId.
RedisClusterReactiveCommands<K,V>	RedisAdvancedClusterReactiveCommands.getConnection(String host, int port) Retrieve a connection to the specified cluster node using the nodeId.

Uses of RedisClusterReactiveCommands in com.lambdaworks.redis.pubsub

Classes in com.lambdaworks.redis.pubsub that implement RedisClusterReactiveCommands

Modifier and Type	Class and Description
class	RedisPubSubReactiveCommandsImpl<K,V> A reactive and thread-safe API for a Redis pub/sub connection.

Uses of RedisClusterReactiveCommands in com.lambdaworks.redis.pubsub.api.rx

Subinterfaces of RedisClusterReactiveCommands in com.lambdaworks.redis.pubsub.api.rx

Modifier and Type	Interface and Description
interface	RedisPubSubReactiveCommands<K,V> Asynchronous and thread-safe Redis PubSub API.