Package io.grpc.netty

Class UdsNameResolver

java.lang.Object

io.grpc.NameResolver

io.grpc.netty.UdsNameResolver

final class UdsNameResolver
extends NameResolver

Nested Class Summary

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

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

Field Summary

Fields

Modifier and Type	Field	Description
private final String	authority
private NameResolver.Listener2	listener

Constructor Summary

Constructors

Constructor	Description
UdsNameResolver(String authority, String targetPath, NameResolver.Args args)

Method Summary

Modifier and Type	Method	Description
String	getServiceAuthority()	Returns the authority used to authenticate connections to servers.
void	refresh()	Re-resolve the name.
private void	resolve()
void	shutdown()	Stops the resolution.
void	start(NameResolver.Listener2 listener)	Starts the resolution.

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

listener

private NameResolver.Listener2 listener

authority

private final String authority

Constructor Details

UdsNameResolver

UdsNameResolver(String authority,
 String targetPath,
 NameResolver.Args args)

Method Details

getServiceAuthority

public String getServiceAuthority()

Description copied from class: NameResolver

Returns the authority used to authenticate connections to servers. It must be from a trusted source, because if the authority is tampered with, RPCs may be sent to the attackers which may leak sensitive user data.

An implementation must generate it without blocking, typically in line, and must keep it unchanged. NameResolvers created from the same factory with the same argument must return the same authority.

Specified by:

getServiceAuthority in class NameResolver

start

public void start(NameResolver.Listener2 listener)

Description copied from class: NameResolver

Starts the resolution. The method is not supposed to throw any exceptions. That might cause the Channel that the name resolver is serving to crash. Errors should be propagated through NameResolver.Listener2.onError(io.grpc.Status).

An instance may not be started more than once, by any overload of this method, even after an intervening call to NameResolver.shutdown().

Overrides:

start in class NameResolver

Parameters:

listener - used to receive updates on the target

refresh

public void refresh()

Description copied from class: NameResolver

Re-resolve the name.

Can only be called after NameResolver.start(io.grpc.NameResolver.Listener) has been called.

This is only a hint. Implementation takes it as a signal but may not start resolution immediately. It should never throw.

The default implementation is no-op.

Overrides:

refresh in class NameResolver

resolve

private void resolve()

shutdown

public void shutdown()

Description copied from class: NameResolver

Stops the resolution. Updates to the Listener will stop.

Specified by:

shutdown in class NameResolver