org.openspaces.grid.gsm.rebalancing

Class RebalancingSlaEnforcement

java.lang.Object

org.openspaces.grid.gsm.rebalancing.RebalancingSlaEnforcement

All Implemented Interfaces:

ServiceLevelAgreementEnforcement<RebalancingSlaEnforcementEndpoint>

public class RebalancingSlaEnforcement
extends Object
implements ServiceLevelAgreementEnforcement<RebalancingSlaEnforcementEndpoint>

Implements the elastic re-balancing algorithm based on the specified SLA. Each endpoint is dedicated to the rebalancing of one processing unit. The SLA specifies the containers that are approved for the pu deployment, and the algorithm enforces equal spread of instances per container, and the primary instances per machine.

Author:

itaif

Constructor Summary

Constructors

Constructor and Description
RebalancingSlaEnforcement()

Method Summary

Modifier and Type	Method and Description
RebalancingSlaEnforcementEndpoint	createEndpoint(ProcessingUnit pu) Creates a new endpoint for the specified pu, if one does not already exist.
void	destroy()
void	destroyEndpoint(ProcessingUnit pu) Destroys the endpoint for the specified pu.
void	enableTracing()
List<FutureStatefulProcessingUnitInstance>	getTrace()

Methods inherited from class java.lang.Object

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

Constructor Detail

RebalancingSlaEnforcement

public RebalancingSlaEnforcement()

Method Detail

enableTracing

public void enableTracing()

getTrace

public List<FutureStatefulProcessingUnitInstance> getTrace()

destroy

public void destroy()

createEndpoint

public RebalancingSlaEnforcementEndpoint createEndpoint(ProcessingUnit pu)
                                                 throws ServiceLevelAgreementEnforcementEndpointAlreadyExistsException

Description copied from interface: ServiceLevelAgreementEnforcement

Creates a new endpoint for the specified pu, if one does not already exist. If an endpoint already exists an exception is raised.

Specified by:

createEndpoint in interface ServiceLevelAgreementEnforcement<RebalancingSlaEnforcementEndpoint>

Parameters:

pu - target processing unit for the endpoint creation

Returns:

the new endpoint

Throws:

ServiceLevelAgreementEnforcementEndpointAlreadyExistsException

destroyEndpoint

public void destroyEndpoint(ProcessingUnit pu)

Description copied from interface: ServiceLevelAgreementEnforcement

Destroys the endpoint for the specified pu.

Specified by:

destroyEndpoint in interface ServiceLevelAgreementEnforcement<RebalancingSlaEnforcementEndpoint>

Parameters:

pu - target processing unit for the endpoint destruction