Package io.smallrye.reactive.messaging.kafka.health

Class BaseHealth

java.lang.Object

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

Direct Known Subclasses:

KafkaSinkHealth, KafkaSourceHealth

public abstract class BaseHealth
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected String	channel
static String	CONNECTION_COUNT_METRIC_NAME

Constructor Summary

Constructors

Constructor	Description
BaseHealth(String channel)

Method Summary

Modifier and Type	Method	Description
protected abstract void	clientBasedReadinessCheck(HealthReport.HealthReportBuilder builder)
protected abstract void	clientBasedStartupCheck(HealthReport.HealthReportBuilder builder)
void	close()
abstract KafkaAdmin	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)
void	isStarted(HealthReport.HealthReportBuilder builder)
protected abstract void	metricsBasedReadinessCheck(HealthReport.HealthReportBuilder builder)
protected abstract void	metricsBasedStartupCheck(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()

isStarted

public void isStarted(HealthReport.HealthReportBuilder builder)

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)

metricsBasedStartupCheck

protected abstract void metricsBasedStartupCheck(HealthReport.HealthReportBuilder builder)

metricsBasedReadinessCheck

protected abstract void metricsBasedReadinessCheck(HealthReport.HealthReportBuilder builder)

clientBasedStartupCheck

protected abstract void clientBasedStartupCheck(HealthReport.HealthReportBuilder builder)

clientBasedReadinessCheck

protected abstract void clientBasedReadinessCheck(HealthReport.HealthReportBuilder builder)

getAdmin

public abstract KafkaAdmin getAdmin()