org.springframework.data.redis.connection.lettuce

Class LettuceReactiveRedisConnection

java.lang.Object

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

All Implemented Interfaces:

Closeable, AutoCloseable, ReactiveRedisConnection

Direct Known Subclasses:

LettuceReactiveRedisClusterConnection

public class LettuceReactiveRedisConnection
extends Object
implements ReactiveRedisConnection

Since:

2.0

Author:

Christoph Strobl

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
LettuceReactiveRedisConnection(com.lambdaworks.redis.AbstractRedisClient client)

Method Summary

Modifier and Type	Method and Description
void	close()
<T> reactor.core.publisher.Flux<T>	execute(org.springframework.data.redis.connection.lettuce.LettuceReactiveRedisConnection.LettuceReactiveCallback<T> callback)
ReactiveGeoCommands	geoCommands() Get ReactiveGeoCommands
protected com.lambdaworks.redis.cluster.api.reactive.RedisClusterReactiveCommands<ByteBuffer,ByteBuffer>	getCommands()
protected com.lambdaworks.redis.api.StatefulConnection<ByteBuffer,ByteBuffer>	getConnection()
ReactiveHashCommands	hashCommands() Get ReactiveHashCommands.
ReactiveHyperLogLogCommands	hyperLogLogCommands() Get ReactiveHyperLogLogCommands.
ReactiveKeyCommands	keyCommands() Get ReactiveKeyCommands.
ReactiveListCommands	listCommands() Get ReactiveListCommands.
ReactiveNumberCommands	numberCommands() Get ReactiveNumberCommands
ReactiveSetCommands	setCommands() Get ReactiveSetCommands.
ReactiveStringCommands	stringCommands() Get ReactiveStringCommands.
ReactiveZSetCommands	zSetCommands() Get ReactiveZSetCommands.

Methods inherited from class java.lang.Object

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

Constructor Detail

LettuceReactiveRedisConnection

public LettuceReactiveRedisConnection(com.lambdaworks.redis.AbstractRedisClient client)

Method Detail

keyCommands

public ReactiveKeyCommands keyCommands()

Description copied from interface: ReactiveRedisConnection

Get ReactiveKeyCommands.

Specified by:

keyCommands in interface ReactiveRedisConnection

Returns:

never null.

stringCommands

public ReactiveStringCommands stringCommands()

Description copied from interface: ReactiveRedisConnection

Get ReactiveStringCommands.

Specified by:

stringCommands in interface ReactiveRedisConnection

Returns:

never null.

numberCommands

public ReactiveNumberCommands numberCommands()

Description copied from interface: ReactiveRedisConnection

Get ReactiveNumberCommands

Specified by:

numberCommands in interface ReactiveRedisConnection

Returns:

never null.

listCommands

public ReactiveListCommands listCommands()

Description copied from interface: ReactiveRedisConnection

Get ReactiveListCommands.

Specified by:

listCommands in interface ReactiveRedisConnection

Returns:

never null.

setCommands

public ReactiveSetCommands setCommands()

Description copied from interface: ReactiveRedisConnection

Get ReactiveSetCommands.

Specified by:

setCommands in interface ReactiveRedisConnection

Returns:

never null.

zSetCommands

public ReactiveZSetCommands zSetCommands()

Description copied from interface: ReactiveRedisConnection

Get ReactiveZSetCommands.

Specified by:

zSetCommands in interface ReactiveRedisConnection

Returns:

never null.

hashCommands

public ReactiveHashCommands hashCommands()

Description copied from interface: ReactiveRedisConnection

Get ReactiveHashCommands.

Specified by:

hashCommands in interface ReactiveRedisConnection

Returns:

geoCommands

public ReactiveGeoCommands geoCommands()

Description copied from interface: ReactiveRedisConnection

Get ReactiveGeoCommands

Specified by:

geoCommands in interface ReactiveRedisConnection

Returns:

never null.

hyperLogLogCommands

public ReactiveHyperLogLogCommands hyperLogLogCommands()

Description copied from interface: ReactiveRedisConnection

Get ReactiveHyperLogLogCommands.

Specified by:

hyperLogLogCommands in interface ReactiveRedisConnection

Returns:

never null.

execute

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

Parameters:

callback -

Returns:

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

getConnection

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

getCommands

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