Package io.deephaven.enterprise.resolver

Class DeephavenNameResolver

java.lang.Object

io.grpc.NameResolver

io.deephaven.enterprise.resolver.DeephavenNameResolver

Direct Known Subclasses:

DeephavenEtcdNameResolver, DeephavenHttpNameResolver

public abstract class DeephavenNameResolver
extends io.grpc.NameResolver

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.NameResolver

io.grpc.NameResolver.Args, io.grpc.NameResolver.ConfigOrError, io.grpc.NameResolver.Factory, io.grpc.NameResolver.Listener, io.grpc.NameResolver.Listener2, io.grpc.NameResolver.ResolutionResult, io.grpc.NameResolver.ResolutionResultAttr, io.grpc.NameResolver.ServiceConfigParser

Field Summary

Fields

Modifier and Type	Field	Description
protected final io.grpc.NameResolver.Args	args
protected io.grpc.NameResolver.Listener2	listener
protected final String	servicePath

Fields inherited from class io.grpc.NameResolver

ATTR_BACKEND_SERVICE

Constructor Summary

Constructors

Constructor	Description
DeephavenNameResolver(String servicePath, io.grpc.NameResolver.Args args)

Method Summary

Modifier and Type	Method	Description
protected abstract ResolverContext	ctx()
static List<io.grpc.EquivalentAddressGroup>	getAddresses(boolean overrideAuthorityToHost, HostPort[] hostPorts)
String	getServiceAuthority()
String	getServicePath()
protected abstract String	logPfx()
protected void	logResolveResult(String caller, List<io.grpc.EquivalentAddressGroup> addresses, io.grpc.NameResolver.ConfigOrError configOrError)
static io.grpc.EquivalentAddressGroup	makeEquivalentAddressGroup(boolean attrAuthorityOverrideToHost, String host, int port)
void	refresh()
protected abstract void	resolveInternal(String caller)
void	shutdown()
void	start(io.grpc.NameResolver.Listener2 listener)
protected io.grpc.NameResolver.ConfigOrError	tryCreateManagedChannelServiceConfigFromJsonString(String json)

Methods inherited from class io.grpc.NameResolver

start

Methods inherited from class java.lang.Object

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

Field Details

servicePath

protected final String servicePath

args

protected final io.grpc.NameResolver.Args args

listener

protected io.grpc.NameResolver.Listener2 listener

Constructor Details

DeephavenNameResolver

public DeephavenNameResolver(String servicePath,
 io.grpc.NameResolver.Args args)

Method Details

resolveInternal

protected abstract void resolveInternal(String caller)

ctx

protected abstract ResolverContext ctx()

logPfx

protected abstract String logPfx()

getServiceAuthority

public String getServiceAuthority()

Specified by:

getServiceAuthority in class io.grpc.NameResolver

getServicePath

public String getServicePath()

start

public void start(io.grpc.NameResolver.Listener2 listener)

Overrides:

start in class io.grpc.NameResolver

refresh

public void refresh()

Overrides:

refresh in class io.grpc.NameResolver

shutdown

public void shutdown()

Specified by:

shutdown in class io.grpc.NameResolver

getAddresses

public static List<io.grpc.EquivalentAddressGroup> getAddresses(boolean overrideAuthorityToHost,
 HostPort[] hostPorts)

makeEquivalentAddressGroup

public static io.grpc.EquivalentAddressGroup makeEquivalentAddressGroup(boolean attrAuthorityOverrideToHost,
 String host,
 int port)

tryCreateManagedChannelServiceConfigFromJsonString

protected io.grpc.NameResolver.ConfigOrError tryCreateManagedChannelServiceConfigFromJsonString(String json)

logResolveResult

protected void logResolveResult(String caller,
 List<io.grpc.EquivalentAddressGroup> addresses,
 io.grpc.NameResolver.ConfigOrError configOrError)