public class NodeLostTrigger extends TriggerBase
TriggerEventType.NODELOST
eventModifier and Type | Class and Description |
---|---|
static class |
NodeLostTrigger.NodeLostEvent |
lastState, zkClient
Constructor and Description |
---|
NodeLostTrigger(String name,
Map<String,Object> properties,
CoreContainer container,
ZkController zkController) |
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 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(AutoScaling.Trigger old)
Set internal state of this trigger from another instance.
|
void |
run() |
void |
setProcessor(AutoScaling.TriggerEventProcessor processor)
Set event processor to call when event is fired.
|
protected void |
setState(Map<String,Object> state)
Restore internal state of this trigger from properties retrieved from ZK.
|
restoreState, saveState
public NodeLostTrigger(String name, Map<String,Object> properties, CoreContainer container, ZkController zkController)
public void init()
AutoScaling.Trigger
public void setProcessor(AutoScaling.TriggerEventProcessor processor)
AutoScaling.Trigger
public AutoScaling.TriggerEventProcessor getProcessor()
AutoScaling.Trigger
public String getName()
AutoScaling.Trigger
public TriggerEventType getEventType()
AutoScaling.Trigger
public boolean isEnabled()
AutoScaling.Trigger
public int getWaitForSecond()
AutoScaling.Trigger
public Map<String,Object> getProperties()
AutoScaling.Trigger
public List<TriggerAction> getActions()
AutoScaling.Trigger
public void close() throws IOException
IOException
public void restoreState(AutoScaling.Trigger old)
AutoScaling.Trigger
protected Map<String,Object> getState()
TriggerBase
getState
in class TriggerBase
Utils.toJSON(Object)
.protected void setState(Map<String,Object> state)
TriggerBase
setState
in class TriggerBase
state
- never null but may be empty.public void run()
public boolean isClosed()
AutoScaling.Trigger
Copyright © 2000-2017 Apache Software Foundation. All Rights Reserved.