Package org.opencastproject.terminationstate.aws

Class AutoScalingTerminationStateService

java.lang.Object

org.opencastproject.terminationstate.api.AbstractJobTerminationStateService

org.opencastproject.terminationstate.aws.AutoScalingTerminationStateService

All Implemented Interfaces:

org.opencastproject.terminationstate.api.TerminationStateService

public final class AutoScalingTerminationStateService
extends org.opencastproject.terminationstate.api.AbstractJobTerminationStateService

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AutoScalingTerminationStateService.CheckLifeCycleState
static class	AutoScalingTerminationStateService.CheckTerminationState

Nested classes/interfaces inherited from interface org.opencastproject.terminationstate.api.TerminationStateService

org.opencastproject.terminationstate.api.TerminationStateService.TerminationState

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CONFIG_AWS_ACCESS_KEY_ID
static final String	CONFIG_AWS_SECRET_ACCESS_KEY
static final String	CONFIG_ENABLE
static final String	CONFIG_LIFECYCLE_HEARTBEAT_PERIOD
static final String	CONFIG_LIFECYCLE_POLLING_ENABLE
static final String	CONFIG_LIFECYCLE_POLLING_PERIOD
protected static final String	SCHEDULE_GROUP
protected static final String	SCHEDULE_JOB_PARAM_PARENT
protected static final String	SCHEDULE_LIFECYCLE_HEARTBEAT_JOB
protected static final String	SCHEDULE_LIFECYCLE_HEARTBEAT_TRIGGER
protected static final String	SCHEDULE_LIFECYCLE_POLLING_JOB
protected static final String	SCHEDULE_LIFECYCLE_POLLING_TRIGGER

Constructor Summary

Constructors

Constructor	Description
AutoScalingTerminationStateService()

Method Summary

Modifier and Type	Method	Description
protected void	activate(org.osgi.service.component.ComponentContext componentContext)
protected void	configure(Dictionary config)
void	deactivate()	OSGI deactivate callback
protected void	setAutoScaling(com.amazonaws.services.autoscaling.AmazonAutoScaling autoScaling)	Methods below are used by test class
protected void	setAutoScalingGroup(com.amazonaws.services.autoscaling.model.AutoScalingGroup autoScalingGroup)
protected void	setLifecycleHook(com.amazonaws.services.autoscaling.model.LifecycleHook lifecycleHook)
protected void	setScheduler(org.quartz.Scheduler scheduler)
void	setServiceRegistry(org.opencastproject.serviceregistry.api.ServiceRegistry serviceRegistry)
void	setState(org.opencastproject.terminationstate.api.TerminationStateService.TerminationState state)
protected void	startPollingLifeCycleHook()
protected void	startPollingTerminationState()
protected void	stopPollingLifeCycleHook()
protected void	stopPollingTerminationState()

Methods inherited from class org.opencastproject.terminationstate.api.AbstractJobTerminationStateService

countJobs, getServiceRegistry, getState, readyToTerminate

Methods inherited from class java.lang.Object

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

Field Details

CONFIG_ENABLE

public static final String CONFIG_ENABLE

See Also:

• Constant Field Values

CONFIG_LIFECYCLE_POLLING_ENABLE

public static final String CONFIG_LIFECYCLE_POLLING_ENABLE

See Also:

• Constant Field Values

CONFIG_LIFECYCLE_POLLING_PERIOD

public static final String CONFIG_LIFECYCLE_POLLING_PERIOD

See Also:

• Constant Field Values

CONFIG_LIFECYCLE_HEARTBEAT_PERIOD

public static final String CONFIG_LIFECYCLE_HEARTBEAT_PERIOD

See Also:

• Constant Field Values

CONFIG_AWS_ACCESS_KEY_ID

public static final String CONFIG_AWS_ACCESS_KEY_ID

See Also:

• Constant Field Values

CONFIG_AWS_SECRET_ACCESS_KEY

public static final String CONFIG_AWS_SECRET_ACCESS_KEY

See Also:

• Constant Field Values

SCHEDULE_GROUP

protected static final String SCHEDULE_GROUP

SCHEDULE_LIFECYCLE_POLLING_JOB

protected static final String SCHEDULE_LIFECYCLE_POLLING_JOB

See Also:

• Constant Field Values

SCHEDULE_LIFECYCLE_HEARTBEAT_JOB

protected static final String SCHEDULE_LIFECYCLE_HEARTBEAT_JOB

See Also:

• Constant Field Values

SCHEDULE_LIFECYCLE_POLLING_TRIGGER

protected static final String SCHEDULE_LIFECYCLE_POLLING_TRIGGER

See Also:

• Constant Field Values

SCHEDULE_LIFECYCLE_HEARTBEAT_TRIGGER

protected static final String SCHEDULE_LIFECYCLE_HEARTBEAT_TRIGGER

See Also:

• Constant Field Values

SCHEDULE_JOB_PARAM_PARENT

protected static final String SCHEDULE_JOB_PARAM_PARENT

See Also:

• Constant Field Values

Constructor Details

AutoScalingTerminationStateService

public AutoScalingTerminationStateService()

Method Details

activate

protected void activate(org.osgi.service.component.ComponentContext componentContext)

configure

protected void configure(Dictionary config)
                  throws org.osgi.service.cm.ConfigurationException

Throws:

org.osgi.service.cm.ConfigurationException

setState

public void setState(org.opencastproject.terminationstate.api.TerminationStateService.TerminationState state)

Specified by:

setState in interface org.opencastproject.terminationstate.api.TerminationStateService

Overrides:

setState in class org.opencastproject.terminationstate.api.AbstractJobTerminationStateService

startPollingLifeCycleHook

protected void startPollingLifeCycleHook()

stopPollingLifeCycleHook

protected void stopPollingLifeCycleHook()

startPollingTerminationState

protected void startPollingTerminationState()

stopPollingTerminationState

protected void stopPollingTerminationState()

deactivate

public void deactivate()

OSGI deactivate callback

setAutoScaling

protected void setAutoScaling(com.amazonaws.services.autoscaling.AmazonAutoScaling autoScaling)

Methods below are used by test class

setAutoScalingGroup

protected void setAutoScalingGroup(com.amazonaws.services.autoscaling.model.AutoScalingGroup autoScalingGroup)

setLifecycleHook

protected void setLifecycleHook(com.amazonaws.services.autoscaling.model.LifecycleHook lifecycleHook)

setScheduler

protected void setScheduler(org.quartz.Scheduler scheduler)

setServiceRegistry

public void setServiceRegistry(org.opencastproject.serviceregistry.api.ServiceRegistry serviceRegistry)

Overrides:

setServiceRegistry in class org.opencastproject.terminationstate.api.AbstractJobTerminationStateService