GigaSpaces XAP 9.0 API

org.openspaces.grid.gsm.machines
Class MachinesSlaEnforcementState

java.lang.Object
  extended by org.openspaces.grid.gsm.machines.MachinesSlaEnforcementState

public class MachinesSlaEnforcementState
extends Object


Constructor Summary
MachinesSlaEnforcementState()
           
 
Method Summary
 void agentGoingDown(ProcessingUnit pu, String agentUid, long timeout, TimeUnit unit)
           
 void agentShutdownComplete(String agentUid)
           
 void allocateCapacity(ProcessingUnit pu, String agentUid, CapacityRequirements capacity)
           
 void completedStateRecovery(ProcessingUnit pu)
           
 void deallocateAgentCapacity(ProcessingUnit pu, String agentUid)
           
 void deallocateCapacity(ProcessingUnit pu, String agentUid, CapacityRequirements capacity)
           
 void destroyProcessingUnit(ProcessingUnit pu)
           
 void futureAgents(ProcessingUnit pu, FutureGridServiceAgent[] futureAgents, CapacityRequirements capacityRequirements)
           
 Collection<String> getAgentUidsGoingDown(ProcessingUnit pu)
           
 Collection<org.openspaces.grid.gsm.machines.GridServiceAgentFutures> getAllDoneFutureAgents(ProcessingUnit pu)
           
 ClusterCapacityRequirements getAllocatedCapacity(ProcessingUnit pu)
           
 Map<ProcessingUnit,ClusterCapacityRequirements> getAllocatedCapacityPerProcessingUnit()
           
 List<ProcessingUnit> getAllProcessingUnitsNotCompletedStateRecovery(Admin admin)
           
 Collection<String> getAllUsedAgentUids()
          Lists all grid service agents from all processing units including those that are marked for deallocation.
 Collection<String> getAllUsedAgentUidsForPu(ProcessingUnit pu)
           
 ClusterCapacityRequirements getAllUsedCapacity()
          Lists all capacity from all processing units including those that are marked for deallocation.
 ClusterCapacityRequirements getCapacityMarkedForDeallocation(ProcessingUnit pu)
           
 Collection<org.openspaces.grid.gsm.machines.GridServiceAgentFutures> getFutureAgents(ProcessingUnit pu)
           
 ElasticProcessingUnitMachineIsolation getMachineIsolation(ProcessingUnit pu)
           
 int getNumberOfFutureAgents(ProcessingUnit pu)
           
 String[] getProcessingUnitsOfFutureMachine(ProcessingUnit pu, FutureGridServiceAgent futureAgent)
           
 Collection<String> getRestrictedAgentUidsForPu(ProcessingUnit pu)
           
 void initProcessingUnit(ProcessingUnit pu)
           
 boolean isAgentSharedWithOtherProcessingUnits(ProcessingUnit pu, String agentUid)
           
 boolean isAgentUidGoingDownTimedOut(String agentUid)
           
 boolean isCompletedStateRecovery(ProcessingUnit pu)
           
 boolean isProcessingUnitDestroyed(ProcessingUnit pu)
           
 void markAgentCapacityForDeallocation(ProcessingUnit pu, String uid)
           
 void markCapacityForDeallocation(ProcessingUnit pu, String agentUid, CapacityRequirements capacity)
           
 void removeFutureAgents(ProcessingUnit pu, org.openspaces.grid.gsm.machines.GridServiceAgentFutures futureAgents)
           
 void setMachineIsolation(ProcessingUnit pu, ElasticProcessingUnitMachineIsolation isolation)
           
 void slaEnforcementComplete(ProcessingUnit pu)
           
 void slaEnforcementInProgress(ProcessingUnit pu)
           
 void unmarkCapacityForDeallocation(ProcessingUnit pu, String agentUid, CapacityRequirements capacity)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MachinesSlaEnforcementState

public MachinesSlaEnforcementState()
Method Detail

initProcessingUnit

public void initProcessingUnit(ProcessingUnit pu)

destroyProcessingUnit

public void destroyProcessingUnit(ProcessingUnit pu)

isProcessingUnitDestroyed

public boolean isProcessingUnitDestroyed(ProcessingUnit pu)

futureAgents

public void futureAgents(ProcessingUnit pu,
                         FutureGridServiceAgent[] futureAgents,
                         CapacityRequirements capacityRequirements)

allocateCapacity

public void allocateCapacity(ProcessingUnit pu,
                             String agentUid,
                             CapacityRequirements capacity)

markCapacityForDeallocation

public void markCapacityForDeallocation(ProcessingUnit pu,
                                        String agentUid,
                                        CapacityRequirements capacity)

unmarkCapacityForDeallocation

public void unmarkCapacityForDeallocation(ProcessingUnit pu,
                                          String agentUid,
                                          CapacityRequirements capacity)

deallocateCapacity

public void deallocateCapacity(ProcessingUnit pu,
                               String agentUid,
                               CapacityRequirements capacity)

getCapacityMarkedForDeallocation

public ClusterCapacityRequirements getCapacityMarkedForDeallocation(ProcessingUnit pu)

getAllocatedCapacity

public ClusterCapacityRequirements getAllocatedCapacity(ProcessingUnit pu)

getNumberOfFutureAgents

public int getNumberOfFutureAgents(ProcessingUnit pu)

getFutureAgents

public Collection<org.openspaces.grid.gsm.machines.GridServiceAgentFutures> getFutureAgents(ProcessingUnit pu)

getAllDoneFutureAgents

public Collection<org.openspaces.grid.gsm.machines.GridServiceAgentFutures> getAllDoneFutureAgents(ProcessingUnit pu)

getAllUsedAgentUids

public Collection<String> getAllUsedAgentUids()
Lists all grid service agents from all processing units including those that are marked for deallocation.


getAllUsedCapacity

public ClusterCapacityRequirements getAllUsedCapacity()
Lists all capacity from all processing units including those that are marked for deallocation.


isAgentSharedWithOtherProcessingUnits

public boolean isAgentSharedWithOtherProcessingUnits(ProcessingUnit pu,
                                                     String agentUid)
Returns:
true if processing units other than the specified PU, also use the specified agent. false otherwise.

agentGoingDown

public void agentGoingDown(ProcessingUnit pu,
                           String agentUid,
                           long timeout,
                           TimeUnit unit)

agentShutdownComplete

public void agentShutdownComplete(String agentUid)

getAgentUidsGoingDown

public Collection<String> getAgentUidsGoingDown(ProcessingUnit pu)

isAgentUidGoingDownTimedOut

public boolean isAgentUidGoingDownTimedOut(String agentUid)

markAgentCapacityForDeallocation

public void markAgentCapacityForDeallocation(ProcessingUnit pu,
                                             String uid)

deallocateAgentCapacity

public void deallocateAgentCapacity(ProcessingUnit pu,
                                    String agentUid)

getRestrictedAgentUidsForPu

public Collection<String> getRestrictedAgentUidsForPu(ProcessingUnit pu)
Returns:
all Grid Service Agent UIDs that the specified PU cannot be deploy on due to machine isolation restrictions or due to the fact that the machine is about to be deployed by another PU that started it.

getProcessingUnitsOfFutureMachine

public String[] getProcessingUnitsOfFutureMachine(ProcessingUnit pu,
                                                  FutureGridServiceAgent futureAgent)
Returns:
all processing units that have a share of the specified future machine not implemented yet. See GS-9484

slaEnforcementComplete

public void slaEnforcementComplete(ProcessingUnit pu)

slaEnforcementInProgress

public void slaEnforcementInProgress(ProcessingUnit pu)

removeFutureAgents

public void removeFutureAgents(ProcessingUnit pu,
                               org.openspaces.grid.gsm.machines.GridServiceAgentFutures futureAgents)

getAllUsedAgentUidsForPu

public Collection<String> getAllUsedAgentUidsForPu(ProcessingUnit pu)

setMachineIsolation

public void setMachineIsolation(ProcessingUnit pu,
                                ElasticProcessingUnitMachineIsolation isolation)

getMachineIsolation

public ElasticProcessingUnitMachineIsolation getMachineIsolation(ProcessingUnit pu)

isCompletedStateRecovery

public boolean isCompletedStateRecovery(ProcessingUnit pu)

completedStateRecovery

public void completedStateRecovery(ProcessingUnit pu)

getAllProcessingUnitsNotCompletedStateRecovery

public List<ProcessingUnit> getAllProcessingUnitsNotCompletedStateRecovery(Admin admin)

getAllocatedCapacityPerProcessingUnit

public Map<ProcessingUnit,ClusterCapacityRequirements> getAllocatedCapacityPerProcessingUnit()

GigaSpaces XAP 9.0 API

Copyright © GigaSpaces.