Package | Description |
---|---|
io.smallrye.reactive.messaging.health | |
io.smallrye.reactive.messaging.kafka.health | |
io.smallrye.reactive.messaging.kafka.impl |
Modifier and Type | Method and Description |
---|---|
HealthReport.HealthReportBuilder |
HealthReport.HealthReportBuilder.add(HealthReport.ChannelInfo info)
Adds a channel info to the report.
|
HealthReport.HealthReportBuilder |
HealthReport.HealthReportBuilder.add(String channel,
boolean ok)
Adds a channel info to the report.
|
HealthReport.HealthReportBuilder |
HealthReport.HealthReportBuilder.add(String channel,
boolean ok,
String message)
Adds a channel info to the report.
|
static HealthReport.HealthReportBuilder |
HealthReport.builder() |
Modifier and Type | Method and Description |
---|---|
protected void |
KafkaSinkReadinessHealth.adminBasedHealthCheck(HealthReport.HealthReportBuilder builder) |
protected void |
KafkaSourceReadinessHealth.adminBasedHealthCheck(HealthReport.HealthReportBuilder builder) |
protected abstract void |
BaseHealth.adminBasedHealthCheck(HealthReport.HealthReportBuilder builder) |
void |
BaseHealth.isReady(HealthReport.HealthReportBuilder builder) |
protected void |
KafkaSinkReadinessHealth.metricsBasedHealthCheck(HealthReport.HealthReportBuilder builder) |
protected void |
KafkaSourceReadinessHealth.metricsBasedHealthCheck(HealthReport.HealthReportBuilder builder) |
protected abstract void |
BaseHealth.metricsBasedHealthCheck(HealthReport.HealthReportBuilder builder) |
Modifier and Type | Method and Description |
---|---|
void |
KafkaSink.isAlive(HealthReport.HealthReportBuilder builder) |
void |
KafkaSource.isAlive(HealthReport.HealthReportBuilder builder) |
void |
KafkaSink.isReady(HealthReport.HealthReportBuilder builder) |
void |
KafkaSource.isReady(HealthReport.HealthReportBuilder builder) |
Copyright © 2018–2021 SmallRye. All rights reserved.