org.openspaces.grid.gsm.strategy
Class AbstractCapacityScaleStrategyBean

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

All Implemented Interfaces:

Runnable, Bean, ContainersSlaEnforcementEndpointAware, ElasticMachineProvisioningAware, GridServiceContainerConfigAware, ElasticProcessingUnitMachineIsolationAware, MachinesSlaEnforcementEndpointAware, ProcessingUnitAware, RebalancingSlaEnforcementEndpointAware, ElasticScaleStrategyEventStorageAware, ScaleStrategyBean

Direct Known Subclasses:

AutomaticCapacityScaleStrategyBean, ManualCapacityScaleStrategyBean

public abstract class AbstractCapacityScaleStrategyBean
extends AbstractScaleStrategyBean
implements GridServiceContainerConfigAware, RebalancingSlaEnforcementEndpointAware, ContainersSlaEnforcementEndpointAware, MachinesSlaEnforcementEndpointAware

A class for code reuse between ManualCapacityScaleStrategyBean and AutomaticCapacityScaleStrategyBean

Since:

9.0.0

Author:

itaif

Constructor Summary

AbstractCapacityScaleStrategyBean()

Method Summary

void	afterPropertiesSet() Invoked by a bean factory after it has set all bean properties.
protected long	calcMemoryInMB()
protected void	enforceCapacityRequirement()
protected ScaleStrategyCapacityRequirementConfig	getCapacityRequirementConfig()
org.openspaces.admin.internal.pu.elastic.GridServiceContainerConfig	getGridServiceContainerConfig()
protected boolean	isUndeploying()
protected void	setCapacityRequirementConfig(ScaleStrategyCapacityRequirementConfig capacityRequirement) Call once in order to modify the behavior of enforceCapacityRequirement()
void	setContainersSlaEnforcementEndpoint(ContainersSlaEnforcementEndpoint containersService)
void	setGridServiceContainerConfig(org.openspaces.admin.internal.pu.elastic.GridServiceContainerConfig containersConfig)
void	setMachinesSlaEnforcementEndpoint(MachinesSlaEnforcementEndpoint machinesService)
void	setRebalancingSlaEnforcementEndpoint(RebalancingSlaEnforcementEndpoint relocationService)
protected void	setScaleStrategyConfig(ScaleStrategyConfig scaleStrategy)

Methods inherited from class org.openspaces.grid.gsm.strategy.AbstractScaleStrategyBean

agentProvisioningCompletedEvent, agentProvisioningInProgressEvent, containerProvisioningCompletedEvent, containerProvisioningInProgressEvent, destroy, enforceSla, getAdmin, getContainerNumberOfCpuCores, getDiscoveredMachinesCache, getEventsStore, getIsolation, getLogger, getMachineProvisioning, getMaximumNumberOfInstances, getMinimumNumberOfMachines, getPollingIntervalSeconds, getProcessingUnit, getProperties, getSchemaConfig, isScaleInProgress, machineProvisioningCompletedEvent, machineProvisioningInProgressEvent, puInstanceProvisioningCompletedEvent, puInstanceProvisioningInProgressEvent, run, setAdmin, setElasticMachineProvisioning, setElasticProcessingUnitMachineIsolation, setElasticScaleStrategyEventStorage, setMachineDiscoveryQuiteMode, setProcessingUnit, setProcessingUnitSchema, setProperties

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

AbstractCapacityScaleStrategyBean

public AbstractCapacityScaleStrategyBean()

Method Detail

setMachinesSlaEnforcementEndpoint

public void setMachinesSlaEnforcementEndpoint(MachinesSlaEnforcementEndpoint machinesService)

Specified by:

setMachinesSlaEnforcementEndpoint in interface MachinesSlaEnforcementEndpointAware

setContainersSlaEnforcementEndpoint

public void setContainersSlaEnforcementEndpoint(ContainersSlaEnforcementEndpoint containersService)

Specified by:

setContainersSlaEnforcementEndpoint in interface ContainersSlaEnforcementEndpointAware

setRebalancingSlaEnforcementEndpoint

public void setRebalancingSlaEnforcementEndpoint(RebalancingSlaEnforcementEndpoint relocationService)

Specified by:

setRebalancingSlaEnforcementEndpoint in interface RebalancingSlaEnforcementEndpointAware

setCapacityRequirementConfig

protected void setCapacityRequirementConfig(ScaleStrategyCapacityRequirementConfig capacityRequirement)

Call once in order to modify the behavior of enforceCapacityRequirement()

getCapacityRequirementConfig

protected ScaleStrategyCapacityRequirementConfig getCapacityRequirementConfig()

setScaleStrategyConfig

protected void setScaleStrategyConfig(ScaleStrategyConfig scaleStrategy)

setGridServiceContainerConfig

public void setGridServiceContainerConfig(org.openspaces.admin.internal.pu.elastic.GridServiceContainerConfig containersConfig)

Specified by:

setGridServiceContainerConfig in interface GridServiceContainerConfigAware

getGridServiceContainerConfig

public org.openspaces.admin.internal.pu.elastic.GridServiceContainerConfig getGridServiceContainerConfig()

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

Overrides:

afterPropertiesSet in class AbstractScaleStrategyBean

See Also:

BeanConfigurationException, BeanInitializationException

enforceCapacityRequirement

protected void enforceCapacityRequirement()
                                   throws SlaEnforcementInProgressException

Throws:

SlaEnforcementInProgressException

calcMemoryInMB

protected long calcMemoryInMB()

isUndeploying

protected boolean isUndeploying()

Specified by:

isUndeploying in class AbstractScaleStrategyBean

Returns:

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