Package io.deephaven.dhservice.client

Class UnifiedServiceGrpcImpl

java.lang.Object

io.deephaven.dhservice.client.AuthenticatedService.DefaultImpl

io.deephaven.dhservice.client.UnifiedServiceGrpcImpl

All Implemented Interfaces:

AuthenticatedService, UnifiedService, AutoCloseable

public final class UnifiedServiceGrpcImpl
extends AuthenticatedService.DefaultImpl
implements UnifiedService, AutoCloseable

Represents the single grpc server hosting multiple services served by the Configuration Server.

Nested Class Summary

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

AuthenticatedService.DefaultImpl

Method Summary

Modifier and Type	Method	Description
String	about()	Return information about this service.
boolean	authenticate()	Attempt default authentication if this is not already authenticated.
void	close()
protected void	finalize()
ConfigurationService	getConfigurationService()	Return an implementation of the ConfigurationService interface that provides data via a network connection to a service provider.
DataRoutingService	getDataRoutingService()	Return an implementation of the DataRoutingService interface that provides data via a network connection to a service provider.
protected @NotNull com.fishlib.io.logger.Logger	getLog()	Get a Logger from the implementation (which probably has one)
ServiceRegistryService	getProcessRegistry()	Return an implementation of the ProcessRegistry interface that provides data via a network connection to a service provider.
SchemaService	getSchemaService()	Return an implementation of the SchemaService interface that provides data via a network connection to a service provider.
EnvoyDiscoverySupportService	getServiceRegistry()	Return an implementation of the ServiceRegistry interface that provides data via a network connection to a service provider.
protected @Nullable TokenFactoryFactory	getTokenFactoryFactory()	Get the current TokenFactoryFactory from the implementation, for use in the authenticate method implementations
WritableDataRoutingService	getWritableDataRoutingService()	Return an implementation of the WritableDataRoutingService interface that provides data via a network connection to a service provider.
static UnifiedService	make()	Create an instance with default configs.
static UnifiedService	make(ClientConnectionConfig configs)	Create an instance with the given configs.
boolean	setTokenFactoryFactory(TokenFactoryFactory newTokenAuthenticationManager)	Send a token from the new authentication client manager to the server for validation.

Methods inherited from class io.deephaven.dhservice.client.AuthenticatedService.DefaultImpl

authenticate, authenticate, getAuthenticatedUser

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.deephaven.dhservice.client.AuthenticatedService

authenticate, authenticate, authenticate, getAuthenticatedUser

Method Details

make

public static UnifiedService make(ClientConnectionConfig configs)
                           throws SSLException

Create an instance with the given configs.

Parameters:

configs - use this ClientConnectionConfig

Returns:

a new instance

Throws:

SSLException - if there is an SSL related problem connecting to the server

make

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

Create an instance with default configs.

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

getSchemaService

public SchemaService getSchemaService()

Description copied from interface: UnifiedService

Return an implementation of the SchemaService interface that provides data via a network connection to a service provider.

Specified by:

getSchemaService in interface UnifiedService

Returns:

a SchemaService

getDataRoutingService

public DataRoutingService getDataRoutingService()

Description copied from interface: UnifiedService

Return an implementation of the DataRoutingService interface that provides data via a network connection to a service provider.

Specified by:

getDataRoutingService in interface UnifiedService

Returns:

a DataRoutingService

getWritableDataRoutingService

public WritableDataRoutingService getWritableDataRoutingService()

Description copied from interface: UnifiedService

Return an implementation of the WritableDataRoutingService interface that provides data via a network connection to a service provider.

Specified by:

getWritableDataRoutingService in interface UnifiedService

Returns:

a WritableDataRoutingService

getConfigurationService

public ConfigurationService getConfigurationService()

Description copied from interface: UnifiedService

Return an implementation of the ConfigurationService interface that provides data via a network connection to a service provider.

Specified by:

getConfigurationService in interface UnifiedService

Returns:

a ConfigurationService

getServiceRegistry

public EnvoyDiscoverySupportService getServiceRegistry()

Description copied from interface: UnifiedService

Return an implementation of the ServiceRegistry interface that provides data via a network connection to a service provider.

Specified by:

getServiceRegistry in interface UnifiedService

Returns:

a ServiceRegistry

getProcessRegistry

public ServiceRegistryService getProcessRegistry()

Description copied from interface: UnifiedService

Return an implementation of the ProcessRegistry interface that provides data via a network connection to a service provider.

Specified by:

getProcessRegistry in interface UnifiedService

Returns:

a RegistryLookup

about

public String about()

Description copied from interface: UnifiedService

Return information about this service.

Specified by:

about in interface UnifiedService

Returns:

an information string.

authenticate

public boolean authenticate()

Description copied from interface: AuthenticatedService

Attempt default authentication if this is not already authenticated.

Specified by:

authenticate in interface AuthenticatedService

Overrides:

authenticate in class AuthenticatedService.DefaultImpl

Returns:

true if authentication succeeded, else false

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface UnifiedService

finalize

protected void finalize()

Overrides:

finalize in class Object

getLog

@NotNull
protected @NotNull com.fishlib.io.logger.Logger getLog()

Description copied from class: AuthenticatedService.DefaultImpl

Get a Logger from the implementation (which probably has one)

Specified by:

getLog in class AuthenticatedService.DefaultImpl

Returns:

a Logger

getTokenFactoryFactory

@Nullable
protected @Nullable TokenFactoryFactory getTokenFactoryFactory()

Description copied from class: AuthenticatedService.DefaultImpl

Get the current TokenFactoryFactory from the implementation, for use in the authenticate method implementations

Specified by:

getTokenFactoryFactory in class AuthenticatedService.DefaultImpl

Returns:

the current auth client manager, may be null

setTokenFactoryFactory

public boolean setTokenFactoryFactory(TokenFactoryFactory newTokenAuthenticationManager)

Send a token from the new authentication client manager to the server for validation. Set tokenAuthenticationManager if it succeeds, or set it to null if it fails (which makes the connection unauthenticated). If newTokenAuthenticationManager is null, no token is sent to the server and return false.

Specified by:

setTokenFactoryFactory in interface AuthenticatedService

Parameters:

newTokenAuthenticationManager - a new authentication client manager, may be null

Returns:

true if we successfully authenticated with the server