com.enremmeta.rtb

Class AwsOrchestrator

java.lang.Object

com.enremmeta.rtb.AwsOrchestrator

All Implemented Interfaces:

Orchestrator

public final class AwsOrchestrator
extends Object
implements Orchestrator

An Orchestrator for Amazon.

Author:

Gregory Golberg (grisha@alum.mit.edu)

Copyright © Enremmeta LLC 2015. All Rights Reserved.

Field Summary

Fields

Modifier and Type	Field and Description
private String	akey
private static Object	apiSynchronizer
private com.amazonaws.services.ec2.AmazonEC2Client	client
private OrchestratorConfig	config
private com.amazonaws.auth.AWSCredentials	creds
static String	DEPLOY_TYPE
private String	ec2Endpoint
private com.amazonaws.services.elasticloadbalancing.AmazonElasticLoadBalancingClient	elbClient
private String	elbEndpoint
private String	elbName
private boolean	isBidder
private long	lastAwsApiCallTs
private String	nodeId
private int	numberOfPeers
private int	previousNumberOfPeers
private String	skey

Constructor Summary

Constructors

Constructor and Description
AwsOrchestrator(OrchestratorConfig config)

Method Summary

Modifier and Type	Method and Description
private String	discoverNodeId()
String	getDeployType()
String	getNodeId()
int	getNumberOfPeers()
private int	getNumberOfPeers(String loadBalancerName)
String	getRegion()
boolean	isBidder()

Methods inherited from class java.lang.Object

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

Field Detail

DEPLOY_TYPE

public static final String DEPLOY_TYPE

See Also:

Constant Field Values

elbName

private final String elbName

elbEndpoint

private final String elbEndpoint

ec2Endpoint

private final String ec2Endpoint

nodeId

private final String nodeId

isBidder

private final boolean isBidder

previousNumberOfPeers

private int previousNumberOfPeers

config

private final OrchestratorConfig config

skey

private final String skey

akey

private final String akey

creds

private com.amazonaws.auth.AWSCredentials creds

elbClient

private final com.amazonaws.services.elasticloadbalancing.AmazonElasticLoadBalancingClient elbClient

client

private final com.amazonaws.services.ec2.AmazonEC2Client client

apiSynchronizer

private static final Object apiSynchronizer

lastAwsApiCallTs

private long lastAwsApiCallTs

numberOfPeers

private int numberOfPeers

Constructor Detail

AwsOrchestrator

public AwsOrchestrator(OrchestratorConfig config)
                throws Lot49Exception

Throws:

Lot49Exception

Method Detail

getDeployType

public String getDeployType()

Specified by:

getDeployType in interface Orchestrator

getNodeId

public String getNodeId()

Specified by:

getNodeId in interface Orchestrator

discoverNodeId

private String discoverNodeId()
                       throws Throwable

Throws:

Throwable

isBidder

public boolean isBidder()

Specified by:

isBidder in interface Orchestrator

getNumberOfPeers

private int getNumberOfPeers(String loadBalancerName)
                      throws Lot49Exception

Throws:

Lot49Exception

getNumberOfPeers

public int getNumberOfPeers()
                     throws Lot49Exception

Specified by:

getNumberOfPeers in interface Orchestrator

Throws:

Lot49Exception

getRegion

public String getRegion()

Specified by:

getRegion in interface Orchestrator