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.script.ScriptService scriptService, org.elasticsearch.common.xcontent.NamedXContentRegistry xContentRegistry, org.elasticsearch.env.NodeEnvironment nodeEnvironment, com.floragunn.searchguard.internalauthtoken.InternalAuthTokenProvider internalAuthTokenProvider, SignalsSettings settings, AccountRegistry accountRegistry)

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.script.ScriptService scriptService, org.elasticsearch.common.xcontent.NamedXContentRegistry xContentRegistry, org.elasticsearch.env.NodeEnvironment nodeEnvironment, com.floragunn.searchguard.internalauthtoken.InternalAuthTokenProvider internalAuthTokenProvider, SignalsSettings settings, AccountRegistry accountRegistry)
void	delete()
void	deleteTenantFromIndexes()
String	getConfigIndexName()
int	getLocalWatchCount()
String	getName()
String	getScopedName()
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.script.ScriptService scriptService,
                     org.elasticsearch.common.xcontent.NamedXContentRegistry xContentRegistry,
                     org.elasticsearch.env.NodeEnvironment nodeEnvironment,
                     com.floragunn.searchguard.internalauthtoken.InternalAuthTokenProvider internalAuthTokenProvider,
                     SignalsSettings settings,
                     AccountRegistry accountRegistry)

Method Detail

create

public static SignalsTenant create(String name,
                                   org.elasticsearch.client.Client client,
                                   org.elasticsearch.cluster.service.ClusterService clusterService,
                                   org.elasticsearch.script.ScriptService scriptService,
                                   org.elasticsearch.common.xcontent.NamedXContentRegistry xContentRegistry,
                                   org.elasticsearch.env.NodeEnvironment nodeEnvironment,
                                   com.floragunn.searchguard.internalauthtoken.InternalAuthTokenProvider internalAuthTokenProvider,
                                   SignalsSettings settings,
                                   AccountRegistry accountRegistry)
                            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)

unack

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

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()