io.lettuce.core.sentinel.api

Interface StatefulRedisSentinelConnection<K,V>

Type Parameters:

K - Key type.

V - Value type.

All Superinterfaces:

AsyncCloseable, 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.
default <T> T	commands(CommandsFactory<StatefulRedisSentinelConnection<K,V>,T> factory) Returns the command API created by factory, bound to this connection.
RedisSentinelReactiveCommands<K,V>	reactive() Deprecated. since 7.8, use commands(CommandsFactory) with RedisSentinelReactiveCommands.factory() instead; scheduled for removal in a future major release.
RedisSentinelCommands<K,V>	sync() Returns the RedisSentinelCommands API for the current connection.

Methods inherited from interface io.lettuce.core.api.StatefulConnection

addListener, close, closeAsync, dispatch, dispatch, flushCommands, getCodec, getOptions, getResources, getTimeout, isOpen, removeListener, setAutoFlushCommands, setTimeout

Method Detail

sync

RedisSentinelCommands<K,V> sync()

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

Note: this accessor is scheduled for removal in a future major release; a commands(...)-based replacement is planned.

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.

Note: this accessor is scheduled for removal in a future major release; a commands(...)-based replacement is planned.

Returns:

the asynchronous API for the underlying connection.

reactive

@Deprecated
RedisSentinelReactiveCommands<K,V> reactive()

Deprecated. since 7.8, use commands(CommandsFactory) with RedisSentinelReactiveCommands.factory() instead; scheduled for removal in a future major release.

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

Returns:

the reactive API for the underlying connection.

commands

default <T> T commands(CommandsFactory<StatefulRedisSentinelConnection<K,V>,T> factory)

Returns the command API created by factory, bound to this connection. Does not create a new connection.

The command API is created once per connection and cached; calling this method again with the same factory returns the same instance.

Type Parameters:

T - the command API type

Parameters:

factory - the command API factory, must not be null

Returns:

the command API bound to this connection

Throws:

UnsupportedOperationException - if the connection implementation does not override this method. The default is provided only for source compatibility in Lettuce 7.x and becomes an abstract method in Lettuce 8.0.

Since:

7.8