You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by ni...@apache.org on 2013/12/10 15:54:11 UTC

[12/16] git commit: new API to return partitions of a partition group of a policy

new API to return partitions of a partition group of a policy


Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/d6bbd3af
Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/d6bbd3af
Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/d6bbd3af

Branch: refs/heads/master
Commit: d6bbd3afbd958ce92062ae7f64347cc5e705676d
Parents: 373ff78
Author: Nirmal Fernando <ni...@apache.org>
Authored: Tue Dec 10 20:04:20 2013 +0530
Committer: Nirmal Fernando <ni...@apache.org>
Committed: Tue Dec 10 20:04:20 2013 +0530

----------------------------------------------------------------------
 .../autoscaler/api/AutoScalerServiceImpl.java       | 16 ++++++++++++++++
 .../interfaces/AutoScalerServiceInterface.java      |  1 +
 2 files changed, 17 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/d6bbd3af/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/api/AutoScalerServiceImpl.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/api/AutoScalerServiceImpl.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/api/AutoScalerServiceImpl.java
index d41072b..23e3c7f 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/api/AutoScalerServiceImpl.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/api/AutoScalerServiceImpl.java
@@ -130,6 +130,22 @@ public class AutoScalerServiceImpl implements AutoScalerServiceInterface{
 		return depPol.getAllPartitions();
 	}
 	
+	@Override
+    public Partition[] getPartitionsOfGroup(String deploymentPolicyId, String groupId) {
+        DeploymentPolicy depPol = this.getDeploymentPolicy(deploymentPolicyId);
+        if(null == depPol) {
+            return null;
+        }
+        
+        PartitionGroup group = depPol.getPartitionGroup(groupId);
+        
+        if(group == null) {
+            return null;
+        }
+        
+        return group.getPartitions();
+    }
+	
 	public void checkLBExistence(String clusterId) throws NonExistingLBException {
         List<NetworkPartitionContext> nwPartitions = partitionManager.getAllNetworkPartitions();
         boolean exist = false;

http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/d6bbd3af/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/interfaces/AutoScalerServiceInterface.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/interfaces/AutoScalerServiceInterface.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/interfaces/AutoScalerServiceInterface.java
index a7f4c10..46d5806 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/interfaces/AutoScalerServiceInterface.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/interfaces/AutoScalerServiceInterface.java
@@ -24,6 +24,7 @@ public interface AutoScalerServiceInterface {
 	public DeploymentPolicy getDeploymentPolicy (String deploymentPolicyId);
 	public AutoscalePolicy getAutoscalingPolicy (String autoscalingPolicyId);
 	public PartitionGroup[] getPartitionGroups (String deploymentPolicyId);	
+	public Partition[] getPartitionsOfGroup(String deploymentPolicyId, String partitionGroup);
 	public Partition[] getPartitionsOfDeploymentPolicy(String deploymentPolicyId);
 	
 	public void checkLBExistence(String clusterId) throws NonExistingLBException;