org.apache.solr.cloud.autoscaling

Class TriggerBase

java.lang.Object

org.apache.solr.cloud.autoscaling.TriggerBase

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable, AutoScaling.Trigger

Direct Known Subclasses:

MetricTrigger, NodeAddedTrigger, NodeLostTrigger, ScheduledTrigger, SearchRateTrigger

public abstract class TriggerBase
extends Object
implements AutoScaling.Trigger

Base class for AutoScaling.Trigger implementations. It handles state snapshot / restore in ZK.

Field Summary

Fields

Modifier and Type	Field and Description
protected List<TriggerAction>	actions
protected SolrCloudManager	cloudManager
protected boolean	enabled
protected TriggerEventType	eventType
protected boolean	isClosed
protected Map<String,Object>	lastState
protected String	name
protected AtomicReference<AutoScaling.TriggerEventProcessor>	processorRef
protected Map<String,Object>	properties
protected DistribStateManager	stateManager
protected int	waitForSecond

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TriggerBase(TriggerEventType eventType, String name, Map<String,Object> properties, SolrResourceLoader loader, SolrCloudManager cloudManager)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	equals(Object obj)
List<TriggerAction>	getActions() Actions to execute when event is fired.
TriggerEventType	getEventType() Event type generated by this trigger.
String	getName() Trigger name.
AutoScaling.TriggerEventProcessor	getProcessor() Get event processor.
Map<String,Object>	getProperties() Trigger properties.
protected abstract Map<String,Object>	getState() Prepare and return internal state of this trigger in a format suitable for persisting in ZK.
int	getWaitForSecond() Number of seconds to wait between fired events ("waitFor" property).
int	hashCode()
void	init() Called before a trigger is scheduled.
boolean	isClosed() Return true when this trigger is closed and cannot be used.
boolean	isEnabled() Returns true if this trigger is enabled.
void	restoreState() Restore internal state of this trigger from ZooKeeper.
void	saveState() Save internal state of this trigger in ZooKeeper.
void	setProcessor(AutoScaling.TriggerEventProcessor processor) Set event processor to call when event is fired.
protected abstract void	setState(Map<String,Object> state) Restore internal state of this trigger from properties retrieved from ZK.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.solr.cloud.autoscaling.AutoScaling.Trigger

restoreState

Methods inherited from interface java.lang.Runnable

run

Field Detail

name

protected final String name

cloudManager

protected final SolrCloudManager cloudManager

stateManager

protected final DistribStateManager stateManager

properties

protected final Map<String,Object> properties

eventType

protected final TriggerEventType eventType

waitForSecond

protected final int waitForSecond

lastState

protected Map<String,Object> lastState

processorRef

protected final AtomicReference<AutoScaling.TriggerEventProcessor> processorRef

actions

protected final List<TriggerAction> actions

enabled

protected final boolean enabled

isClosed

protected boolean isClosed

Constructor Detail

TriggerBase

protected TriggerBase(TriggerEventType eventType,
                      String name,
                      Map<String,Object> properties,
                      SolrResourceLoader loader,
                      SolrCloudManager cloudManager)

Method Detail

init

public void init()

Description copied from interface: AutoScaling.Trigger

Called before a trigger is scheduled. Any heavy object creation or initialisation should be done in this method instead of the Trigger's constructor.

Specified by:

init in interface AutoScaling.Trigger

setProcessor

public void setProcessor(AutoScaling.TriggerEventProcessor processor)

Description copied from interface: AutoScaling.Trigger

Set event processor to call when event is fired.

Specified by:

setProcessor in interface AutoScaling.Trigger

getProcessor

public AutoScaling.TriggerEventProcessor getProcessor()

Description copied from interface: AutoScaling.Trigger

Get event processor.

Specified by:

getProcessor in interface AutoScaling.Trigger

getName

public String getName()

Description copied from interface: AutoScaling.Trigger

Trigger name.

Specified by:

getName in interface AutoScaling.Trigger

getEventType

public TriggerEventType getEventType()

Description copied from interface: AutoScaling.Trigger

Event type generated by this trigger.

Specified by:

getEventType in interface AutoScaling.Trigger

isEnabled

public boolean isEnabled()

Description copied from interface: AutoScaling.Trigger

Returns true if this trigger is enabled.

Specified by:

isEnabled in interface AutoScaling.Trigger

getWaitForSecond

public int getWaitForSecond()

Description copied from interface: AutoScaling.Trigger

Number of seconds to wait between fired events ("waitFor" property).

Specified by:

getWaitForSecond in interface AutoScaling.Trigger

getProperties

public Map<String,Object> getProperties()

Description copied from interface: AutoScaling.Trigger

Trigger properties.

Specified by:

getProperties in interface AutoScaling.Trigger

getActions

public List<TriggerAction> getActions()

Description copied from interface: AutoScaling.Trigger

Actions to execute when event is fired.

Specified by:

getActions in interface AutoScaling.Trigger

isClosed

public boolean isClosed()

Description copied from interface: AutoScaling.Trigger

Return true when this trigger is closed and cannot be used.

Specified by:

isClosed in interface AutoScaling.Trigger

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

getState

protected abstract Map<String,Object> getState()

Prepare and return internal state of this trigger in a format suitable for persisting in ZK.

Returns:

map of internal state properties. Note: values must be supported by Utils.toJSON(Object).

setState

protected abstract void setState(Map<String,Object> state)

Restore internal state of this trigger from properties retrieved from ZK.

Parameters:

state - never null but may be empty.

saveState

public void saveState()

Description copied from interface: AutoScaling.Trigger

Save internal state of this trigger in ZooKeeper.

Specified by:

saveState in interface AutoScaling.Trigger

restoreState

public void restoreState()

Description copied from interface: AutoScaling.Trigger

Restore internal state of this trigger from ZooKeeper.

Specified by:

restoreState in interface AutoScaling.Trigger