Package com.floragunn.signals

Class SignalsTenant

java.lang.Object

com.floragunn.signals.SignalsTenant

All Implemented Interfaces:

Closeable, AutoCloseable

public class SignalsTenant
extends Object
implements Closeable

Constructor Summary

Constructors

Constructor	Description
SignalsTenant(String name, org.elasticsearch.client.Client client, org.elasticsearch.cluster.service.ClusterService clusterService, org.elasticsearch.env.NodeEnvironment nodeEnvironment, org.elasticsearch.script.ScriptService scriptService, org.elasticsearch.xcontent.NamedXContentRegistry xContentRegistry, com.floragunn.searchguard.internalauthtoken.InternalAuthTokenProvider internalAuthTokenProvider, SignalsSettings settings, AccountRegistry accountRegistry, com.floragunn.searchguard.modules.state.ComponentState tenantState, com.floragunn.searchsupport.diag.DiagnosticContext diagnosticContext)
SignalsTenant(String name, org.elasticsearch.client.Client client, org.elasticsearch.cluster.service.ClusterService clusterService, org.elasticsearch.env.NodeEnvironment nodeEnvironment, org.elasticsearch.script.ScriptService scriptService, org.elasticsearch.xcontent.NamedXContentRegistry xContentRegistry, com.floragunn.searchguard.internalauthtoken.InternalAuthTokenProvider internalAuthTokenProvider, SignalsSettings settings, AccountRegistry accountRegistry, com.floragunn.searchsupport.diag.DiagnosticContext diagnosticContext)

Method Summary

Modifier and Type	Method	Description
List<String>	ack(String watchId, com.floragunn.searchguard.user.User user)
void	ack(String watchId, String actionId, com.floragunn.searchguard.user.User user)
org.elasticsearch.action.index.IndexResponse	addWatch(Watch watch, com.floragunn.searchguard.user.User user)
org.elasticsearch.action.index.IndexResponse	addWatch(String watchId, String watchJsonString, com.floragunn.searchguard.user.User user)
void	close()
static SignalsTenant	create(String name, org.elasticsearch.client.Client client, org.elasticsearch.cluster.service.ClusterService clusterService, org.elasticsearch.env.NodeEnvironment nodeEnvironment, org.elasticsearch.script.ScriptService scriptService, org.elasticsearch.xcontent.NamedXContentRegistry xContentRegistry, com.floragunn.searchguard.internalauthtoken.InternalAuthTokenProvider internalAuthTokenProvider, SignalsSettings settings, AccountRegistry accountRegistry, com.floragunn.searchguard.modules.state.ComponentState tenantState, com.floragunn.searchsupport.diag.DiagnosticContext diagnosticContext)
void	delete()
void	deleteTenantFromIndexes()
String	getConfigIndexName()
int	getLocalWatchCount()
String	getName()
String	getScopedName()
SignalsSettings	getSettings()
String	getWatchIdForConfigIndex(Watch watch)
String	getWatchIdForConfigIndex(String watchId)
WatchState	getWatchState(String watchId)
WatchStateManager	getWatchStateManager()
WatchStateIndexReader	getWatchStateReader()
void	init()
boolean	isActive()
void	pause()
void	restart()
void	restartAsync()
void	resume()
boolean	runsWatchLocally(String watchId)
void	shutdown()
void	shutdownHard()
String	toString()
List<String>	unack(String watchId, com.floragunn.searchguard.user.User user)
boolean	unack(String watchId, String actionId, com.floragunn.searchguard.user.User user)

Methods inherited from class java.lang.Object

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

Constructor Detail

SignalsTenant

public SignalsTenant(String name,
                     org.elasticsearch.client.Client client,
                     org.elasticsearch.cluster.service.ClusterService clusterService,
                     org.elasticsearch.env.NodeEnvironment nodeEnvironment,
                     org.elasticsearch.script.ScriptService scriptService,
                     org.elasticsearch.xcontent.NamedXContentRegistry xContentRegistry,
                     com.floragunn.searchguard.internalauthtoken.InternalAuthTokenProvider internalAuthTokenProvider,
                     SignalsSettings settings,
                     AccountRegistry accountRegistry,
                     com.floragunn.searchguard.modules.state.ComponentState tenantState,
                     com.floragunn.searchsupport.diag.DiagnosticContext diagnosticContext)

SignalsTenant

public SignalsTenant(String name,
                     org.elasticsearch.client.Client client,
                     org.elasticsearch.cluster.service.ClusterService clusterService,
                     org.elasticsearch.env.NodeEnvironment nodeEnvironment,
                     org.elasticsearch.script.ScriptService scriptService,
                     org.elasticsearch.xcontent.NamedXContentRegistry xContentRegistry,
                     com.floragunn.searchguard.internalauthtoken.InternalAuthTokenProvider internalAuthTokenProvider,
                     SignalsSettings settings,
                     AccountRegistry accountRegistry,
                     com.floragunn.searchsupport.diag.DiagnosticContext diagnosticContext)

Method Detail

create

public static SignalsTenant create(String name,
                                   org.elasticsearch.client.Client client,
                                   org.elasticsearch.cluster.service.ClusterService clusterService,
                                   org.elasticsearch.env.NodeEnvironment nodeEnvironment,
                                   org.elasticsearch.script.ScriptService scriptService,
                                   org.elasticsearch.xcontent.NamedXContentRegistry xContentRegistry,
                                   com.floragunn.searchguard.internalauthtoken.InternalAuthTokenProvider internalAuthTokenProvider,
                                   SignalsSettings settings,
                                   AccountRegistry accountRegistry,
                                   com.floragunn.searchguard.modules.state.ComponentState tenantState,
                                   com.floragunn.searchsupport.diag.DiagnosticContext diagnosticContext)
                            throws org.quartz.SchedulerException

Throws:

org.quartz.SchedulerException

init

public void init()
          throws org.quartz.SchedulerException

Throws:

org.quartz.SchedulerException

pause

public void pause()
           throws org.quartz.SchedulerException

Throws:

org.quartz.SchedulerException

resume

public void resume()
            throws org.quartz.SchedulerException

Throws:

org.quartz.SchedulerException

isActive

public boolean isActive()
                 throws org.quartz.SchedulerException

Throws:

org.quartz.SchedulerException

shutdown

public void shutdown()

shutdownHard

public void shutdownHard()

restart

public void restart()
             throws org.quartz.SchedulerException

Throws:

org.quartz.SchedulerException

restartAsync

public void restartAsync()

runsWatchLocally

public boolean runsWatchLocally(String watchId)

getLocalWatchCount

public int getLocalWatchCount()

getWatchIdForConfigIndex

public String getWatchIdForConfigIndex(String watchId)

getWatchIdForConfigIndex

public String getWatchIdForConfigIndex(Watch watch)

addWatch

public org.elasticsearch.action.index.IndexResponse addWatch(Watch watch,
                                                             com.floragunn.searchguard.user.User user)
                                                      throws IOException

Throws:

IOException

addWatch

public org.elasticsearch.action.index.IndexResponse addWatch(String watchId,
                                                             String watchJsonString,
                                                             com.floragunn.searchguard.user.User user)
                                                      throws com.floragunn.searchsupport.config.validation.ConfigValidationException,
                                                             IOException

Throws:

com.floragunn.searchsupport.config.validation.ConfigValidationException

IOException

ack

public List<String> ack(String watchId,
                        com.floragunn.searchguard.user.User user)

ack

public void ack(String watchId,
                String actionId,
                com.floragunn.searchguard.user.User user)

unack

public List<String> unack(String watchId,
                          com.floragunn.searchguard.user.User user)
                   throws NoSuchWatchOnThisNodeException

Throws:

NoSuchWatchOnThisNodeException

unack

public boolean unack(String watchId,
                     String actionId,
                     com.floragunn.searchguard.user.User user)
              throws NoSuchWatchOnThisNodeException

Throws:

NoSuchWatchOnThisNodeException

getWatchState

public WatchState getWatchState(String watchId)

deleteTenantFromIndexes

public void deleteTenantFromIndexes()

delete

public void delete()

getWatchStateManager

public WatchStateManager getWatchStateManager()

getName

public String getName()

getConfigIndexName

public String getConfigIndexName()

getScopedName

public String getScopedName()

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object

getWatchStateReader

public WatchStateIndexReader getWatchStateReader()

getSettings

public SignalsSettings getSettings()