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:

NodeAddedTrigger, NodeLostTrigger

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 Map<String,Object>	lastState
protected SolrZkClient	zkClient

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TriggerBase(SolrZkClient zkClient)

Method Summary

Modifier and Type	Method and Description
protected abstract Map<String,Object>	getState() Prepare and return internal state of this trigger in a format suitable for persisting in ZK.
void	restoreState() Restore internal state of this trigger from ZooKeeper.
void	saveState() Save internal state of this trigger in ZooKeeper.
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, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

getActions, getEventType, getName, getProcessor, getProperties, getWaitForSecond, init, isClosed, isEnabled, restoreState, setProcessor

Methods inherited from interface java.io.Closeable

close

Methods inherited from interface java.lang.Runnable

run

Field Detail

zkClient

protected SolrZkClient zkClient

lastState

protected Map<String,Object> lastState

Constructor Detail

TriggerBase

protected TriggerBase(SolrZkClient zkClient)

Method Detail

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