Package ai.pipestream.registration.handlers

Class ServiceDiscoveryHandler

java.lang.Object
ai.pipestream.registration.handlers.ServiceDiscoveryHandler
@ApplicationScoped public class ServiceDiscoveryHandler extends Object
Handles service discovery and lookup operations. Updated to use the new VerbNoun proto naming convention.

  • Constructor Details

    • ServiceDiscoveryHandler

      public ServiceDiscoveryHandler()

  • Method Details

    • listServices

      public io.smallrye.mutiny.Uni<ListServicesResponse> listServices()
      List all services (non-modules)

    • listModules

      public io.smallrye.mutiny.Uni<ListModulesResponse> listModules()
      List all modules

    • getServiceByName

      public io.smallrye.mutiny.Uni<GetServiceResponse> getServiceByName(String serviceName)
      Get service by name (returns first healthy instance)

    • getServiceById

      public io.smallrye.mutiny.Uni<GetServiceResponse> getServiceById(String serviceId)
      Get service by ID

    • getModuleByName

      public io.smallrye.mutiny.Uni<GetModuleResponse> getModuleByName(String moduleName)
      Get module by name

    • getModuleById

      public io.smallrye.mutiny.Uni<GetModuleResponse> getModuleById(String moduleId)
      Get module by ID

    • resolveService

      public io.smallrye.mutiny.Uni<ResolveServiceResponse> resolveService(ResolveServiceRequest request)
      Resolve service to find the best available instance

    • watchServices

      public io.smallrye.mutiny.Multi<WatchServicesResponse> watchServices()
      Watch for real-time updates to the list of all healthy services. Sends an initial list immediately, then sends updates whenever services change.

    • watchModules

      public io.smallrye.mutiny.Multi<WatchModulesResponse> watchModules()
      Watch for real-time updates to the list of all registered modules. Sends an initial list immediately, then sends updates whenever modules change.