io.lettuce.core.failover.health

Class AbstractHealthCheckStrategy

java.lang.Object

io.lettuce.core.failover.health.AbstractHealthCheckStrategy

All Implemented Interfaces:

HealthCheckStrategy, Closeable, AutoCloseable

@Experimental
public class AbstractHealthCheckStrategy
extends Object
implements HealthCheckStrategy

Abstract base class for health check strategies.

This class provides a basic implementation of the HealthCheckStrategy interface. It can be extended to implement custom health check strategies.

• Application-specific health validation logic
• Integration with external monitoring systems
• Custom performance or latency-based health checks

Since:

7.4

Author:

Ivo Gaydazhiev

Nested Class Summary

Nested classes/interfaces inherited from interface io.lettuce.core.failover.health.HealthCheckStrategy

HealthCheckStrategy.Config

Constructor Summary

Constructors

Constructor and Description
AbstractHealthCheckStrategy(HealthCheckStrategy.Config config)

Method Summary

Modifier and Type	Method and Description
HealthStatus	doHealthCheck(RedisURI endpoint) Implement custom health check logic
int	getDelayInBetweenProbes() Get the delay (in milliseconds) between retries for failed health checks.
int	getInterval() Get the interval (in milliseconds) between health checks.
int	getNumProbes() Get the number of probes for health checks to repeat.
ProbingPolicy	getPolicy() Get the policy for health checks.
int	getTimeout() Get the timeout (in milliseconds) for a health check.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.lettuce.core.failover.health.HealthCheckStrategy

close

Constructor Detail

AbstractHealthCheckStrategy

public AbstractHealthCheckStrategy(HealthCheckStrategy.Config config)

Method Detail

doHealthCheck

public HealthStatus doHealthCheck(RedisURI endpoint)

Implement custom health check logic

Specified by:

doHealthCheck in interface HealthCheckStrategy

Parameters:

endpoint - the endpoint to check

Returns:

one of HealthStatus.HEALTHY, HealthStatus.UNHEALTHY, or HealthStatus.UNKNOWN

getInterval

public int getInterval()

Description copied from interface: HealthCheckStrategy

Get the interval (in milliseconds) between health checks.

Specified by:

getInterval in interface HealthCheckStrategy

Returns:

the interval in milliseconds

getTimeout

public int getTimeout()

Description copied from interface: HealthCheckStrategy

Get the timeout (in milliseconds) for a health check.

Specified by:

getTimeout in interface HealthCheckStrategy

Returns:

the timeout in milliseconds

getNumProbes

public int getNumProbes()

Description copied from interface: HealthCheckStrategy

Get the number of probes for health checks to repeat.

Specified by:

getNumProbes in interface HealthCheckStrategy

Returns:

the number of probes

getDelayInBetweenProbes

public int getDelayInBetweenProbes()

Description copied from interface: HealthCheckStrategy

Get the delay (in milliseconds) between retries for failed health checks.

Specified by:

getDelayInBetweenProbes in interface HealthCheckStrategy

Returns:

the delay in milliseconds

getPolicy

public ProbingPolicy getPolicy()

Description copied from interface: HealthCheckStrategy

Get the policy for health checks.

Specified by:

getPolicy in interface HealthCheckStrategy

Returns:

the policy