io.druid.indexing.overlord.autoscaling

Interface AutoScaler<T>

All Known Implementing Classes:

EC2AutoScaler, NoopAutoScaler

public interface AutoScaler<T>

The AutoScaler has the actual methods to provision and terminate worker nodes.

Method Summary

Modifier and Type	Method and Description
T	getEnvConfig()
int	getMaxNumWorkers()
int	getMinNumWorkers()
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)

Method Detail

getMinNumWorkers

int getMinNumWorkers()

getMaxNumWorkers

int getMaxNumWorkers()

getEnvConfig

T getEnvConfig()

provision

@Nullable
AutoScalingData provision()

terminate

@Nullable
AutoScalingData terminate(List<String> ips)

terminateWithIds

@Nullable
AutoScalingData terminateWithIds(List<String> ids)

ipToIdLookup

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

Provides a lookup of ip addresses to node ids

Parameters:

ips - - nodes IPs

Returns:

node ids

idToIpLookup

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

Provides a lookup of node ids to ip addresses

Parameters:

nodeIds - - nodes ids

Returns:

IPs associated with the node