com.atlassian.buildeng.ecs.scheduling

Interface SchedulerBackend

All Known Implementing Classes:

AWSSchedulerBackend

public interface SchedulerBackend

Author:

mkleint

Method Summary

Modifier and Type	Method and Description
Collection<ArnStoppedState>	checkStoppedTasks(String cluster, List<String> taskArns) for given taskArn strings return an ArnStoppedState object for every taskArn that is stopped or missing in the cluster.
com.amazonaws.services.autoscaling.model.AutoScalingGroup	describeAutoScalingGroup(String autoScalingGroup) describe autoscaling group of given name
void	drainInstances(List<DockerHost> hosts, String clusterName) set the listed EC2 instances to "draining" state
List<com.amazonaws.services.ecs.model.ContainerInstance>	getClusterContainerInstances(String cluster) Get all owned container instances on a cluster
List<com.amazonaws.services.ec2.model.Instance>	getInstances(Collection<String> instanceIds) get EC2 Instances for the passed ids
void	scaleTo(int desiredCapacity, String autoScalingGroup) scale the ASG to desired capacity
SchedulingResult	schedule(DockerHost dockerHost, String cluster, SchedulingRequest req, String taskDefinition)
void	suspendProcess(String autoScalingGroupName, String azRebalance)
void	terminateAndDetachInstances(List<DockerHost> dockerHosts, String autoScalingGroup, boolean decrementSize, String ecsClusterName) terminate the listed EC2 instances and reduce the size of ASG by the given amount
void	terminateInstances(List<String> instanceIds) terminate listed EC2 instances

Method Detail

getClusterContainerInstances

List<com.amazonaws.services.ecs.model.ContainerInstance> getClusterContainerInstances(String cluster)
                                                                               throws ECSException

Get all owned container instances on a cluster

Parameters:

cluster -

Returns:

Throws:

ECSException

getInstances

List<com.amazonaws.services.ec2.model.Instance> getInstances(Collection<String> instanceIds)
                                                      throws ECSException

get EC2 Instances for the passed ids

Parameters:

instanceIds -

Returns:

Throws:

ECSException

scaleTo

void scaleTo(int desiredCapacity,
             String autoScalingGroup)
      throws ECSException

scale the ASG to desired capacity

Parameters:

desiredCapacity -

autoScalingGroup -

Throws:

ECSException

terminateAndDetachInstances

void terminateAndDetachInstances(List<DockerHost> dockerHosts,
                                 String autoScalingGroup,
                                 boolean decrementSize,
                                 String ecsClusterName)
                          throws ECSException

terminate the listed EC2 instances and reduce the size of ASG by the given amount

Parameters:

dockerHosts -

autoScalingGroup -

decrementSize - should we decrease size of ASG or not? if not, new instance is started eventually.

ecsClusterName -

Throws:

ECSException

terminateInstances

void terminateInstances(List<String> instanceIds)
                 throws ECSException

terminate listed EC2 instances

Parameters:

instanceIds -

Throws:

ECSException

drainInstances

void drainInstances(List<DockerHost> hosts,
                    String clusterName)

set the listed EC2 instances to "draining" state

Parameters:

hosts -

clusterName -

schedule

SchedulingResult schedule(DockerHost dockerHost,
                          String cluster,
                          SchedulingRequest req,
                          String taskDefinition)
                   throws ECSException

Throws:

ECSException

describeAutoScalingGroup

com.amazonaws.services.autoscaling.model.AutoScalingGroup describeAutoScalingGroup(String autoScalingGroup)
                                                                            throws ECSException

describe autoscaling group of given name

Parameters:

autoScalingGroup -

Returns:

get AutoscalingGroup

Throws:

ECSException

checkStoppedTasks

Collection<ArnStoppedState> checkStoppedTasks(String cluster,
                                              List<String> taskArns)
                                       throws ECSException

for given taskArn strings return an ArnStoppedState object for every taskArn that is stopped or missing in the cluster.

Parameters:

cluster -

taskArns -

Returns:

Throws:

ECSException

suspendProcess

void suspendProcess(String autoScalingGroupName,
                    String azRebalance)
             throws ECSException

Throws:

ECSException