com.lambdaworks.redis.sentinel.api

Interface StatefulRedisSentinelConnection<K,V>

Type Parameters:

K - Key type.

V - Value type.

All Superinterfaces:

AutoCloseable, StatefulConnection<K,V>

All Known Implementing Classes:

StatefulRedisSentinelConnectionImpl

public interface StatefulRedisSentinelConnection<K,V>
extends StatefulConnection<K,V>

A thread-safe connection to a redis server. Multiple threads may share one StatefulRedisSentinelConnection. A ConnectionWatchdog monitors each connection and reconnects automatically until StatefulConnection.close() is called. All pending commands will be (re)sent after successful reconnection.

Since:

4.0

Author:

Mark Paluch

Method Summary

Modifier and Type	Method and Description
RedisSentinelAsyncCommands<K,V>	async() Returns the RedisSentinelAsyncCommands API for the current connection.
RedisSentinelReactiveCommands<K,V>	reactive() Returns the RedisSentinelReactiveCommands API for the current connection.
RedisSentinelCommands<K,V>	sync() Returns the RedisSentinelCommands API for the current connection.

Methods inherited from interface com.lambdaworks.redis.api.StatefulConnection

close, dispatch, flushCommands, getOptions, getTimeout, getTimeoutUnit, isOpen, reset, setAutoFlushCommands, setTimeout

Method Detail

sync

RedisSentinelCommands<K,V> sync()

Returns the RedisSentinelCommands API for the current connection. Does not create a new connection.

Returns:

the synchronous API for the underlying connection.

async

RedisSentinelAsyncCommands<K,V> async()

Returns the RedisSentinelAsyncCommands API for the current connection. Does not create a new connection. *

Returns:

the asynchronous API for the underlying connection.

reactive

RedisSentinelReactiveCommands<K,V> reactive()

Returns the RedisSentinelReactiveCommands API for the current connection. Does not create a new connection. *

Returns:

the reactive API for the underlying connection.