Package ai.pipestream.registration.consul

Class ConsulRegistrar

java.lang.Object

ai.pipestream.registration.consul.ConsulRegistrar

@ApplicationScoped
public class ConsulRegistrar
extends Object

Handles service registration and unregistration with Consul. Updated to use schema-first RegisterServiceRequest.

Constructor Summary

Constructors

Constructor	Description
ConsulRegistrar()

Method Summary

Modifier and Type	Method	Description
static String	generateServiceId(String serviceName, String host, int port)	Generate a consistent service ID from service details
io.smallrye.mutiny.Uni<Boolean>	registerService(RegisterServiceRequest request, String serviceId)	Register a service with Consul including health check configuration.
io.smallrye.mutiny.Uni<Boolean>	unregisterService(String serviceId)	Unregister a service from Consul

Methods inherited from class java.lang.Object

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

Constructor Details

ConsulRegistrar

public ConsulRegistrar()

Method Details

registerService

public io.smallrye.mutiny.Uni<Boolean> registerService(RegisterServiceRequest request,
 String serviceId)

Register a service with Consul including health check configuration. * @param request The schema-first RegisterServiceRequest

Parameters:

serviceId - The unique Consul service ID to use

Returns:

A Uni indicating success or failure

unregisterService

public io.smallrye.mutiny.Uni<Boolean> unregisterService(String serviceId)

Unregister a service from Consul

generateServiceId

public static String generateServiceId(String serviceName,
 String host,
 int port)

Generate a consistent service ID from service details