Package io.deephaven.dhservice.client

Class EnvoyDiscoverySupportServiceGrpcImpl

java.lang.Object

io.deephaven.dhservice.client.EnvoyDiscoverySupportServiceGrpcImpl

All Implemented Interfaces:

AuthenticatedService, EnvoyDiscoverySupportService

public class EnvoyDiscoverySupportServiceGrpcImpl
extends Object
implements EnvoyDiscoverySupportService

Implementation of the ServiceRegistry API which sends requests over grpc to a remote server.

Nested Class Summary

Nested classes/interfaces inherited from interface io.deephaven.dhservice.client.AuthenticatedService

AuthenticatedService.DefaultImpl

Method Summary

Modifier and Type	Method	Description
boolean	authenticate()	Attempt default authentication if this is not already authenticated.
boolean	authenticate(@NotNull String keyFile)	Authenticate, or re-authenticate using the given private key file.
boolean	authenticate(@NotNull String user, @NotNull String password)	Authenticate, or re-authenticate using the given credentials.
boolean	authenticate(@NotNull String user, @NotNull String password, @Nullable String operateAsUser)	Authenticate, or re-authenticate using the given credentials.
UserContext	getAuthenticatedUser()
static EnvoyDiscoverySupportService	make()	Create an instance with the default config.
static EnvoyDiscoverySupportService	make(@NotNull ClientConnectionConfig configs)	Create an instance with the given config.
boolean	setTokenFactoryFactory(@Nullable TokenFactoryFactory tokenAuthenticationManager)	Set the authentication client manager to use for token generation.
void	setWorkerSnapshot(@NotNull String serviceId, @NotNull Collection<? extends WorkerStreamProvider.WorkerInfo> workersSnapshot)	Notify the system that the collection of workers has changed for the given serviceId.

Methods inherited from class java.lang.Object

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

Method Details

make

public static EnvoyDiscoverySupportService make(@NotNull
 @NotNull ClientConnectionConfig configs)

Create an instance with the given config.

Parameters:

configs - use this ClientConnectionConfig

Returns:

a new instance

make

public static EnvoyDiscoverySupportService make()
                                         throws IOException,
ClientConnectionConfigProvider.ProviderException

Create an instance with the default config.

Returns:

a new instance

Throws:

IOException - if an IO exception occurs while loading the client connection configuration

ClientConnectionConfigProvider.ProviderException - if a parsing exception occurs while processing the client connection configuration

setWorkerSnapshot

public void setWorkerSnapshot(@NotNull
 @NotNull String serviceId,
 @NotNull
 @NotNull Collection<? extends WorkerStreamProvider.WorkerInfo> workersSnapshot)

Description copied from interface: EnvoyDiscoverySupportService

Notify the system that the collection of workers has changed for the given serviceId.

Specified by:

setWorkerSnapshot in interface EnvoyDiscoverySupportService

Parameters:

serviceId - an identifier for this collection of workers

workersSnapshot - the current complete collection of workers for the serviceId

authenticate

public boolean authenticate()

Description copied from interface: AuthenticatedService

Attempt default authentication if this is not already authenticated.

Specified by:

authenticate in interface AuthenticatedService

Returns:

true if authentication succeeded, else false

authenticate

public boolean authenticate(@NotNull
 @NotNull String keyFile)

Description copied from interface: AuthenticatedService

Authenticate, or re-authenticate using the given private key file.

Specified by:

authenticate in interface AuthenticatedService

Returns:

true if authentication succeeded, else false

authenticate

public boolean authenticate(@NotNull
 @NotNull String user,
 @NotNull
 @NotNull String password,
 @Nullable
 @Nullable String operateAsUser)

Description copied from interface: AuthenticatedService

Authenticate, or re-authenticate using the given credentials.

Specified by:

authenticate in interface AuthenticatedService

Parameters:

user - user to authenticate

password - password for authentication

operateAsUser - optional operate-as user

Returns:

true if authentication succeeded, else false

authenticate

public boolean authenticate(@NotNull
 @NotNull String user,
 @NotNull
 @NotNull String password)

Description copied from interface: AuthenticatedService

Authenticate, or re-authenticate using the given credentials.

Specified by:

authenticate in interface AuthenticatedService

Parameters:

user - user to authenticate

password - password for authentication

Returns:

true if authentication succeeded, else false

setTokenFactoryFactory

public boolean setTokenFactoryFactory(@Nullable
 @Nullable TokenFactoryFactory tokenAuthenticationManager)

Description copied from interface: AuthenticatedService

Set the authentication client manager to use for token generation. If tokenAuthenticationManager is null or is not already authenticated, this call will de-authenticate the connection.

Specified by:

setTokenFactoryFactory in interface AuthenticatedService

Parameters:

tokenAuthenticationManager - the authentication client manager to be used for future calls.

Returns:

true if authentication succeeded, else false

getAuthenticatedUser

public UserContext getAuthenticatedUser()

Specified by:

getAuthenticatedUser in interface AuthenticatedService