Package ai.pipestream.dynamic.grpc.client

Class DynamicGrpcClientFactory

java.lang.Object

ai.pipestream.dynamic.grpc.client.DynamicGrpcClientFactory

All Implemented Interfaces:

GrpcClientFactory

@ApplicationScoped
public class DynamicGrpcClientFactory
extends Object
implements GrpcClientFactory

Factory for creating Mutiny gRPC clients using dynamic service discovery. This factory ensures the service is defined in Stork, discovers instances, obtains a Channel from ChannelManager, and produces Mutiny stubs on demand.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DynamicGrpcClientFactory.StorkNameResolver
static class	DynamicGrpcClientFactory.StorkNameResolverProvider	NameResolverProvider that uses SmallRye Stork to resolve service instances for a logical service name into gRPC address groups.

Constructor Summary

Constructors

Constructor	Description
DynamicGrpcClientFactory()	Default constructor for CDI frameworks.

Method Summary

Modifier and Type	Method	Description
void	evictChannel(String serviceName)	Evict (close) a cached channel for a service to force reconnection.
int	getActiveServiceCount()	Get the number of active service connections being managed.
String	getCacheStats()	Get cache statistics for debugging and monitoring.
io.smallrye.mutiny.Uni<io.grpc.Channel>	getChannel(String serviceName)	Get a raw Channel for advanced use cases.
<T extends io.quarkus.grpc.MutinyStub> io.smallrye.mutiny.Uni<T>	getClient(String serviceName, Function<io.grpc.Channel,T> stubCreator)	Get a typed Mutiny stub using a method reference (zero reflection).

Methods inherited from class java.lang.Object

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

Constructor Details

DynamicGrpcClientFactory

public DynamicGrpcClientFactory()

Default constructor for CDI frameworks.

Method Details

getClient

public <T extends io.quarkus.grpc.MutinyStub>
io.smallrye.mutiny.Uni<T> getClient(String serviceName,
 Function<io.grpc.Channel,T> stubCreator)

Get a typed Mutiny stub using a method reference (zero reflection).

Specified by:

getClient in interface GrpcClientFactory

Type Parameters:

T - The Mutiny stub type (must extend MutinyStub)

Parameters:

serviceName - The logical service name for discovery

stubCreator - Method reference to create stub (e.g., MutinyFooServiceGrpc::newMutinyStub)

Returns:

A Uni emitting the typed Stub

getChannel

public io.smallrye.mutiny.Uni<io.grpc.Channel> getChannel(String serviceName)

Description copied from interface: GrpcClientFactory

Get a raw Channel for advanced use cases.

Specified by:

getChannel in interface GrpcClientFactory

Parameters:

serviceName - The logical service name for discovery

Returns:

A Uni emitting the Channel

getActiveServiceCount

public int getActiveServiceCount()

Description copied from interface: GrpcClientFactory

Get the number of active service connections being managed.

Specified by:

getActiveServiceCount in interface GrpcClientFactory

evictChannel

public void evictChannel(String serviceName)

Description copied from interface: GrpcClientFactory

Evict (close) a cached channel for a service to force reconnection.

Specified by:

evictChannel in interface GrpcClientFactory

getCacheStats

public String getCacheStats()

Description copied from interface: GrpcClientFactory

Get cache statistics for debugging and monitoring.

Specified by:

getCacheStats in interface GrpcClientFactory