org.openspaces.grid.gsm.strategy
Class AbstractScaleStrategyBean

java.lang.Object
  org.openspaces.grid.gsm.strategy.AbstractScaleStrategyBean

All Implemented Interfaces:

Runnable, Bean, ElasticMachineProvisioningAware, ProcessingUnitAware, ElasticScaleStrategyEventStorageAware, ScaleStrategyBean

Direct Known Subclasses:

EagerScaleStrategyBean, ManualCapacityScaleStrategyBean, UndeployScaleStrategyBean

public abstract class AbstractScaleStrategyBean
extends Object
implements ElasticMachineProvisioningAware, ProcessingUnitAware, ElasticScaleStrategyEventStorageAware, ScaleStrategyBean, Bean, Runnable

Constructor Summary

AbstractScaleStrategyBean()

Method Summary

void	afterPropertiesSet() Invoked by a bean factory after it has set all bean properties.
protected void	agentProvisioningCompletedEvent()
protected void	agentProvisioningInProgressEvent(GridServiceAgentSlaEnforcementInProgressException e)
protected void	containerProvisioningCompletedEvent()
protected void	containerProvisioningInProgressEvent(ContainersSlaEnforcementInProgressException e)
void	destroy() Invoked by a bean factory on destruction of a singleton.
protected abstract void	enforceSla()
protected org.openspaces.admin.internal.admin.InternalAdmin	getAdmin()
org.openspaces.core.internal.commons.math.fraction.Fraction	getContainerNumberOfCpuCores(ManualCapacityScaleConfig slaConfig)
protected DiscoveredMachinesCache	getDiscoveredMachinesCache()
protected ElasticProcessingUnitMachineIsolation	getIsolation()
protected Log	getLogger()
protected NonBlockingElasticMachineProvisioning	getMachineProvisioning()
protected int	getMaximumNumberOfInstances()
protected int	getMinimumNumberOfMachines()
protected long	getPollingIntervalSeconds()
protected ProcessingUnit	getProcessingUnit()
Map<String,String>	getProperties()
protected org.openspaces.admin.internal.pu.elastic.ProcessingUnitSchemaConfig	getSchemaConfig()
boolean	isScaleInProgress()
protected abstract boolean	isUndeploying()
protected void	machineProvisioningCompletedEvent()
protected void	machineProvisioningInProgressEvent(MachinesSlaEnforcementInProgressException e)
protected void	puInstanceProvisioningCompletedEvent()
protected void	puInstanceProvisioningInProgressEvent(RebalancingSlaEnforcementInProgressException e)
void	run()
void	setAdmin(Admin admin) Set the Admin instance to be used by this Bean.
void	setElasticMachineIsolation(org.openspaces.admin.internal.pu.elastic.ElasticMachineIsolationConfig isolationConfig)
void	setElasticMachineProvisioning(NonBlockingElasticMachineProvisioning machineProvisioning)
void	setElasticScaleStrategyEventStorage(org.jini.rio.monitor.event.EventsStore eventQueue)
protected void	setMachineDiscoveryQuiteMode(boolean discoveryQuiteMode)
void	setProcessingUnit(ProcessingUnit pu)
void	setProcessingUnitSchema(org.openspaces.admin.internal.pu.elastic.ProcessingUnitSchemaConfig schemaConfig)
void	setProperties(Map<String,String> properties) The bean properties supplied using a client side bean configuration object, or by plain String key-value pairs.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.openspaces.grid.gsm.strategy.ScaleStrategyBean

getConfig

Constructor Detail

AbstractScaleStrategyBean

public AbstractScaleStrategyBean()

Method Detail

getAdmin

protected org.openspaces.admin.internal.admin.InternalAdmin getAdmin()

getLogger

protected Log getLogger()

getMinimumNumberOfMachines

protected int getMinimumNumberOfMachines()

getProperties

public Map<String,String> getProperties()

Specified by:

getProperties in interface Bean

Returns:

properties used to configure this bean.

setProcessingUnit

public void setProcessingUnit(ProcessingUnit pu)

Specified by:

setProcessingUnit in interface ProcessingUnitAware

getProcessingUnit

protected ProcessingUnit getProcessingUnit()

getPollingIntervalSeconds

protected long getPollingIntervalSeconds()

setElasticMachineIsolation

public void setElasticMachineIsolation(org.openspaces.admin.internal.pu.elastic.ElasticMachineIsolationConfig isolationConfig)

Specified by:

setElasticMachineIsolation in interface ElasticMachineProvisioningAware

getIsolation

protected ElasticProcessingUnitMachineIsolation getIsolation()

setProcessingUnitSchema

public void setProcessingUnitSchema(org.openspaces.admin.internal.pu.elastic.ProcessingUnitSchemaConfig schemaConfig)

Specified by:

setProcessingUnitSchema in interface ProcessingUnitAware

getSchemaConfig

protected org.openspaces.admin.internal.pu.elastic.ProcessingUnitSchemaConfig getSchemaConfig()

setAdmin

public void setAdmin(Admin admin)

Description copied from interface: Bean

Set the Admin instance to be used by this Bean.

Specified by:

setAdmin in interface Bean

Parameters:

admin - an Admin instance.

setElasticMachineProvisioning

public void setElasticMachineProvisioning(NonBlockingElasticMachineProvisioning machineProvisioning)

Specified by:

setElasticMachineProvisioning in interface ElasticMachineProvisioningAware

getMachineProvisioning

protected NonBlockingElasticMachineProvisioning getMachineProvisioning()

setElasticScaleStrategyEventStorage

public void setElasticScaleStrategyEventStorage(org.jini.rio.monitor.event.EventsStore eventQueue)

Specified by:

setElasticScaleStrategyEventStorage in interface ElasticScaleStrategyEventStorageAware

setMachineDiscoveryQuiteMode

protected void setMachineDiscoveryQuiteMode(boolean discoveryQuiteMode)

afterPropertiesSet

public void afterPropertiesSet()

Description copied from interface: Bean

Invoked by a bean factory after it has set all bean properties. This method allows the bean instance to perform non-blocking initialization, which is only possible when all bean properties have been set and to throw an exception in the event of misconfiguration.

Specified by:

afterPropertiesSet in interface Bean

See Also:

BeanConfigurationException, BeanInitializationException

destroy

public void destroy()

Description copied from interface: Bean

Invoked by a bean factory on destruction of a singleton.

Specified by:

destroy in interface Bean

See Also:

BeanConfigException

setProperties

public void setProperties(Map<String,String> properties)

Description copied from interface: Bean

The bean properties supplied using a client side bean configuration object, or by plain String key-value pairs.

Specified by:

setProperties in interface Bean

Parameters:

properties - properties to configure this bean.

getDiscoveredMachinesCache

protected DiscoveredMachinesCache getDiscoveredMachinesCache()

getMaximumNumberOfInstances

protected int getMaximumNumberOfInstances()

getContainerNumberOfCpuCores

public org.openspaces.core.internal.commons.math.fraction.Fraction getContainerNumberOfCpuCores(ManualCapacityScaleConfig slaConfig)

run

public void run()

Specified by:

run in interface Runnable

enforceSla

protected abstract void enforceSla()
                            throws SlaEnforcementInProgressException

Throws:

SlaEnforcementInProgressException

isUndeploying

protected abstract boolean isUndeploying()

Returns:

true if this is an undeployment strategy (pu is undeploying)

isScaleInProgress

public boolean isScaleInProgress()

Specified by:

isScaleInProgress in interface ScaleStrategyBean

Returns:

true if the SLA is breached and corrective actions are in progress.

agentProvisioningCompletedEvent

protected void agentProvisioningCompletedEvent()

agentProvisioningInProgressEvent

protected void agentProvisioningInProgressEvent(GridServiceAgentSlaEnforcementInProgressException e)

machineProvisioningCompletedEvent

protected void machineProvisioningCompletedEvent()

machineProvisioningInProgressEvent

protected void machineProvisioningInProgressEvent(MachinesSlaEnforcementInProgressException e)

containerProvisioningCompletedEvent

protected void containerProvisioningCompletedEvent()

containerProvisioningInProgressEvent

protected void containerProvisioningInProgressEvent(ContainersSlaEnforcementInProgressException e)

puInstanceProvisioningCompletedEvent

protected void puInstanceProvisioningCompletedEvent()

puInstanceProvisioningInProgressEvent

protected void puInstanceProvisioningInProgressEvent(RebalancingSlaEnforcementInProgressException e)