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. Module metadata is inline on RegisterRequest — no PipeStepProcessorService callback clients.

Constructor Summary

Constructors

Constructor	Description
RegistrationGrpcClients()

Method Summary

Modifier and Type	Method	Description
void	evictChannel(String serviceName)
int	getActiveServiceCount()
String	getCacheStats()
io.smallrye.mutiny.Uni<ai.pipestream.platform.registration.v1.MutinyPlatformRegistrationServiceGrpc.MutinyPlatformRegistrationServiceStub>	getPlatformRegistrationClient(String serviceName)	Get a PlatformRegistration client for a given service.

Methods inherited from class java.lang.Object

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

Constructor Details

RegistrationGrpcClients

public RegistrationGrpcClients()

Method Details

getPlatformRegistrationClient

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

evictChannel

public void evictChannel(String serviceName)

getCacheStats

public String getCacheStats()