Package io.deephaven.enterprise.remote

Class ControllerStateWatcher

java.lang.Object

io.deephaven.enterprise.remote.ControllerStateWatcher

All Implemented Interfaces:

RemoteTableStateWatcher

public class ControllerStateWatcher
extends Object
implements RemoteTableStateWatcher

A RemoteTableStateWatcher that uses a PersistentQueryControllerClient to produce tokens backed by PersistentQueryInfoMessages.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	ControllerStateWatcher.PersistentQueryStateToken	A RemoteTableStateWatcher.StateToken backed by a PersistentQueryInfoMessage

Nested classes/interfaces inherited from interface io.deephaven.enterprise.remote.RemoteTableStateWatcher

RemoteTableStateWatcher.Observer, RemoteTableStateWatcher.StateToken

Constructor Summary

Constructors

Constructor	Description
ControllerStateWatcher(@NotNull PersistentQueryControllerClient client, @NotNull String queryName)	Createa a new ControllerStateWatcher that monitors the state of the specified query by name.

Method Summary

Modifier and Type	Method	Description
void	clearObserver(@NotNull RemoteTableStateWatcher.Observer o)	Remove the RemoteTableStateWatcher.Observer set by RemoteTableStateWatcher.setObserver(Observer).
String	description()	Get a description of the watcher.
void	setObserver(@NotNull RemoteTableStateWatcher.Observer o)	Set the RemoteTableStateWatcher.Observer to notify of state changes.

Methods inherited from class java.lang.Object

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

Constructor Details

ControllerStateWatcher

public ControllerStateWatcher(@NotNull
 @NotNull PersistentQueryControllerClient client,
 @NotNull
 @NotNull String queryName)

Createa a new ControllerStateWatcher that monitors the state of the specified query by name.

Parameters:

client - the PersistentQueryControllerClient

queryName - the query name.

Method Details

setObserver

public void setObserver(@NotNull
 @NotNull RemoteTableStateWatcher.Observer o)

Description copied from interface: RemoteTableStateWatcher

Set the RemoteTableStateWatcher.Observer to notify of state changes.

Specified by:

setObserver in interface RemoteTableStateWatcher

Parameters:

o - the observer

description

public String description()

Description copied from interface: RemoteTableStateWatcher

Get a description of the watcher.

Specified by:

description in interface RemoteTableStateWatcher

Returns:

a description.

clearObserver

public void clearObserver(@NotNull
 @NotNull RemoteTableStateWatcher.Observer o)

Description copied from interface: RemoteTableStateWatcher

Remove the RemoteTableStateWatcher.Observer set by RemoteTableStateWatcher.setObserver(Observer). The observer must be identical.

Specified by:

clearObserver in interface RemoteTableStateWatcher

Parameters:

o - the observer to remove. Must be identical to what was passed to RemoteTableStateWatcher.setObserver(Observer)