Package org.redisson.spring.data.connection

Class RedissonReactiveRedisClusterConnection

java.lang.Object

org.redisson.spring.data.connection.RedissonReactiveRedisConnection

org.redisson.spring.data.connection.RedissonReactiveRedisClusterConnection

All Implemented Interfaces:

Closeable, AutoCloseable, org.springframework.data.redis.connection.ReactiveRedisClusterConnection, org.springframework.data.redis.connection.ReactiveRedisConnection

public class RedissonReactiveRedisClusterConnection
extends RedissonReactiveRedisConnection
implements org.springframework.data.redis.connection.ReactiveRedisClusterConnection

Author:

Nikita Koksharov

Nested Class Summary

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

org.springframework.data.redis.connection.ReactiveRedisConnection.AbsentByteBufferResponse<I extends Object>, org.springframework.data.redis.connection.ReactiveRedisConnection.BooleanResponse<I extends Object>, org.springframework.data.redis.connection.ReactiveRedisConnection.ByteBufferResponse<I extends Object>, org.springframework.data.redis.connection.ReactiveRedisConnection.Command, org.springframework.data.redis.connection.ReactiveRedisConnection.CommandResponse<I extends Object,O extends Object>, org.springframework.data.redis.connection.ReactiveRedisConnection.KeyCommand, org.springframework.data.redis.connection.ReactiveRedisConnection.KeyScanCommand, org.springframework.data.redis.connection.ReactiveRedisConnection.MultiValueResponse<I extends Object,O extends Object>, org.springframework.data.redis.connection.ReactiveRedisConnection.NumericResponse<I extends Object,O extends Number>, org.springframework.data.redis.connection.ReactiveRedisConnection.RangeCommand

Constructor Summary

Constructors

Constructor	Description
RedissonReactiveRedisClusterConnection(CommandReactiveExecutor executorService)

Method Summary

Modifier and Type	Method	Description
org.springframework.data.redis.connection.ReactiveClusterGeoCommands	geoCommands()
org.springframework.data.redis.connection.ReactiveClusterHashCommands	hashCommands()
org.springframework.data.redis.connection.ReactiveClusterHyperLogLogCommands	hyperLogLogCommands()
org.springframework.data.redis.connection.ReactiveClusterKeyCommands	keyCommands()
org.springframework.data.redis.connection.ReactiveClusterListCommands	listCommands()
org.springframework.data.redis.connection.ReactiveClusterNumberCommands	numberCommands()
reactor.core.publisher.Mono<String>	ping(org.springframework.data.redis.connection.RedisClusterNode node)
org.springframework.data.redis.connection.ReactiveClusterServerCommands	serverCommands()
org.springframework.data.redis.connection.ReactiveClusterSetCommands	setCommands()
org.springframework.data.redis.connection.ReactiveClusterStringCommands	stringCommands()
static byte[]	toByteArray(ByteBuffer buffer)
org.springframework.data.redis.connection.ReactiveClusterZSetCommands	zSetCommands()

Methods inherited from class org.redisson.spring.data.connection.RedissonReactiveRedisConnection

closeLater, ping, pubSubCommands, scriptingCommands

Methods inherited from class java.lang.Object

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

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

close, closeLater, ping, pubSubCommands, scriptingCommands

Constructor Detail

RedissonReactiveRedisClusterConnection

public RedissonReactiveRedisClusterConnection(CommandReactiveExecutor executorService)

Method Detail

keyCommands

public org.springframework.data.redis.connection.ReactiveClusterKeyCommands keyCommands()

Specified by:

keyCommands in interface org.springframework.data.redis.connection.ReactiveRedisClusterConnection

Specified by:

keyCommands in interface org.springframework.data.redis.connection.ReactiveRedisConnection

Overrides:

keyCommands in class RedissonReactiveRedisConnection

stringCommands

public org.springframework.data.redis.connection.ReactiveClusterStringCommands stringCommands()

Specified by:

stringCommands in interface org.springframework.data.redis.connection.ReactiveRedisClusterConnection

Specified by:

stringCommands in interface org.springframework.data.redis.connection.ReactiveRedisConnection

Overrides:

stringCommands in class RedissonReactiveRedisConnection

numberCommands

public org.springframework.data.redis.connection.ReactiveClusterNumberCommands numberCommands()

Specified by:

numberCommands in interface org.springframework.data.redis.connection.ReactiveRedisClusterConnection

Specified by:

numberCommands in interface org.springframework.data.redis.connection.ReactiveRedisConnection

Overrides:

numberCommands in class RedissonReactiveRedisConnection

listCommands

public org.springframework.data.redis.connection.ReactiveClusterListCommands listCommands()

Specified by:

listCommands in interface org.springframework.data.redis.connection.ReactiveRedisClusterConnection

Specified by:

listCommands in interface org.springframework.data.redis.connection.ReactiveRedisConnection

Overrides:

listCommands in class RedissonReactiveRedisConnection

setCommands

public org.springframework.data.redis.connection.ReactiveClusterSetCommands setCommands()

Specified by:

setCommands in interface org.springframework.data.redis.connection.ReactiveRedisClusterConnection

Specified by:

setCommands in interface org.springframework.data.redis.connection.ReactiveRedisConnection

Overrides:

setCommands in class RedissonReactiveRedisConnection

zSetCommands

public org.springframework.data.redis.connection.ReactiveClusterZSetCommands zSetCommands()

Specified by:

zSetCommands in interface org.springframework.data.redis.connection.ReactiveRedisClusterConnection

Specified by:

zSetCommands in interface org.springframework.data.redis.connection.ReactiveRedisConnection

Overrides:

zSetCommands in class RedissonReactiveRedisConnection

hashCommands

public org.springframework.data.redis.connection.ReactiveClusterHashCommands hashCommands()

Specified by:

hashCommands in interface org.springframework.data.redis.connection.ReactiveRedisClusterConnection

Specified by:

hashCommands in interface org.springframework.data.redis.connection.ReactiveRedisConnection

Overrides:

hashCommands in class RedissonReactiveRedisConnection

geoCommands

public org.springframework.data.redis.connection.ReactiveClusterGeoCommands geoCommands()

Specified by:

geoCommands in interface org.springframework.data.redis.connection.ReactiveRedisClusterConnection

Specified by:

geoCommands in interface org.springframework.data.redis.connection.ReactiveRedisConnection

Overrides:

geoCommands in class RedissonReactiveRedisConnection

hyperLogLogCommands

public org.springframework.data.redis.connection.ReactiveClusterHyperLogLogCommands hyperLogLogCommands()

Specified by:

hyperLogLogCommands in interface org.springframework.data.redis.connection.ReactiveRedisClusterConnection

Specified by:

hyperLogLogCommands in interface org.springframework.data.redis.connection.ReactiveRedisConnection

Overrides:

hyperLogLogCommands in class RedissonReactiveRedisConnection

serverCommands

public org.springframework.data.redis.connection.ReactiveClusterServerCommands serverCommands()

Specified by:

serverCommands in interface org.springframework.data.redis.connection.ReactiveRedisClusterConnection

Specified by:

serverCommands in interface org.springframework.data.redis.connection.ReactiveRedisConnection

Overrides:

serverCommands in class RedissonReactiveRedisConnection

ping

public reactor.core.publisher.Mono<String> ping(org.springframework.data.redis.connection.RedisClusterNode node)

Specified by:

ping in interface org.springframework.data.redis.connection.ReactiveRedisClusterConnection

toByteArray

public static byte[] toByteArray(ByteBuffer buffer)