Package ai.pipestream.dynamic.grpc.client

Class DynamicGrpcClientFactory.StorkNameResolverProvider

java.lang.Object

io.grpc.NameResolver.Factory

io.grpc.NameResolverProvider

ai.pipestream.dynamic.grpc.client.DynamicGrpcClientFactory.StorkNameResolverProvider

Enclosing class:

DynamicGrpcClientFactory

public static class DynamicGrpcClientFactory.StorkNameResolverProvider
extends io.grpc.NameResolverProvider

NameResolverProvider that uses SmallRye Stork to resolve service instances for a logical service name into gRPC address groups.

Constructor Summary

Constructors

Constructor	Description
StorkNameResolverProvider(String serviceName)	Creates a new StorkNameResolverProvider.

Method Summary

Modifier and Type	Method	Description
String	getDefaultScheme()
protected boolean	isAvailable()
io.grpc.NameResolver	newNameResolver(URI targetUri, io.grpc.NameResolver.Args args)
protected int	priority()

Methods inherited from class io.grpc.NameResolverProvider

getProducedSocketAddressTypes, getScheme

Methods inherited from class java.lang.Object

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

Constructor Details

StorkNameResolverProvider

public StorkNameResolverProvider(String serviceName)

Creates a new StorkNameResolverProvider.

Parameters:

serviceName - the logical service name to resolve

Method Details

isAvailable

protected boolean isAvailable()

Specified by:

isAvailable in class io.grpc.NameResolverProvider

priority

protected int priority()

Specified by:

priority in class io.grpc.NameResolverProvider

newNameResolver

public io.grpc.NameResolver newNameResolver(URI targetUri,
 io.grpc.NameResolver.Args args)

Specified by:

newNameResolver in class io.grpc.NameResolver.Factory

getDefaultScheme

public String getDefaultScheme()

Specified by:

getDefaultScheme in class io.grpc.NameResolver.Factory