Package ai.pipestream.platform.registration.client

Class RegistrationGrpcClients

java.lang.Object
ai.pipestream.platform.registration.client.RegistrationGrpcClients
@ApplicationScoped public class RegistrationGrpcClients extends Object
Service-specific gRPC client factory for platform-registration-service. Provides type-safe methods using method references (zero reflection).

  • Constructor Details

    • RegistrationGrpcClients

      public RegistrationGrpcClients()

  • Method Details

    • getPipeStepProcessorClient

      public io.smallrye.mutiny.Uni<MutinyPipeStepProcessorServiceGrpc.MutinyPipeStepProcessorServiceStub> getPipeStepProcessorClient(String serviceName)
      Get a PipeStepProcessor client for a given service.
      Parameters:
      serviceName - The logical service name for discovery
      Returns:
      A Uni emitting the PipeStepProcessor stub

    • getPlatformRegistrationClient

      public io.smallrye.mutiny.Uni<MutinyPlatformRegistrationServiceGrpc.MutinyPlatformRegistrationServiceStub> getPlatformRegistrationClient(String serviceName)
      Get a PlatformRegistration client for a given service.
      Parameters:
      serviceName - The logical service name for discovery
      Returns:
      A Uni emitting the PlatformRegistration stub

    • getActiveServiceCount

      public int getActiveServiceCount()
      Get the number of active service connections being managed.
      Returns:
      The count of active service channels

    • evictChannel

      public void evictChannel(String serviceName)
      Evict (close) a cached channel for a service to force reconnection.
      Parameters:
      serviceName - The service name to evict

    • getCacheStats

      public String getCacheStats()
      Get cache statistics for debugging and monitoring.
      Returns:
      String representation of cache statistics