Package org.springframework.data.redis.connection

Interface ReactiveRedisClusterConnection

All Superinterfaces:

AutoCloseable, Closeable, ReactiveClusterCommands, ReactiveRedisConnection

public interface ReactiveRedisClusterConnection
extends ReactiveRedisConnection, ReactiveClusterCommands

Since:

2.0

Author:

Christoph Strobl, Mark Paluch

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.data.redis.connection.ReactiveClusterCommands

ReactiveClusterCommands.AddSlots

Nested classes/interfaces inherited from interface org.springframework.data.redis.connection.ReactiveRedisConnection

ReactiveRedisConnection.AbsentByteBufferResponse<I>, ReactiveRedisConnection.BooleanResponse<I>, ReactiveRedisConnection.ByteBufferResponse<I>, ReactiveRedisConnection.Command, ReactiveRedisConnection.CommandResponse<I,O>, ReactiveRedisConnection.KeyCommand, ReactiveRedisConnection.KeyScanCommand, ReactiveRedisConnection.MultiValueResponse<I,O>, ReactiveRedisConnection.NumericResponse<I,O extends Number>, ReactiveRedisConnection.RangeCommand

Method Summary

Modifier and Type	Method	Description
ReactiveClusterGeoCommands	geoCommands()	Get ReactiveGeoCommands
ReactiveClusterHashCommands	hashCommands()	Get ReactiveHashCommands.
ReactiveClusterHyperLogLogCommands	hyperLogLogCommands()	Get ReactiveHyperLogLogCommands.
ReactiveClusterKeyCommands	keyCommands()	Get ReactiveKeyCommands.
ReactiveClusterListCommands	listCommands()	Get ReactiveListCommands.
ReactiveClusterNumberCommands	numberCommands()	Get ReactiveNumberCommands
reactor.core.publisher.Mono<String>	ping(RedisClusterNode node)	Test the connection to a specific Redis cluster node.
ReactiveClusterServerCommands	serverCommands()	Get ReactiveServerCommands.
ReactiveClusterSetCommands	setCommands()	Get ReactiveSetCommands.
ReactiveClusterStreamCommands	streamCommands()	Get ReactiveStreamCommands.
ReactiveClusterStringCommands	stringCommands()	Get ReactiveStringCommands.
ReactiveClusterZSetCommands	zSetCommands()	Get ReactiveZSetCommands.

Methods inherited from interface org.springframework.data.redis.connection.ReactiveClusterCommands

clusterAddSlots, clusterAddSlots, clusterCountKeysInSlot, clusterDeleteSlots, clusterDeleteSlotsInRange, clusterForget, clusterGetClusterInfo, clusterGetKeysInSlot, clusterGetMasterReplicaMap, clusterGetNodeForKey, clusterGetNodeForSlot, clusterGetNodes, clusterGetReplicas, clusterGetSlotForKey, clusterMeet, clusterReplicate, clusterSetSlot

Methods inherited from interface org.springframework.data.redis.connection.ReactiveRedisConnection

close, closeLater, ping, pubSubCommands, scriptingCommands

Method Details

keyCommands

ReactiveClusterKeyCommands keyCommands()

Description copied from interface: ReactiveRedisConnection

Get ReactiveKeyCommands.

Specified by:

keyCommands in interface ReactiveRedisConnection

Returns:

never null.

stringCommands

ReactiveClusterStringCommands stringCommands()

Description copied from interface: ReactiveRedisConnection

Get ReactiveStringCommands.

Specified by:

stringCommands in interface ReactiveRedisConnection

Returns:

never null.

numberCommands

ReactiveClusterNumberCommands numberCommands()

Description copied from interface: ReactiveRedisConnection

Get ReactiveNumberCommands

Specified by:

numberCommands in interface ReactiveRedisConnection

Returns:

never null.

listCommands

ReactiveClusterListCommands listCommands()

Description copied from interface: ReactiveRedisConnection

Get ReactiveListCommands.

Specified by:

listCommands in interface ReactiveRedisConnection

Returns:

never null.

setCommands

ReactiveClusterSetCommands setCommands()

Description copied from interface: ReactiveRedisConnection

Get ReactiveSetCommands.

Specified by:

setCommands in interface ReactiveRedisConnection

Returns:

never null.

zSetCommands

ReactiveClusterZSetCommands zSetCommands()

Description copied from interface: ReactiveRedisConnection

Get ReactiveZSetCommands.

Specified by:

zSetCommands in interface ReactiveRedisConnection

Returns:

never null.

hashCommands

ReactiveClusterHashCommands hashCommands()

Description copied from interface: ReactiveRedisConnection

Get ReactiveHashCommands.

Specified by:

hashCommands in interface ReactiveRedisConnection

Returns:

never null.

geoCommands

ReactiveClusterGeoCommands geoCommands()

Description copied from interface: ReactiveRedisConnection

Get ReactiveGeoCommands

Specified by:

geoCommands in interface ReactiveRedisConnection

Returns:

never null.

hyperLogLogCommands

ReactiveClusterHyperLogLogCommands hyperLogLogCommands()

Description copied from interface: ReactiveRedisConnection

Get ReactiveHyperLogLogCommands.

Specified by:

hyperLogLogCommands in interface ReactiveRedisConnection

Returns:

never null.

serverCommands

ReactiveClusterServerCommands serverCommands()

Description copied from interface: ReactiveRedisConnection

Get ReactiveServerCommands.

Specified by:

serverCommands in interface ReactiveRedisConnection

Returns:

never null.

streamCommands

ReactiveClusterStreamCommands streamCommands()

Description copied from interface: ReactiveRedisConnection

Get ReactiveStreamCommands.

Specified by:

streamCommands in interface ReactiveRedisConnection

Returns:

never null.

ping

reactor.core.publisher.Mono<String> ping(RedisClusterNode node)

Test the connection to a specific Redis cluster node.

Parameters:

node - must not be null.

Returns:

Mono wrapping server response message - usually PONG.

Throws:

IllegalArgumentException - when node is null.

See Also:

• RedisConnectionCommands.ping()