org.springframework.data.redis.connection.lettuce

Class LettuceReactiveRedisClusterConnection

java.lang.Object

org.springframework.data.redis.connection.lettuce.LettuceReactiveRedisConnection

org.springframework.data.redis.connection.lettuce.LettuceReactiveRedisClusterConnection

All Implemented Interfaces:

Closeable, AutoCloseable, ReactiveRedisClusterConnection, ReactiveRedisConnection

public class LettuceReactiveRedisClusterConnection
extends LettuceReactiveRedisConnection
implements ReactiveRedisClusterConnection

Since:

2.0

Author:

Christoph Strobl, Mark Paluch

Nested Class Summary

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

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

Constructor Summary

Constructors

Constructor and Description
LettuceReactiveRedisClusterConnection(com.lambdaworks.redis.cluster.RedisClusterClient client)

Method Summary

Modifier and Type	Method and Description
<T> reactor.core.publisher.Flux<T>	execute(RedisNode node, org.springframework.data.redis.connection.lettuce.LettuceReactiveRedisConnection.LettuceReactiveCallback<T> callback)
LettuceReactiveClusterGeoCommands	geoCommands() Get ReactiveGeoCommands
protected com.lambdaworks.redis.cluster.api.reactive.RedisClusterReactiveCommands<ByteBuffer,ByteBuffer>	getCommands()
protected com.lambdaworks.redis.api.reactive.RedisReactiveCommands<ByteBuffer,ByteBuffer>	getCommands(RedisNode node)
protected com.lambdaworks.redis.cluster.api.StatefulRedisClusterConnection<ByteBuffer,ByteBuffer>	getConnection()
LettuceReactiveClusterHashCommands	hashCommands() Get ReactiveHashCommands.
LettuceReactiveClusterHyperLogLogCommands	hyperLogLogCommands() Get ReactiveHyperLogLogCommands.
LettuceReactiveClusterKeyCommands	keyCommands() Get ReactiveKeyCommands.
LettuceReactiveClusterListCommands	listCommands() Get ReactiveListCommands.
LettuceReactiveClusterNumberCommands	numberCommands() Get ReactiveNumberCommands
LettuceReactiveClusterSetCommands	setCommands() Get ReactiveSetCommands.
LettuceReactiveClusterStringCommands	stringCommands() Get ReactiveStringCommands.
LettuceReactiveClusterZSetCommands	zSetCommands() Get ReactiveZSetCommands.

Methods inherited from class org.springframework.data.redis.connection.lettuce.LettuceReactiveRedisConnection

close, execute

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.io.Closeable

close

Constructor Detail

LettuceReactiveRedisClusterConnection

public LettuceReactiveRedisClusterConnection(com.lambdaworks.redis.cluster.RedisClusterClient client)

Method Detail

keyCommands

public LettuceReactiveClusterKeyCommands keyCommands()

Description copied from interface: ReactiveRedisConnection

Get ReactiveKeyCommands.

Specified by:

keyCommands in interface ReactiveRedisClusterConnection

Specified by:

keyCommands in interface ReactiveRedisConnection

Overrides:

keyCommands in class LettuceReactiveRedisConnection

Returns:

never null.

listCommands

public LettuceReactiveClusterListCommands listCommands()

Description copied from interface: ReactiveRedisConnection

Get ReactiveListCommands.

Specified by:

listCommands in interface ReactiveRedisClusterConnection

Specified by:

listCommands in interface ReactiveRedisConnection

Overrides:

listCommands in class LettuceReactiveRedisConnection

Returns:

never null.

setCommands

public LettuceReactiveClusterSetCommands setCommands()

Description copied from interface: ReactiveRedisConnection

Get ReactiveSetCommands.

Specified by:

setCommands in interface ReactiveRedisClusterConnection

Specified by:

setCommands in interface ReactiveRedisConnection

Overrides:

setCommands in class LettuceReactiveRedisConnection

Returns:

never null.

zSetCommands

public LettuceReactiveClusterZSetCommands zSetCommands()

Description copied from interface: ReactiveRedisConnection

Get ReactiveZSetCommands.

Specified by:

zSetCommands in interface ReactiveRedisClusterConnection

Specified by:

zSetCommands in interface ReactiveRedisConnection

Overrides:

zSetCommands in class LettuceReactiveRedisConnection

Returns:

never null.

hyperLogLogCommands

public LettuceReactiveClusterHyperLogLogCommands hyperLogLogCommands()

Description copied from interface: ReactiveRedisConnection

Get ReactiveHyperLogLogCommands.

Specified by:

hyperLogLogCommands in interface ReactiveRedisClusterConnection

Specified by:

hyperLogLogCommands in interface ReactiveRedisConnection

Overrides:

hyperLogLogCommands in class LettuceReactiveRedisConnection

Returns:

never null.

stringCommands

public LettuceReactiveClusterStringCommands stringCommands()

Description copied from interface: ReactiveRedisConnection

Get ReactiveStringCommands.

Specified by:

stringCommands in interface ReactiveRedisClusterConnection

Specified by:

stringCommands in interface ReactiveRedisConnection

Overrides:

stringCommands in class LettuceReactiveRedisConnection

Returns:

never null.

geoCommands

public LettuceReactiveClusterGeoCommands geoCommands()

Description copied from interface: ReactiveRedisConnection

Get ReactiveGeoCommands

Specified by:

geoCommands in interface ReactiveRedisClusterConnection

Specified by:

geoCommands in interface ReactiveRedisConnection

Overrides:

geoCommands in class LettuceReactiveRedisConnection

Returns:

never null.

hashCommands

public LettuceReactiveClusterHashCommands hashCommands()

Description copied from interface: ReactiveRedisConnection

Get ReactiveHashCommands.

Specified by:

hashCommands in interface ReactiveRedisClusterConnection

Specified by:

hashCommands in interface ReactiveRedisConnection

Overrides:

hashCommands in class LettuceReactiveRedisConnection

Returns:

numberCommands

public LettuceReactiveClusterNumberCommands numberCommands()

Description copied from interface: ReactiveRedisConnection

Get ReactiveNumberCommands

Specified by:

numberCommands in interface ReactiveRedisClusterConnection

Specified by:

numberCommands in interface ReactiveRedisConnection

Overrides:

numberCommands in class LettuceReactiveRedisConnection

Returns:

never null.

execute

public <T> reactor.core.publisher.Flux<T> execute(RedisNode node,
                                                  org.springframework.data.redis.connection.lettuce.LettuceReactiveRedisConnection.LettuceReactiveCallback<T> callback)

Parameters:

callback -

Returns:

getConnection

protected com.lambdaworks.redis.cluster.api.StatefulRedisClusterConnection<ByteBuffer,ByteBuffer> getConnection()

Overrides:

getConnection in class LettuceReactiveRedisConnection

getCommands

protected com.lambdaworks.redis.cluster.api.reactive.RedisClusterReactiveCommands<ByteBuffer,ByteBuffer> getCommands()

Overrides:

getCommands in class LettuceReactiveRedisConnection

getCommands

protected com.lambdaworks.redis.api.reactive.RedisReactiveCommands<ByteBuffer,ByteBuffer> getCommands(RedisNode node)