Package org.apache.solr.cloud.autoscaling

Class NodeLostTrigger

java.lang.Object

org.apache.solr.cloud.autoscaling.TriggerBase

org.apache.solr.cloud.autoscaling.NodeLostTrigger

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable, AutoScaling.Trigger

public class NodeLostTrigger
extends TriggerBase

Trigger for the TriggerEventType.NODELOST event

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	NodeLostTrigger.NodeLostEvent

Field Summary

Fields inherited from class org.apache.solr.cloud.autoscaling.TriggerBase

actions, cloudManager, enabled, eventType, isClosed, lastState, loader, name, processorRef, properties, requiredProperties, stateManager, validProperties, waitForSecond

Constructor Summary

Constructors

Constructor	Description
NodeLostTrigger(String name)

Method Summary

Modifier and Type	Method	Description
void	configure(SolrResourceLoader loader, SolrCloudManager cloudManager, Map<String,Object> properties)	Called when trigger is created but before it's initialized or scheduled for use.
protected Map<String,Object>	getState()	Prepare and return internal state of this trigger in a format suitable for persisting in ZK.
void	init()	Called before a trigger is scheduled.
void	restoreState(AutoScaling.Trigger old)	Set internal state of this trigger from another instance.
void	run()
protected void	setState(Map<String,Object> state)	Restore internal state of this trigger from properties retrieved from ZK.

Methods inherited from class org.apache.solr.cloud.autoscaling.TriggerBase

close, deepCopyState, equals, getActions, getEventType, getName, getProcessor, getProperties, getWaitForSecond, hashCode, isClosed, isEnabled, restoreState, saveState, setProcessor

Methods inherited from class java.lang.Object

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

Constructor Detail

NodeLostTrigger

public NodeLostTrigger(String name)

Method Detail

init

public void init()
          throws Exception

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

Overrides:

init in class TriggerBase

Throws:

Exception

configure

public void configure(SolrResourceLoader loader,
                      SolrCloudManager cloudManager,
                      Map<String,Object> properties)
               throws TriggerValidationException

Description copied from interface: AutoScaling.Trigger

Called when trigger is created but before it's initialized or scheduled for use. This method should also verify that the trigger configuration parameters are correct. It may be called multiple times.

Specified by:

configure in interface AutoScaling.Trigger

Overrides:

configure in class TriggerBase

properties - configuration properties

Throws:

TriggerValidationException - contains details of invalid configuration parameters.

restoreState

public void restoreState(AutoScaling.Trigger old)

Description copied from interface: AutoScaling.Trigger

Set internal state of this trigger from another instance.

getState

protected Map<String,Object> getState()

Description copied from class: TriggerBase

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

Specified by:

getState in class TriggerBase

Returns:

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

setState

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

Description copied from class: TriggerBase

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

Specified by:

setState in class TriggerBase

Parameters:

state - never null but may be empty.

run

public void run()