com.atlassian.buildeng.ecs.scheduling

Class AWSSchedulerBackend

java.lang.Object

com.atlassian.buildeng.ecs.scheduling.AWSSchedulerBackend

All Implemented Interfaces:

SchedulerBackend

public class AWSSchedulerBackend
extends Object
implements SchedulerBackend

class encapsulating all AWS interaction for the CyclingECSScheduler.

Constructor Summary

Constructors

Constructor and Description
AWSSchedulerBackend()

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) describeAutoScalingGroup.
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 request, String taskDefinition)
void	suspendProcess(String autoScalingGroupName, String processName)
void	terminateAndDetachInstances(List<DockerHost> hosts, String asgName, boolean decrementSize, String clusterName) terminate the listed EC2 instances and reduce the size of ASG by the given amount.
void	terminateInstances(List<String> instanceIds) terminate listed EC2 instances.

Methods inherited from class java.lang.Object

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

Constructor Detail

AWSSchedulerBackend

@Inject
public AWSSchedulerBackend()

Method Detail

getClusterContainerInstances

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

Description copied from interface: SchedulerBackend

Get all owned container instances on a cluster.

Specified by:

getClusterContainerInstances in interface SchedulerBackend

Throws:

ECSException

getInstances

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

Description copied from interface: SchedulerBackend

get EC2 Instances for the passed ids.

Specified by:

getInstances in interface SchedulerBackend

Throws:

ECSException

scaleTo

public void scaleTo(int desiredCapacity,
                    String autoScalingGroup)
             throws ECSException

Description copied from interface: SchedulerBackend

scale the ASG to desired capacity.

Specified by:

scaleTo in interface SchedulerBackend

Throws:

ECSException

terminateAndDetachInstances

public void terminateAndDetachInstances(List<DockerHost> hosts,
                                        String asgName,
                                        boolean decrementSize,
                                        String clusterName)
                                 throws ECSException

Description copied from interface: SchedulerBackend

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

Specified by:

terminateAndDetachInstances in interface SchedulerBackend

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

Throws:

ECSException

terminateInstances

public void terminateInstances(List<String> instanceIds)
                        throws ECSException

Description copied from interface: SchedulerBackend

terminate listed EC2 instances.

Specified by:

terminateInstances in interface SchedulerBackend

Throws:

ECSException

drainInstances

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

Description copied from interface: SchedulerBackend

set the listed EC2 instances to "draining" state.

Specified by:

drainInstances in interface SchedulerBackend

schedule

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

Specified by:

schedule in interface SchedulerBackend

Throws:

ECSException

describeAutoScalingGroup

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

describeAutoScalingGroup.

Specified by:

describeAutoScalingGroup in interface SchedulerBackend

Parameters:

autoScalingGroup - name

Returns:

described autoscaling group

Throws:

ECSException - when there are none or multiple matching AGSs

checkStoppedTasks

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

Description copied from interface: SchedulerBackend

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

Specified by:

checkStoppedTasks in interface SchedulerBackend

Throws:

ECSException

suspendProcess

public void suspendProcess(String autoScalingGroupName,
                           String processName)
                    throws ECSException

Specified by:

suspendProcess in interface SchedulerBackend

Throws:

ECSException