Package io.deephaven.enterprise.dnd.controller

Class PersistentQueryControllerClientImpl

java.lang.Object

io.deephaven.enterprise.dnd.controller.PersistentQueryControllerClientImpl

All Implemented Interfaces:

PersistentQueryControllerClient, PersistentQueryScriptSource

public class PersistentQueryControllerClientImpl
extends Object
implements PersistentQueryControllerClient

Nested Class Summary

Nested classes/interfaces inherited from interface io.deephaven.enterprise.dnd.controller.PersistentQueryControllerClient

PersistentQueryControllerClient.Observer, PersistentQueryControllerClient.ObserverImpl

Field Summary

Fields

Modifier and Type	Field	Description
protected final io.deephaven.hash.KeyedLongObjectHashMap<PersistentQueryInfoMessage>	queryMap

Constructor Summary

Constructors

Constructor	Description
PersistentQueryControllerClientImpl(@NotNull String who, @NotNull ControllerClientGrpc grpcClient)
PersistentQueryControllerClientImpl(@NotNull String who, @NotNull io.grpc.ManagedChannel channel)
PersistentQueryControllerClientImpl(@NotNull String who, @NotNull io.grpc.ManagedChannel channel, @NotNull ScheduledExecutorService executorService)
PersistentQueryControllerClientImpl(@NotNull String who, @NotNull io.grpc.ManagedChannel channel, @NotNull ScheduledExecutorService executorService, @NotNull AuthenticationClient authClient, long heartBeatPeriodMillis, long heartBeatTimeoutMillis)

Method Summary

Modifier and Type	Method	Description
void	addObserver(@NotNull PersistentQueryControllerClient.Observer observer)	Add an Observer.
void	addObserverAndGetData(@NotNull PersistentQueryControllerClient.Observer observer)	Add an Observer.
long	addQuery(@NotNull PersistentQueryConfigMessage config)	Adds a configuration to the controller's hash table.
boolean	authenticate(@NotNull AuthToken token)	Use the specified auth token to authenticate this client to the hashtable server.
@Nullable PersistentQueryInfoMessage	get(long querySerial)	Get the info for the specified query serial.
@Nullable PersistentQueryInfoMessage	get(@NotNull String name)	Get the info for the specified query name.
@Nullable PersistentQueryInfoMessage	get(@NotNull String owner, @NotNull String name)	Get the info for the specified query owner and name.
@NotNull ControllerConfigurationMessage	getConfiguration()	Get the current ControllerConfigurationMessage.
@NotNull Map<Long,PersistentQueryInfoMessage>	getDataCopy()	Get a copy of the current set of query data.
@Nullable String	getScriptBody(@NotNull String scriptPath, boolean isPathRelative, @Nullable String scriptLoaderStateJson)	Get the body of the specified script as the currently authenticated user.
@Nullable String	getScriptBodyByQuery(@NotNull String scriptPath, long querySerial, boolean isPathRelative, @Nullable String scriptLoaderStateJson)	Get a script by path for the owner of a specific query by serial, with optional script loader state information.
@Nullable String	getScriptBodyByUser(@NotNull String scriptPath, @NotNull String ownerName, boolean isPathRelative, @Nullable String scriptLoaderStateJson)	Get the body of the specified script as the specified user.
@NotNull Set<String>	getScriptPaths(@Nullable String scriptLoaderStateJson, boolean useRelativePath)	Get all script paths available for the currently authenticated user.
@NotNull Set<String>	getScriptPathsByQuery(long querySerial, @Nullable String scriptLoaderState, boolean useRelativePath)	Get all script paths available to the owner of a specific query by serial, providing optional script loader state information.
@NotNull Set<String>	getScriptPathsByUser(@NotNull String userName, @Nullable String scriptLoaderStateJson, boolean useRelativePath)	Get the script paths available for the specified user.
boolean	isConnected()	Check if the client is connected to the Controller.
void	modifyQuery(@NotNull PersistentQueryConfigMessage config, boolean restartIfRunning)	Modifies a configuration in the controller's hash table.
void	reloadConfiguration()	Command the PersistentQueryController to reload parts of its configuration without requiring a controller restart.
void	removeObserver(@NotNull PersistentQueryControllerClient.Observer observer)	Remove the specified PersistentQueryControllerClient.Observer from the notification list.
void	removeQuery(long serialId)	Removes a configuration from the controller's hash table by serial ID.
void	restartQueriesBySerial(@NotNull List<Long> serials)	Restarts one or more persistent queries.
void	restartReplicas(@NotNull List<ReplicaSpecifier> replicas)	Restart one or more query replicas and/or spares.
void	setEphemeral()	Make this client ephemeral.
void	shutdown()	Shut down the client.
void	stopQueriesBySerial(@NotNull List<Long> serials)	Stop the specified queries by serial.
void	subscribeToAll()	Subscribe for updates for all visible queries.
void	subscribeWithFilter(@NotNull List<SubscriptionFilter> filters)	Subscribe for updates narrowed to the PQs that match at least one of the supplied filter elements (OR-combined).
void	updateQueryStatus(long querySerial, String processInfoId, @Nullable PersistentQueryStatusEnum status, @Nullable Map<String,ExportedObjectInfoMessage> scopeFields, @Nullable Map<String,String[]> tableGroups)	Publish an update for a persistent query.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.deephaven.enterprise.dnd.controller.PersistentQueryControllerClient

modifyQuery, removeQuery, restartQueries, restartQueriesBySerial, restartQuery, stopQueries, stopQueriesBySerial, stopQuery

Methods inherited from interface io.deephaven.enterprise.dnd.controller.PersistentQueryScriptSource

getScriptBody, getScriptBodyByQuery, getScriptBodyByUser, getScriptPaths, getScriptPathsByQuery, getScriptPathsByUser

Field Details

queryMap

protected final io.deephaven.hash.KeyedLongObjectHashMap<PersistentQueryInfoMessage> queryMap

Constructor Details

PersistentQueryControllerClientImpl

public PersistentQueryControllerClientImpl(@NotNull
 @NotNull String who,
 @NotNull
 @NotNull io.grpc.ManagedChannel channel)

PersistentQueryControllerClientImpl

public PersistentQueryControllerClientImpl(@NotNull
 @NotNull String who,
 @NotNull
 @NotNull io.grpc.ManagedChannel channel,
 @NotNull
 @NotNull ScheduledExecutorService executorService)

PersistentQueryControllerClientImpl

public PersistentQueryControllerClientImpl(@NotNull
 @NotNull String who,
 @NotNull
 @NotNull io.grpc.ManagedChannel channel,
 @NotNull
 @NotNull ScheduledExecutorService executorService,
 @NotNull
 @NotNull AuthenticationClient authClient,
 long heartBeatPeriodMillis,
 long heartBeatTimeoutMillis)

PersistentQueryControllerClientImpl

public PersistentQueryControllerClientImpl(@NotNull
 @NotNull String who,
 @NotNull
 @NotNull ControllerClientGrpc grpcClient)

Method Details

addObserver

public void addObserver(@NotNull
 @NotNull PersistentQueryControllerClient.Observer observer)

Description copied from interface: PersistentQueryControllerClient

Add an Observer. If the controller is available the PersistentQueryControllerClient.Observer.handleConnectionEstablished() will be invoked immediately. No initial put events will be generated. If you want an initial snapshot with registration use PersistentQueryControllerClient.addObserverAndGetData(Observer)

Specified by:

addObserver in interface PersistentQueryControllerClient

Parameters:

observer - the PersistentQueryControllerClient.Observer to add

addObserverAndGetData

public void addObserverAndGetData(@NotNull
 @NotNull PersistentQueryControllerClient.Observer observer)

Description copied from interface: PersistentQueryControllerClient

Add an Observer. If the controller is available the PersistentQueryControllerClient.Observer.handleConnectionEstablished() will be invoked immediately. The put method will be immediately invoked for each existing query.

Specified by:

addObserverAndGetData in interface PersistentQueryControllerClient

Parameters:

observer - the PersistentQueryControllerClient.Observer to add

removeObserver

public void removeObserver(@NotNull
 @NotNull PersistentQueryControllerClient.Observer observer)

Description copied from interface: PersistentQueryControllerClient

Remove the specified PersistentQueryControllerClient.Observer from the notification list.

Specified by:

removeObserver in interface PersistentQueryControllerClient

Parameters:

observer - the observer to remove.

getDataCopy

@NotNull
public @NotNull Map<Long,PersistentQueryInfoMessage> getDataCopy()

Description copied from interface: PersistentQueryControllerClient

Get a copy of the current set of query data.

Specified by:

getDataCopy in interface PersistentQueryControllerClient

Returns:

a copy of the current set of queries.

isConnected

public boolean isConnected()

Description copied from interface: PersistentQueryControllerClient

Check if the client is connected to the Controller.

Specified by:

isConnected in interface PersistentQueryControllerClient

Returns:

true if is connected, false otherwise

setEphemeral

public void setEphemeral()

Description copied from interface: PersistentQueryControllerClient

Make this client ephemeral. An Ephemeral client will not try to reconnect once it has lost its connection.

Specified by:

setEphemeral in interface PersistentQueryControllerClient

authenticate

public boolean authenticate(@NotNull
 @NotNull AuthToken token)

Description copied from interface: PersistentQueryControllerClient

Use the specified auth token to authenticate this client to the hashtable server.

Specified by:

authenticate in interface PersistentQueryControllerClient

Parameters:

token - the token for authentication

Returns:

true if authentication was successful.

subscribeToAll

public void subscribeToAll()
                    throws UncheckedDeephavenException

Description copied from interface: PersistentQueryControllerClient

Subscribe for updates for all visible queries. This method will block until subscription is complete, or an error occurs.

Specified by:

subscribeToAll in interface PersistentQueryControllerClient

Throws:

UncheckedDeephavenException - If an error occurs

subscribeWithFilter

public void subscribeWithFilter(@NotNull
 @NotNull List<SubscriptionFilter> filters)
                         throws UncheckedDeephavenException

Description copied from interface: PersistentQueryControllerClient

Subscribe for updates narrowed to the PQs that match at least one of the supplied filter elements (OR-combined). An empty list is equivalent to PersistentQueryControllerClient.subscribeToAll(). This method blocks until the initial snapshot is received or an error occurs.

Per the proto contract on SubscribeRequest.filters, the server may decide to ignore the filter (an older controller will not know about the field). The underlying gRPC client always re-applies the same filter locally, synthesizing remove notifications for any PQ that transitions out of the matching set (e.g. via rename or owner change), so callers see the same enter/leave semantics regardless.

Specified by:

subscribeWithFilter in interface PersistentQueryControllerClient

Parameters:

filters - the filter list narrowing the subscription.

Throws:

UncheckedDeephavenException - If an error occurs.

shutdown

public void shutdown()
              throws IOException

Description copied from interface: PersistentQueryControllerClient

Shut down the client.

Specified by:

shutdown in interface PersistentQueryControllerClient

Throws:

IOException - if an error occurs while shutting down

getConfiguration

@NotNull
public @NotNull ControllerConfigurationMessage getConfiguration()

Description copied from interface: PersistentQueryControllerClient

Get the current ControllerConfigurationMessage.

Specified by:

getConfiguration in interface PersistentQueryControllerClient

Returns:

the current controller configuration

reloadConfiguration

public void reloadConfiguration()

Description copied from interface: PersistentQueryControllerClient

Command the PersistentQueryController to reload parts of its configuration without requiring a controller restart. The controller will broadcast the updated configuration to all connected clients.

Note that not all properties or configuration parameters may be reloaded.

Specified by:

reloadConfiguration in interface PersistentQueryControllerClient

addQuery

public long addQuery(@NotNull
 @NotNull PersistentQueryConfigMessage config)

Description copied from interface: PersistentQueryControllerClient

Adds a configuration to the controller's hash table.

Specified by:

addQuery in interface PersistentQueryControllerClient

Parameters:

config - the configuration to add

Returns:

the serial number of the added configuration

modifyQuery

public void modifyQuery(@NotNull
 @NotNull PersistentQueryConfigMessage config,
 boolean restartIfRunning)

Description copied from interface: PersistentQueryControllerClient

Modifies a configuration in the controller's hash table.

Specified by:

modifyQuery in interface PersistentQueryControllerClient

Parameters:

config - the updated configuration

restartIfRunning - restart the query when it is running if set to true

removeQuery

public void removeQuery(long serialId)

Description copied from interface: PersistentQueryControllerClient

Removes a configuration from the controller's hash table by serial ID.

Specified by:

removeQuery in interface PersistentQueryControllerClient

Parameters:

serialId - the serial ID of configuration to remove

restartQueriesBySerial

public void restartQueriesBySerial(@NotNull
 @NotNull List<Long> serials)

Description copied from interface: PersistentQueryControllerClient

Restarts one or more persistent queries.

Specified by:

restartQueriesBySerial in interface PersistentQueryControllerClient

Parameters:

serials - a list of serial ids to restart

restartReplicas

public void restartReplicas(@NotNull
 @NotNull List<ReplicaSpecifier> replicas)

Description copied from interface: PersistentQueryControllerClient

Restart one or more query replicas and/or spares.

Specified by:

restartReplicas in interface PersistentQueryControllerClient

Parameters:

replicas - the replicas or spares to restart.

stopQueriesBySerial

public void stopQueriesBySerial(@NotNull
 @NotNull List<Long> serials)

Description copied from interface: PersistentQueryControllerClient

Stop the specified queries by serial.

Specified by:

stopQueriesBySerial in interface PersistentQueryControllerClient

Parameters:

serials - the serials

get

@Nullable
public @Nullable PersistentQueryInfoMessage get(long querySerial)

Description copied from interface: PersistentQueryControllerClient

Get the info for the specified query serial.

Specified by:

get in interface PersistentQueryControllerClient

Parameters:

querySerial - the query serial

Returns:

the info or null if it did not exist.

get

@Nullable
public @Nullable PersistentQueryInfoMessage get(@NotNull
 @NotNull String name)

Description copied from interface: PersistentQueryControllerClient

Get the info for the specified query name.

Specified by:

get in interface PersistentQueryControllerClient

Parameters:

name - the name of the query

Returns:

the info if it exists.

get

@Nullable
public @Nullable PersistentQueryInfoMessage get(@NotNull
 @NotNull String owner,
 @NotNull
 @NotNull String name)

Description copied from interface: PersistentQueryControllerClient

Get the info for the specified query owner and name.

Specified by:

get in interface PersistentQueryControllerClient

Parameters:

owner - the expected owner of the query

name - the name of the query

Returns:

the info if it exists.

updateQueryStatus

public void updateQueryStatus(long querySerial,
 String processInfoId,
 @Nullable
 @Nullable PersistentQueryStatusEnum status,
 @Nullable
 @Nullable Map<String,ExportedObjectInfoMessage> scopeFields,
 @Nullable
 @Nullable Map<String,String[]> tableGroups)

Description copied from interface: PersistentQueryControllerClient

Publish an update for a persistent query. This is intended for use by Interactive Consoles only. The status. scopeFields, and tableGroups fields may all be omitted. If all three are omitted the message will be treated as a basic heartbeat.

Specified by:

updateQueryStatus in interface PersistentQueryControllerClient

Parameters:

querySerial - the serial of the query this update is for.

status - an optional new status

scopeFields - an optional map of exportable objects

tableGroups - an optional map of exportable object to ACL groups.

getScriptPathsByUser

@NotNull
public @NotNull Set<String> getScriptPathsByUser(@NotNull
 @NotNull String userName,
 @Nullable
 @Nullable String scriptLoaderStateJson,
 boolean useRelativePath)

Description copied from interface: PersistentQueryScriptSource

Get the script paths available for the specified user.

Specified by:

getScriptPathsByUser in interface PersistentQueryScriptSource

Parameters:

userName - the user to fetch paths for

scriptLoaderStateJson - optional script loader state information

useRelativePath - whether to return relative or display script paths

Returns:

the set of paths available for the specified user

getScriptPaths

@NotNull
public @NotNull Set<String> getScriptPaths(@Nullable
 @Nullable String scriptLoaderStateJson,
 boolean useRelativePath)

Description copied from interface: PersistentQueryScriptSource

Get all script paths available for the currently authenticated user.

Specified by:

getScriptPaths in interface PersistentQueryScriptSource

Parameters:

scriptLoaderStateJson - optional script loader state information

useRelativePath - whether to return relative or display script paths

Returns:

the set of paths available for the current user

getScriptPathsByQuery

@NotNull
public @NotNull Set<String> getScriptPathsByQuery(long querySerial,
 @Nullable
 @Nullable String scriptLoaderState,
 boolean useRelativePath)

Description copied from interface: PersistentQueryScriptSource

Get all script paths available to the owner of a specific query by serial, providing optional script loader state information.

Specified by:

getScriptPathsByQuery in interface PersistentQueryScriptSource

Parameters:

querySerial - the query serial

scriptLoaderState - an optional loader state

useRelativePath - whether to return relative or display script paths

Returns:

The paths available to the serial ID.

getScriptBody

@Nullable
public @Nullable String getScriptBody(@NotNull
 @NotNull String scriptPath,
 boolean isPathRelative,
 @Nullable
 @Nullable String scriptLoaderStateJson)

Description copied from interface: PersistentQueryScriptSource

Get the body of the specified script as the currently authenticated user.

Specified by:

getScriptBody in interface PersistentQueryScriptSource

Parameters:

scriptPath - the script path

isPathRelative - if the scriptPath is a relative path

scriptLoaderStateJson - optional script loader state information

Returns:

the body of the script

getScriptBodyByUser

@Nullable
public @Nullable String getScriptBodyByUser(@NotNull
 @NotNull String scriptPath,
 @NotNull
 @NotNull String ownerName,
 boolean isPathRelative,
 @Nullable
 @Nullable String scriptLoaderStateJson)

Description copied from interface: PersistentQueryScriptSource

Get the body of the specified script as the specified user.

Specified by:

getScriptBodyByUser in interface PersistentQueryScriptSource

Parameters:

scriptPath - the script path

ownerName - the user to fetch the body as

isPathRelative - if the scriptPath is relative

scriptLoaderStateJson - optional script loader state information

Returns:

the body of the script

getScriptBodyByQuery

@Nullable
public @Nullable String getScriptBodyByQuery(@NotNull
 @NotNull String scriptPath,
 long querySerial,
 boolean isPathRelative,
 @Nullable
 @Nullable String scriptLoaderStateJson)

Description copied from interface: PersistentQueryScriptSource

Get a script by path for the owner of a specific query by serial, with optional script loader state information.

Specified by:

getScriptBodyByQuery in interface PersistentQueryScriptSource

Parameters:

scriptPath - The path string.

querySerial - The Serial ID.

isPathRelative - if the scriptPath is relative

scriptLoaderStateJson - optional script loader state information

Returns:

The contents of the script.