io.druid.indexing.overlord.scaling

Class EC2AutoScalingStrategy

java.lang.Object

io.druid.indexing.overlord.scaling.EC2AutoScalingStrategy

All Implemented Interfaces:

AutoScalingStrategy

public class EC2AutoScalingStrategy
extends Object
implements AutoScalingStrategy

Constructor Summary

Constructors

Constructor and Description
EC2AutoScalingStrategy(com.amazonaws.services.ec2.AmazonEC2 amazonEC2Client, SimpleResourceManagementConfig config, com.google.common.base.Supplier<WorkerSetupData> workerSetupDataRef)

Method Summary

Methods

Modifier and Type	Method and Description
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)

Methods inherited from class java.lang.Object

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

Constructor Detail

EC2AutoScalingStrategy

@Inject
public EC2AutoScalingStrategy(com.amazonaws.services.ec2.AmazonEC2 amazonEC2Client,
                             SimpleResourceManagementConfig config,
                             com.google.common.base.Supplier<WorkerSetupData> workerSetupDataRef)

Method Detail

provision

public AutoScalingData provision()

Specified by:

provision in interface AutoScalingStrategy

terminate

public AutoScalingData terminate(List<String> ips)

Specified by:

terminate in interface AutoScalingStrategy

terminateWithIds

public AutoScalingData terminateWithIds(List<String> ids)

Specified by:

terminateWithIds in interface AutoScalingStrategy

ipToIdLookup

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

Description copied from interface: AutoScalingStrategy

Provides a lookup of ip addresses to node ids

Specified by:

ipToIdLookup in interface AutoScalingStrategy

Parameters:

ips - - nodes IPs

Returns:

node ids

idToIpLookup

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

Description copied from interface: AutoScalingStrategy

Provides a lookup of node ids to ip addresses

Specified by:

idToIpLookup in interface AutoScalingStrategy

Parameters:

nodeIds - - nodes ids

Returns:

IPs associated with the node