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

  • Constructor Summary

    Constructors
    Constructor
    Description
    ServiceDiscoveryHandler()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.ModuleDetails>
    getModuleById(String moduleId)
    Get module by ID
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.ModuleDetails>
    getModuleByName(String moduleName)
    Get module by name
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.ServiceDetails>
    getServiceById(String serviceId)
    Get service by ID
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.ServiceDetails>
    getServiceByName(String serviceName)
    Get service by name (returns first healthy instance)
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.ModuleListResponse>
    listModules()
    List all modules
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.ServiceListResponse>
    listServices()
    List all services (non-modules)
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.ServiceResolveResponse>
    resolveService(ai.pipestream.platform.registration.ServiceResolveRequest request)
    Resolve service to find the best available instance
    io.smallrye.mutiny.Multi<ai.pipestream.platform.registration.ModuleListResponse>
    watchModules()
    Watch for real-time updates to the list of all registered modules.
    io.smallrye.mutiny.Multi<ai.pipestream.platform.registration.ServiceListResponse>
    watchServices()
    Watch for real-time updates to the list of all healthy services.

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • ServiceDiscoveryHandler

      public ServiceDiscoveryHandler()

  • Method Details

    • listServices

      public io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.ServiceListResponse> listServices()
      List all services (non-modules)

    • listModules

      public io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.ModuleListResponse> listModules()
      List all modules

    • getServiceByName

      public io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.ServiceDetails> getServiceByName(String serviceName)
      Get service by name (returns first healthy instance)

    • getServiceById

      public io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.ServiceDetails> getServiceById(String serviceId)
      Get service by ID

    • getModuleByName

      public io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.ModuleDetails> getModuleByName(String moduleName)
      Get module by name

    • getModuleById

      public io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.ModuleDetails> getModuleById(String moduleId)
      Get module by ID

    • resolveService

      public io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.ServiceResolveResponse> resolveService(ai.pipestream.platform.registration.ServiceResolveRequest request)
      Resolve service to find the best available instance

    • watchServices

      public io.smallrye.mutiny.Multi<ai.pipestream.platform.registration.ServiceListResponse> 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<ai.pipestream.platform.registration.ModuleListResponse> watchModules()
      Watch for real-time updates to the list of all registered modules. Sends an initial list immediately, then sends updates whenever modules change.