org.springframework.data.redis.connection

Interface ReactiveRedisConnection

All Superinterfaces:

AutoCloseable, Closeable

All Known Subinterfaces:

ReactiveRedisClusterConnection

All Known Implementing Classes:

LettuceReactiveRedisClusterConnection, LettuceReactiveRedisConnection

public interface ReactiveRedisConnection
extends Closeable

Redis connection using reactive infrastructure declaring entry points for reactive command execution.

ReactiveRedisConnection is typically implemented by a stateful object that requires to be closed once it is no longer required.

Commands can be either executed by passing plain arguments like key, value or wrapped inside a command stream. Streaming command execution accepts Publisher of a particular ReactiveRedisConnection.Command. Commands are executed at the time their emission.

Arguments are binary-safe by using ByteBuffer arguments. Expect ByteBuffer to be consumed by ReactiveRedisConnection invocation or during execution. Any ByteBuffer used as method parameter should not be altered after invocation.

Since:

2.0

Author:

Christoph Strobl, Mark Paluch

See Also:

ReactiveRedisConnection.Command, ReactiveRedisConnection.CommandResponse, ReactiveRedisConnection.KeyCommand

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	ReactiveRedisConnection.BooleanResponse<I> ReactiveRedisConnection.CommandResponse implementation for Boolean responses.
static class	ReactiveRedisConnection.ByteBufferResponse<I> ReactiveRedisConnection.CommandResponse implementation for ByteBuffer responses.
static interface	ReactiveRedisConnection.Command Base interface for Redis commands executed with a reactive infrastructure.
static class	ReactiveRedisConnection.CommandResponse<I,O> Base class for command responses.
static class	ReactiveRedisConnection.KeyCommand ReactiveRedisConnection.Command for key-bound operations.
static class	ReactiveRedisConnection.MultiValueResponse<I,O> ReactiveRedisConnection.CommandResponse implementation for List responses.
static class	ReactiveRedisConnection.NumericResponse<I,O extends Number> ReactiveRedisConnection.CommandResponse implementation for numeric responses.
static class	ReactiveRedisConnection.RangeCommand

Method Summary

Modifier and Type	Method and Description
void	close()
ReactiveGeoCommands	geoCommands() Get ReactiveGeoCommands
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.

Method Detail

close

void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

keyCommands

ReactiveKeyCommands keyCommands()

Get ReactiveKeyCommands.

Returns:

never null.

stringCommands

ReactiveStringCommands stringCommands()

Get ReactiveStringCommands.

Returns:

never null.

numberCommands

ReactiveNumberCommands numberCommands()

Get ReactiveNumberCommands

Returns:

never null.

listCommands

ReactiveListCommands listCommands()

Get ReactiveListCommands.

Returns:

never null.

setCommands

ReactiveSetCommands setCommands()

Get ReactiveSetCommands.

Returns:

never null.

zSetCommands

ReactiveZSetCommands zSetCommands()

Get ReactiveZSetCommands.

Returns:

never null.

hashCommands

ReactiveHashCommands hashCommands()

Get ReactiveHashCommands.

Returns:

geoCommands

ReactiveGeoCommands geoCommands()

Get ReactiveGeoCommands

Returns:

never null.

hyperLogLogCommands

ReactiveHyperLogLogCommands hyperLogLogCommands()

Get ReactiveHyperLogLogCommands.

Returns:

never null.