io.smallrye.reactive.messaging.kafka.health

Class BaseHealth

java.lang.Object

io.smallrye.reactive.messaging.kafka.health.BaseHealth

Direct Known Subclasses:

KafkaSinkReadinessHealth, KafkaSourceReadinessHealth

public abstract class BaseHealth
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected String	channel
static String	CONNECTION_COUNT_METRIC_NAME

Constructor Summary

Constructors

Constructor and Description
BaseHealth(String channel)

Method Summary

Modifier and Type	Method and Description
protected abstract void	adminBasedHealthCheck(HealthReport.HealthReportBuilder builder)
void	close()
abstract io.vertx.mutiny.kafka.admin.KafkaAdminClient	getAdmin()
org.apache.kafka.common.Metric	getMetric(Map<org.apache.kafka.common.MetricName,? extends org.apache.kafka.common.Metric> metrics)
void	isReady(HealthReport.HealthReportBuilder builder)
protected abstract void	metricsBasedHealthCheck(HealthReport.HealthReportBuilder builder)

Methods inherited from class java.lang.Object

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

Field Detail

CONNECTION_COUNT_METRIC_NAME

public static final String CONNECTION_COUNT_METRIC_NAME

See Also:

Constant Field Values

channel

protected final String channel

Constructor Detail

BaseHealth

public BaseHealth(String channel)

Method Detail

close

public void close()

isReady

public void isReady(HealthReport.HealthReportBuilder builder)

getMetric

public org.apache.kafka.common.Metric getMetric(Map<org.apache.kafka.common.MetricName,? extends org.apache.kafka.common.Metric> metrics)

metricsBasedHealthCheck

protected abstract void metricsBasedHealthCheck(HealthReport.HealthReportBuilder builder)

adminBasedHealthCheck

protected abstract void adminBasedHealthCheck(HealthReport.HealthReportBuilder builder)

getAdmin

public abstract io.vertx.mutiny.kafka.admin.KafkaAdminClient getAdmin()