io.druid.indexing.overlord.autoscaling.ec2

Class EC2AutoScaler

java.lang.Object

io.druid.indexing.overlord.autoscaling.ec2.EC2AutoScaler

All Implemented Interfaces:

AutoScaler<EC2EnvironmentConfig>

public class EC2AutoScaler
extends Object
implements AutoScaler<EC2EnvironmentConfig>

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_AWS_FILTER_VALUES

Constructor Summary

Constructors

Constructor and Description
EC2AutoScaler(int minNumWorkers, int maxNumWorkers, EC2EnvironmentConfig envConfig, com.amazonaws.services.ec2.AmazonEC2 amazonEC2Client, SimpleWorkerProvisioningConfig config)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
EC2EnvironmentConfig	getEnvConfig()
int	getMaxNumWorkers()
int	getMinNumWorkers()
int	hashCode()
List<String>	idToIpLookup(List<String> nodeIds) Provides a lookup of node ids to ip addresses
List<String>	ipToIdLookup(List<String> ips) Provides a lookup of ip addresses to node ids
AutoScalingData	provision()
AutoScalingData	terminate(List<String> ips)
AutoScalingData	terminateWithIds(List<String> ids)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

MAX_AWS_FILTER_VALUES

public static final int MAX_AWS_FILTER_VALUES

See Also:

Constant Field Values

Constructor Detail

EC2AutoScaler

public EC2AutoScaler(int minNumWorkers,
                     int maxNumWorkers,
                     EC2EnvironmentConfig envConfig,
                     com.amazonaws.services.ec2.AmazonEC2 amazonEC2Client,
                     SimpleWorkerProvisioningConfig config)

Method Detail

getMinNumWorkers

public int getMinNumWorkers()

Specified by:

getMinNumWorkers in interface AutoScaler<EC2EnvironmentConfig>

getMaxNumWorkers

public int getMaxNumWorkers()

Specified by:

getMaxNumWorkers in interface AutoScaler<EC2EnvironmentConfig>

getEnvConfig

public EC2EnvironmentConfig getEnvConfig()

Specified by:

getEnvConfig in interface AutoScaler<EC2EnvironmentConfig>

provision

public AutoScalingData provision()

Specified by:

provision in interface AutoScaler<EC2EnvironmentConfig>

terminate

public AutoScalingData terminate(List<String> ips)

Specified by:

terminate in interface AutoScaler<EC2EnvironmentConfig>

terminateWithIds

public AutoScalingData terminateWithIds(List<String> ids)

Specified by:

terminateWithIds in interface AutoScaler<EC2EnvironmentConfig>

ipToIdLookup

public List<String> ipToIdLookup(List<String> ips)

Description copied from interface: AutoScaler

Provides a lookup of ip addresses to node ids

Specified by:

ipToIdLookup in interface AutoScaler<EC2EnvironmentConfig>

Parameters:

ips - - nodes IPs

Returns:

node ids

idToIpLookup

public List<String> idToIpLookup(List<String> nodeIds)

Description copied from interface: AutoScaler

Provides a lookup of node ids to ip addresses

Specified by:

idToIpLookup in interface AutoScaler<EC2EnvironmentConfig>

Parameters:

nodeIds - - nodes ids

Returns:

IPs associated with the node

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object