Class CassandraDriverReactiveHealthIndicator

java.lang.Object

org.springframework.boot.health.contributor.AbstractReactiveHealthIndicator

org.springframework.boot.cassandra.health.CassandraDriverReactiveHealthIndicator

All Implemented Interfaces:

ReactiveHealthContributor, ReactiveHealthIndicator

public class CassandraDriverReactiveHealthIndicator
extends AbstractReactiveHealthIndicator

Simple implementation of a ReactiveHealthIndicator returning status information for Cassandra data stores.

Since:

4.0.0

Author:

Alexandre Dutra, Tomasz Lelek

Constructor Summary

Constructors

Constructor	Description
CassandraDriverReactiveHealthIndicator(com.datastax.oss.driver.api.core.CqlSession session)	Create a new CassandraDriverReactiveHealthIndicator instance.

Method Summary

Modifier and Type	Method	Description
protected reactor.core.publisher.Mono<Health>	doHealthCheck(Health.Builder builder)	Actual health check logic.

Methods inherited from class AbstractReactiveHealthIndicator

health

Methods inherited from class Object

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

Methods inherited from interface ReactiveHealthIndicator

asHealthContributor, health

Constructor Details

CassandraDriverReactiveHealthIndicator

public CassandraDriverReactiveHealthIndicator(com.datastax.oss.driver.api.core.CqlSession session)

Create a new CassandraDriverReactiveHealthIndicator instance.

Parameters:

session - the CqlSession.

Method Details

doHealthCheck

protected reactor.core.publisher.Mono<Health> doHealthCheck(Health.Builder builder)

Description copied from class: AbstractReactiveHealthIndicator

Actual health check logic. If an error occurs in the pipeline, it will be handled automatically.

Specified by:

doHealthCheck in class AbstractReactiveHealthIndicator

Parameters:

builder - the Health.Builder to report health status and details

Returns:

a Mono that provides the Health