io.lettuce.core.failover.api

Interface BaseRedisMultiDbConnection

All Superinterfaces:

AutoCloseable, Closeable

All Known Subinterfaces:

StatefulRedisMultiDbConnection<K,V>, StatefulRedisMultiDbPubSubConnection<K,V>

@Experimental
public interface BaseRedisMultiDbConnection
extends Closeable

Since:

7.4

Author:

Ali Takavci

Method Summary

Modifier and Type	Method and Description
void	addDatabase(DatabaseConfig databaseConfig) Add a new database to the multi-database connection.
void	addDatabase(RedisURI redisURI, float weight) Add a new database to the multi-database connection.
RedisDatabase	getCurrentDatabase() Get the current database.
RedisURI	getCurrentEndpoint() Get the current database endpoint.
RedisDatabase	getDatabase(RedisURI endpoint) Get the RedisDatabase for a specific endpoint.
Iterable<RedisURI>	getEndpoints() Get all available database endpoints.
boolean	isHealthy(RedisURI endpoint) Check if an endpoint is healthy (health status is HEALTHY and circuit breaker is CLOSED).
void	removeDatabase(RedisURI redisURI) Remove a database from the multi-database connection.
void	switchTo(RedisURI redisURI) Switch to a different database.

Methods inherited from interface java.io.Closeable

close

Method Detail

switchTo

void switchTo(RedisURI redisURI)

Switch to a different database.

This method performs a thread-safe switch to the specified database endpoint. If the target database is already the current database, this is a no-op. The method verifies that the target database is healthy and has a closed circuit breaker before switching.

Parameters:

redisURI - the Redis URI of the database to switch to, must not be null

Throws:

IllegalArgumentException - if the database endpoint is not registered in the connection map

IllegalStateException - if the requested database is unhealthy or circuit breaker is open, or if the requested database is a different instance than registered in connection map but with the same target endpoint/uri, or if the switch operation fails

UnsupportedOperationException - if the source or destination endpoint cannot be located

getCurrentEndpoint

RedisURI getCurrentEndpoint()

Get the current database endpoint.

Returns:

the current database endpoint

getCurrentDatabase

RedisDatabase getCurrentDatabase()

Get the current database.

Returns:

the current database

getEndpoints

Iterable<RedisURI> getEndpoints()

Get all available database endpoints.

Returns:

an iterable of all database endpoints

isHealthy

boolean isHealthy(RedisURI endpoint)

Check if an endpoint is healthy (health status is HEALTHY and circuit breaker is CLOSED).

Parameters:

endpoint - the Redis endpoint URI

Returns:

true if the endpoint is healthy (HEALTHY status and CLOSED circuit breaker), false otherwise

Throws:

IllegalArgumentException - if the endpoint is not known

getDatabase

RedisDatabase getDatabase(RedisURI endpoint)

Get the RedisDatabase for a specific endpoint.

Parameters:

endpoint - the Redis endpoint URI

Returns:

the RedisDatabase for the endpoint

Throws:

IllegalArgumentException - if the endpoint is not known

addDatabase

void addDatabase(RedisURI redisURI,
                 float weight)

Add a new database to the multi-database connection.

Parameters:

redisURI - the Redis URI for the new database, must not be null

weight - the weight for endpoint priority, must be greater than 0

Throws:

IllegalArgumentException - if the database already exists or parameters are invalid

addDatabase

void addDatabase(DatabaseConfig databaseConfig)

Add a new database to the multi-database connection.

Parameters:

databaseConfig - the database configuration, must not be null

Throws:

IllegalArgumentException - if the database already exists or configuration is invalid

removeDatabase

void removeDatabase(RedisURI redisURI)

Remove a database from the multi-database connection.

Parameters:

redisURI - the Redis URI of the database to remove, must not be null

Throws:

IllegalArgumentException - if the database does not exist

UnsupportedOperationException - if attempting to remove the currently active database