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.

Throws:

ECSException

getInstances

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

get EC2 Instances for the passed ids.

Throws:

ECSException

scaleTo

void scaleTo(int desiredCapacity,
             String autoScalingGroup)
      throws ECSException

scale the ASG to desired capacity.

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:

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

Throws:

ECSException

terminateInstances

void terminateInstances(List<String> instanceIds)
                 throws ECSException

terminate listed EC2 instances.

Throws:

ECSException

drainInstances

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

set the listed EC2 instances to "draining" state.

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.

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.

Throws:

ECSException

suspendProcess

void suspendProcess(String autoScalingGroupName,
                    String azRebalance)
             throws ECSException

Throws:

ECSException