com.illumon.iris.controller

Class PersistentQueryControllerClient

java.lang.Object

com.illumon.iris.controller.ControllerHashtable

com.illumon.iris.controller.ControllerHashtableClient

com.illumon.iris.controller.PersistentQueryControllerClient

All Implemented Interfaces:

com.fishlib.net.api.CommandHandler, com.fishlib.net.api.ConnectionStatusHandlerEx, com.fishlib.net.CommBase.ConnectionStatusHandler, ControllerHashtableEventSource, PersistentQueryScriptSource, RemoteScriptSource, Map<Long,PersistentQueryInfo>

public class PersistentQueryControllerClient
extends ControllerHashtableClient
implements PersistentQueryScriptSource

Client for subscribing to state from the PersistentQueryController and manipulating persistent queries.

Nested Class Summary

Nested classes/interfaces inherited from interface com.fishlib.net.api.ConnectionStatusHandlerEx

com.fishlib.net.api.ConnectionStatusHandlerEx.Adapter

Nested classes/interfaces inherited from interface java.util.Map

Map.Entry<K,V>

Field Summary

Fields inherited from class com.illumon.iris.controller.ControllerHashtable

id

Constructor Summary

Constructors

Constructor and Description
PersistentQueryControllerClient(com.fishlib.io.logger.Logger log, com.fishlib.io.sched.Scheduler scheduler, com.fishlib.net.CommBase.ConnectionStatusHandler connectionStatusHandler, com.fishlib.net.ConnectionMonitor.Params connectionMonitorParams, boolean async)
PersistentQueryControllerClient(com.fishlib.io.logger.Logger log, com.fishlib.io.sched.Scheduler scheduler, com.fishlib.net.CommBase.ConnectionStatusHandler connectionStatusHandler, com.fishlib.net.ConnectionMonitor.Params connectionMonitorParams, boolean async, com.fishlib.base.hash.IndexableMap<Long,PersistentQueryInfo> map)

Method Summary

Modifier and Type	Method and Description
long	addQueryConfiguration(PersistentQueryConfiguration config) Adds a configuration to the controller's hash table.
boolean	authenticateToController(com.fishlib.auth.AuthToken authToken) Present an authentication token to the controller.
static void	disallowReconnections()
String[]	getAllGroups() Returns the list of all groups.
String[]	getAllUsers() Returns the list of all users.
String[]	getGroupsForUser(com.fishlib.auth.UserContext userContext) Return the groups which a user belongs to.
String	getScriptBody(boolean relative, String scriptPath, long configSerial, ScriptPathLoaderState scriptLoaderState) Get a script by path for a specific serial ID and a specific state.
String	getScriptBody(boolean relative, String scriptPath, ScriptPathLoaderState scriptLoaderState) Get a script by path and state.
String	getScriptBody(boolean relative, String scriptPath, String ownerName, ScriptPathLoaderState scriptLoaderState) Get a script by path for a specific owner and state.
Set<String>	getScriptDisplayPaths(long configSerial, ScriptPathLoaderState scriptLoaderState) Get all display paths available to a specific PersistentQuery serial ID and a specific state..
Set<String>	getScriptDisplayPaths(ScriptPathLoaderState scriptLoaderState) Get all available display paths for a specific state.
Set<String>	getScriptDisplayPaths(String ownerName, ScriptPathLoaderState scriptLoaderState) Get all display paths available to a specific owner and state.
PersistentQueryControllerConfiguration	getServerConfiguration() Gets the server configuration from the controller.
String[]	getUsersForGroup(String group) Return the users which belong to a group.
void	handleConnectionReestablished()
boolean	isAclEditor(com.fishlib.auth.UserContext userContext) Returns true if the effective user is an ACL editor
boolean	isSuperUser(com.fishlib.auth.UserContext userContext) Returns true if the effective user is a superuser.
void	modifyQueryConfiguration(PersistentQueryConfiguration config) Modifies a configuration in the controller's hash table.
void	reloadConfiguration() Reloads the controller configuration.
void	removeQueryConfiguration(PersistentQueryConfiguration config) Removes a configuration from the controller's hash table.
void	restartQuery(PersistentQueryConfiguration config) Restarts a persistent query.
void	stopQuery(PersistentQueryConfiguration config) Stops a persistent query.

Methods inherited from class com.illumon.iris.controller.ControllerHashtableClient

addEventHandlerAndGetData, addReloadCommandListener, clear, containsKey, containsValue, disconnect, entrySet, get, getComm, getData, getUnderlyingMap, handleClientDeath, handleCommand, handleConnectionLost, handleInitialConnection, isEmpty, keySet, put, putAll, remove, size, subscribeToAll, values

Methods inherited from class com.illumon.iris.controller.ControllerHashtable

addCommandHandler, addEventHandler, removeCommandHandler, removeEventHandler

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.illumon.iris.controller.PersistentQueryScriptSource

getScriptBody, getScriptDisplayPaths

Methods inherited from interface com.illumon.iris.controller.RemoteScriptSource

getScriptBody, getScriptBody, getScriptDisplayPaths, getScriptDisplayPaths

Methods inherited from interface java.util.Map

compute, computeIfAbsent, computeIfPresent, equals, forEach, getOrDefault, hashCode, merge, putIfAbsent, remove, replace, replace, replaceAll

Constructor Detail

PersistentQueryControllerClient

public PersistentQueryControllerClient(com.fishlib.io.logger.Logger log,
                                       com.fishlib.io.sched.Scheduler scheduler,
                                       @Nullable
                                       com.fishlib.net.CommBase.ConnectionStatusHandler connectionStatusHandler,
                                       @Nullable
                                       com.fishlib.net.ConnectionMonitor.Params connectionMonitorParams,
                                       boolean async)
                                throws IOException

Throws:

IOException

PersistentQueryControllerClient

public PersistentQueryControllerClient(com.fishlib.io.logger.Logger log,
                                       com.fishlib.io.sched.Scheduler scheduler,
                                       @Nullable
                                       com.fishlib.net.CommBase.ConnectionStatusHandler connectionStatusHandler,
                                       @Nullable
                                       com.fishlib.net.ConnectionMonitor.Params connectionMonitorParams,
                                       boolean async,
                                       com.fishlib.base.hash.IndexableMap<Long,PersistentQueryInfo> map)
                                throws IOException

Throws:

IOException

Method Detail

disallowReconnections

public static void disallowReconnections()

addQueryConfiguration

public long addQueryConfiguration(PersistentQueryConfiguration config)

Adds a configuration to the controller's hash table.

Parameters:

config - the configuration to add

Returns:

the serial number of the added configuration

modifyQueryConfiguration

public void modifyQueryConfiguration(PersistentQueryConfiguration config)

Modifies a configuration in the controller's hash table.

Parameters:

config - the updated configuration

removeQueryConfiguration

public void removeQueryConfiguration(PersistentQueryConfiguration config)

Removes a configuration from the controller's hash table.

Parameters:

config - the configuration to remove

restartQuery

public void restartQuery(PersistentQueryConfiguration config)

Restarts a persistent query.

Parameters:

config - the persistent query configuration to be restarted.

stopQuery

public void stopQuery(PersistentQueryConfiguration config)

Stops a persistent query.

Parameters:

config - the persistent query configuration to be stopped.

reloadConfiguration

public void reloadConfiguration()

Reloads the controller configuration. This function causes 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.

getServerConfiguration

public PersistentQueryControllerConfiguration getServerConfiguration()

Gets the server configuration from the controller.

Returns:

the currently loaded controller configuration

getScriptDisplayPaths

public Set<String> getScriptDisplayPaths(String ownerName,
                                         ScriptPathLoaderState scriptLoaderState)

Description copied from interface: RemoteScriptSource

Get all display paths available to a specific owner and state.

Specified by:

getScriptDisplayPaths in interface RemoteScriptSource

Parameters:

ownerName - A specific user.

scriptLoaderState - The state to get paths from or ScriptPathLoaderState.NONE to get the latest version.

Returns:

The paths available to ownerName.

getScriptDisplayPaths

public Set<String> getScriptDisplayPaths(ScriptPathLoaderState scriptLoaderState)

Description copied from interface: RemoteScriptSource

Get all available display paths for a specific state.

Specified by:

getScriptDisplayPaths in interface RemoteScriptSource

Parameters:

scriptLoaderState - The state to get paths from or ScriptPathLoaderState.NONE to get the latest version.

Returns:

All display paths.

getScriptDisplayPaths

public Set<String> getScriptDisplayPaths(long configSerial,
                                         ScriptPathLoaderState scriptLoaderState)

Description copied from interface: PersistentQueryScriptSource

Get all display paths available to a specific PersistentQuery serial ID and a specific state..

Specified by:

getScriptDisplayPaths in interface PersistentQueryScriptSource

Parameters:

configSerial - A serial ID.

scriptLoaderState - A specific state to retrieve scripts from or ScriptPathLoaderState.NONE to get the latest version.

Returns:

The paths available to the serial ID.

getScriptBody

public String getScriptBody(boolean relative,
                            String scriptPath,
                            ScriptPathLoaderState scriptLoaderState)

Description copied from interface: RemoteScriptSource

Get a script by path and state.

Specified by:

getScriptBody in interface RemoteScriptSource

Parameters:

relative - Is the path a relative path?

scriptPath - The path string.

scriptLoaderState - The state to get scripts from or ScriptPathLoaderState.NONE to get the latest version.

Returns:

The contents of the script.

getScriptBody

public String getScriptBody(boolean relative,
                            String scriptPath,
                            long configSerial,
                            ScriptPathLoaderState scriptLoaderState)

Description copied from interface: PersistentQueryScriptSource

Get a script by path for a specific serial ID and a specific state.

Specified by:

getScriptBody in interface PersistentQueryScriptSource

Parameters:

relative - Is the path a relative path?

scriptPath - The path string.

configSerial - The Serial ID.

scriptLoaderState - A specific state to retrieve scripts from or ScriptPathLoaderState.NONE to get the latest version.

Returns:

The contents of the script.

getScriptBody

public String getScriptBody(boolean relative,
                            String scriptPath,
                            String ownerName,
                            ScriptPathLoaderState scriptLoaderState)

Description copied from interface: RemoteScriptSource

Get a script by path for a specific owner and state.

Specified by:

getScriptBody in interface RemoteScriptSource

Parameters:

relative - Is the path a relative path?

scriptPath - The path string.

ownerName - The owner.

scriptLoaderState - The state to get script from or ScriptPathLoaderState.NONE to get the latest version.

Returns:

The contents of the script.

authenticateToController

public boolean authenticateToController(com.fishlib.auth.AuthToken authToken)

Present an authentication token to the controller.

Parameters:

authToken - the token to present to the controller

Returns:

true if authentication succeeded

getGroupsForUser

public String[] getGroupsForUser(com.fishlib.auth.UserContext userContext)

Return the groups which a user belongs to.

Parameters:

userContext - the userContext to get membership for

Returns:

an array of group names that the effective user belongs to

getUsersForGroup

public String[] getUsersForGroup(String group)

Return the users which belong to a group.

Parameters:

group - the group to get membership for

Returns:

an array of user names that belong to the group

isSuperUser

public boolean isSuperUser(com.fishlib.auth.UserContext userContext)

Returns true if the effective user is a superuser.

Parameters:

userContext - the usercontext to query

Returns:

true if the user is a member of the iris-superusers group.

isAclEditor

public boolean isAclEditor(com.fishlib.auth.UserContext userContext)

Returns true if the effective user is an ACL editor

Parameters:

userContext - the usercontext to query

Returns:

true if the user is a member of the iris-acleditors group.

getAllGroups

public String[] getAllGroups()

Returns the list of all groups.

Returns:

an array of all group names

getAllUsers

public String[] getAllUsers()

Returns the list of all users.

Returns:

an array of all user names

handleConnectionReestablished

public void handleConnectionReestablished()

Specified by:

handleConnectionReestablished in interface com.fishlib.net.CommBase.ConnectionStatusHandler

Overrides:

handleConnectionReestablished in class ControllerHashtableClient