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 Summary

    Constructors
    Constructor
    Description
    ServiceDiscoveryHandler()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.v1.GetModuleResponse>
    getModuleById(String moduleId)
    Get module by ID
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.v1.GetModuleResponse>
    getModuleByName(String moduleName)
    Get module by name
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.v1.GetServiceResponse>
    getServiceById(String serviceId)
    Get service by ID
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.v1.GetServiceResponse>
    getServiceByName(String serviceName)
    Get service by name (returns first healthy instance)
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.v1.ListPlatformModulesResponse>
    listModules()
    List all modules
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.v1.ListServicesResponse>
    listServices()
    List all services (non-modules)
    io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.v1.ResolveServiceResponse>
    resolveService(ai.pipestream.platform.registration.v1.ResolveServiceRequest request)
    Resolve service to find the best available instance
    io.smallrye.mutiny.Multi<ai.pipestream.platform.registration.v1.WatchModulesResponse>
    watchModules()
    Watch for real-time updates to the list of all registered modules.
    io.smallrye.mutiny.Multi<ai.pipestream.platform.registration.v1.WatchServicesResponse>
    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.v1.ListServicesResponse> listServices()
      List all services (non-modules)

    • listModules

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

    • getServiceByName

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

    • getServiceById

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

    • getModuleByName

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

    • getModuleById

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

    • resolveService

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

    • watchServices

      public io.smallrye.mutiny.Multi<ai.pipestream.platform.registration.v1.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<ai.pipestream.platform.registration.v1.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.