org.apache.solr.cloud.autoscaling

Class ScheduledTriggers

java.lang.Object

org.apache.solr.cloud.autoscaling.ScheduledTriggers

All Implemented Interfaces:

Closeable, AutoCloseable

public class ScheduledTriggers
extends Object
implements Closeable

Responsible for scheduling active triggers, starting and stopping them and performing actions when they fire

Constructor Summary

Constructors

Constructor and Description
ScheduledTriggers(SolrResourceLoader loader, SolrCloudManager cloudManager)

Method Summary

Modifier and Type	Method and Description
void	add(AutoScaling.Trigger newTrigger) Adds a new trigger or replaces an existing one.
void	close()
Set<String>	getScheduledTriggerNames()
void	remove(String triggerName) Removes and stops the trigger with the given name.
void	setAutoScalingConfig(AutoScalingConfig autoScalingConfig) Set the current autoscaling config.

Methods inherited from class java.lang.Object

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

Constructor Detail

ScheduledTriggers

public ScheduledTriggers(SolrResourceLoader loader,
                         SolrCloudManager cloudManager)

Method Detail

setAutoScalingConfig

public void setAutoScalingConfig(AutoScalingConfig autoScalingConfig)

Set the current autoscaling config. This is invoked by OverseerTriggerThread when autoscaling.json is updated, and it re-initializes trigger listeners and other properties used by the framework

Parameters:

autoScalingConfig - current autoscaling.json

add

public void add(AutoScaling.Trigger newTrigger)

Adds a new trigger or replaces an existing one. The replaced trigger, if any, is closed before the new trigger is run. If a trigger is replaced with itself then this operation becomes a no-op.

Parameters:

newTrigger - the trigger to be managed

Throws:

AlreadyClosedException - if this class has already been closed

remove

public void remove(String triggerName)

Removes and stops the trigger with the given name. Also cleans up any leftover state / events in ZK.

Parameters:

triggerName - the name of the trigger to be removed

getScheduledTriggerNames

public Set<String> getScheduledTriggerNames()

Returns:

an unmodifiable set of names of all triggers being managed by this class

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException