Package ai.pipestream.registration.consul

Class ConsulHealthChecker

java.lang.Object

ai.pipestream.registration.consul.ConsulHealthChecker

@ApplicationScoped
public class ConsulHealthChecker
extends Object

Handles health check operations for services registered with Consul

Constructor Summary

Constructors

Constructor	Description
ConsulHealthChecker()

Method Summary

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<Boolean>	waitForHealthy(String serviceName, String serviceId)	Wait for a service to become healthy in Consul's view

Methods inherited from class java.lang.Object

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

Constructor Details

ConsulHealthChecker

public ConsulHealthChecker()

Method Details

waitForHealthy

public io.smallrye.mutiny.Uni<Boolean> waitForHealthy(String serviceName,
 String serviceId)

Wait for a service to become healthy in Consul's view

Parameters:

serviceName - The Consul service name (used for health API query)

serviceId - The full service ID (serviceName-host-port)

Returns:

Uni true if service becomes healthy, false if timeout