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 the unified RegisterRequest from the new proto API.

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(RegisterRequest 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(RegisterRequest request,
 String serviceId)

Register a service with Consul including health check configuration.

Parameters:

request - The unified RegisterRequest (works for both services and modules)

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