com.atlassian.bamboo.agent.elastic.server
Class ElasticInstanceManagerImpl

java.lang.Object
  extended by com.atlassian.bamboo.agent.elastic.server.ElasticInstanceManagerImpl
All Implemented Interfaces:
ElasticInstanceManager, ElasticAgentTunnelPorts

public class ElasticInstanceManagerImpl
extends java.lang.Object
implements ElasticInstanceManager


Field Summary
 
Fields inherited from interface com.atlassian.bamboo.agent.elastic.server.ElasticInstanceManager
DEFAULT_INSTANCE_TYPE_32, DEFAULT_INSTANCE_TYPE_64, DEFAULT_PRODUCT_FOR_LINUX_PLATFORM, DEFAULT_PRODUCT_FOR_WINDOWS_PLATFORM, ELASTIC_BAMBOO_KEY_PAIR, ELASTIC_BAMBOO_KEY_PAIR_FILE, ELASTIC_BAMBOO_SECURITY_GROUP
 
Constructor Summary
ElasticInstanceManagerImpl(AwsAccountBean awsAccountBean, AdministrationConfigurationManager administrationConfigurationManager, int startupTimeoutSeconds, java.util.concurrent.ScheduledExecutorService executor, KeyStoreFactory keyStoreFactory, SSLContextFactory sslContextFactory, BootstrapManager bootstrapManager, ErrorHandler errorHandler, com.atlassian.bamboo.agent.elastic.server.EBSVolumeSupervisorFactory ebsVolumeSupervisorFactory)
           
 
Method Summary
 void addElasticLogEntry(org.apache.log4j.Logger log, java.lang.String logEntry)
           
 void addElasticLogEntry(java.lang.String logEntry)
          Add a line to the elastic activity logs
 void ensureLoginKeyPairExists(com.atlassian.aws.AWSAccount awsAccount)
          Ensures that a key pair, named "elasticbamboo", has been defined in the configured AWS account.
 com.google.common.collect.SetMultimap<ElasticImageConfiguration,RemoteElasticInstance> getAllElasticAgentsAsMap()
          Returns all elastic instances in a SetMultimap, keyed by the ElasticImageConfiguration
 java.util.List<RemoteElasticInstance> getAllElasticRemoteAgents()
          Returns all elastic instances.
 java.util.Set<com.atlassian.aws.ec2.EC2InstanceType> getAllowedInstanceTypes()
           
 java.util.List<java.lang.String> getElasticAgentLogs()
          Retrieve activity logs
 RemoteElasticInstance getElasticRemoteAgentByInstanceId(java.lang.String instanceId)
          Retrieve elastic instance of the given ID.
 java.util.List<RemoteElasticInstance> getElasticRemoteAgents()
          Retrieve a readonly list of any currently existing EC2 instances
 java.util.List<RemoteElasticInstance> getElasticRemoteAgentsByConfiguration(ElasticImageConfiguration elasticImageConfiguration)
           
 java.util.List<RemoteElasticInstance> getElasticRemoteAgentsByConfiguration(long id)
           
 int getHTTPProxyPort()
          The TCP port upon which the Elastic Agent listens for HTTP traffic intended for the Bamboo Server.
 java.util.List<RemoteElasticInstance> getInstancesWithStartingAgents()
          Returns those elastic instances that have already started but their agents have not yet connected to the bamboo server.
 int getJMSProxyPort()
          The TCP port upon which the Elastic Agent listens for JMS traffic intended for the Bamboo Server.
 java.util.List<RemoteElasticInstance> getRequestedElasticRemoteAgents()
          Returns the elastic instances which have been requested but not yet identified.
 java.util.List<RemoteElasticInstance> getStartingElasticInstances()
          Return the elastic instances which have been identified but not started up yet, i.e.
 int getTotalNumElasticRemoteAgents()
          Return how many license spots are currently being occupied by elastic instances (pending and running)
 int getTunnelPort()
          The TCP port upon which Elastic Agents listens for incoming tunnel connections from the Bamboo Server.
 boolean isElasticSupportEnabled()
           
 RemoteElasticInstance newElasticAgent(RemoteElasticInstanceListener listener, com.atlassian.aws.AWSAccount awsAccount, AgentManager agentManager, ElasticImageConfiguration elasticImageConfiguration)
           
 void onInstanceIdentified(RemoteElasticInstance instance)
          Tell the manager that the instance is up and running
 void onInstanceRunning(RemoteElasticInstance instance)
          Invoked when the instance enters the 'running' state
 void registerElasticAgentStopped(RemoteElasticInstance instance)
          Remove and EC2 instance from the "currently Running map
 void setTunnelTimeoutMinutes(int tunnelTimeoutMinutes)
           
 boolean validateAwsCredentials(java.lang.String awsAccessID, java.lang.String awsSecretKey, ErrorCollection errorCollection)
          Validate a set of supplied AWS credentials.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ElasticInstanceManagerImpl

public ElasticInstanceManagerImpl(AwsAccountBean awsAccountBean,
                                  AdministrationConfigurationManager administrationConfigurationManager,
                                  int startupTimeoutSeconds,
                                  java.util.concurrent.ScheduledExecutorService executor,
                                  KeyStoreFactory keyStoreFactory,
                                  SSLContextFactory sslContextFactory,
                                  BootstrapManager bootstrapManager,
                                  ErrorHandler errorHandler,
                                  com.atlassian.bamboo.agent.elastic.server.EBSVolumeSupervisorFactory ebsVolumeSupervisorFactory)
Method Detail

newElasticAgent

public RemoteElasticInstance newElasticAgent(RemoteElasticInstanceListener listener,
                                             com.atlassian.aws.AWSAccount awsAccount,
                                             @NotNull
                                             AgentManager agentManager,
                                             @NotNull
                                             ElasticImageConfiguration elasticImageConfiguration)
                                      throws java.security.NoSuchAlgorithmException,
                                             java.security.KeyManagementException,
                                             java.io.IOException,
                                             java.security.cert.CertificateException,
                                             java.security.UnrecoverableKeyException,
                                             java.security.KeyStoreException
Specified by:
newElasticAgent in interface ElasticInstanceManager
Throws:
java.security.NoSuchAlgorithmException
java.security.KeyManagementException
java.io.IOException
java.security.cert.CertificateException
java.security.UnrecoverableKeyException
java.security.KeyStoreException

ensureLoginKeyPairExists

public void ensureLoginKeyPairExists(com.atlassian.aws.AWSAccount awsAccount)
                              throws com.atlassian.aws.AWSException
Description copied from interface: ElasticInstanceManager

Ensures that a key pair, named "elasticbamboo", has been defined in the configured AWS account.

Specified by:
ensureLoginKeyPairExists in interface ElasticInstanceManager
Parameters:
awsAccount - that should contain the key pair
Throws:
com.atlassian.aws.AWSException - if there is a problem communicating with EC2.

validateAwsCredentials

public boolean validateAwsCredentials(java.lang.String awsAccessID,
                                      java.lang.String awsSecretKey,
                                      ErrorCollection errorCollection)
Description copied from interface: ElasticInstanceManager

Validate a set of supplied AWS credentials.

Specified by:
validateAwsCredentials in interface ElasticInstanceManager
Parameters:
awsAccessID - The Access ID of the Amazon Web Services Account
awsSecretKey - The Secret Key of the Amazon Web Services Account
errorCollection - An ErrorCollection to which validation errors should be added, or null if validation errors are not required.
Returns:
true if the supplied credentials are successfully validated; false otherwise.

getElasticRemoteAgents

@NotNull
public java.util.List<RemoteElasticInstance> getElasticRemoteAgents()
Description copied from interface: ElasticInstanceManager
Retrieve a readonly list of any currently existing EC2 instances

Specified by:
getElasticRemoteAgents in interface ElasticInstanceManager
Returns:
List of RemoteElasticInstance

getElasticRemoteAgentsByConfiguration

@NotNull
public java.util.List<RemoteElasticInstance> getElasticRemoteAgentsByConfiguration(ElasticImageConfiguration elasticImageConfiguration)
Specified by:
getElasticRemoteAgentsByConfiguration in interface ElasticInstanceManager

getElasticRemoteAgentsByConfiguration

@NotNull
public java.util.List<RemoteElasticInstance> getElasticRemoteAgentsByConfiguration(long id)
Specified by:
getElasticRemoteAgentsByConfiguration in interface ElasticInstanceManager

getElasticRemoteAgentByInstanceId

@Nullable
public RemoteElasticInstance getElasticRemoteAgentByInstanceId(java.lang.String instanceId)
Description copied from interface: ElasticInstanceManager
Retrieve elastic instance of the given ID.

Specified by:
getElasticRemoteAgentByInstanceId in interface ElasticInstanceManager
Parameters:
instanceId - of the instance
Returns:
the elastic remote agent specific to the provided instance id

getRequestedElasticRemoteAgents

@NotNull
public java.util.List<RemoteElasticInstance> getRequestedElasticRemoteAgents()
Description copied from interface: ElasticInstanceManager
Returns the elastic instances which have been requested but not yet identified.

Specified by:
getRequestedElasticRemoteAgents in interface ElasticInstanceManager
Returns:
List of elastic instances which have been requested but not yet started up yet..

getStartingElasticInstances

@NotNull
public java.util.List<RemoteElasticInstance> getStartingElasticInstances()
Description copied from interface: ElasticInstanceManager
Return the elastic instances which have been identified but not started up yet, i.e. those instances that are IDENTIFIED pending to move to RUNNING state. The list does not include those instances that have been requested but not yet identified.

Specified by:
getStartingElasticInstances in interface ElasticInstanceManager
Returns:
List of elastic instances which have been requested and identified but not yet started up yet..

getInstancesWithStartingAgents

@NotNull
public java.util.List<RemoteElasticInstance> getInstancesWithStartingAgents()
Description copied from interface: ElasticInstanceManager
Returns those elastic instances that have already started but their agents have not yet connected to the bamboo server. Once the elastic instance is started it launches a bamboo agents that connects to the bamboo server. There is a period of time when the instance has already started (and therefore it is not returned by ElasticInstanceManager.getRequestedElasticRemoteAgents()) but the agent on the instance has not yet connected to the bamboo server. Elastic instances in such state are returned by this method and the list is a subset of the list returned by ElasticInstanceManager.getElasticRemoteAgents().

Specified by:
getInstancesWithStartingAgents in interface ElasticInstanceManager
Returns:
List of RemoteElasticInstance

getAllElasticRemoteAgents

public java.util.List<RemoteElasticInstance> getAllElasticRemoteAgents()
Description copied from interface: ElasticInstanceManager
Returns all elastic instances. It includes requested agents as well as active agents

Specified by:
getAllElasticRemoteAgents in interface ElasticInstanceManager
Returns:

getAllElasticAgentsAsMap

public com.google.common.collect.SetMultimap<ElasticImageConfiguration,RemoteElasticInstance> getAllElasticAgentsAsMap()
Description copied from interface: ElasticInstanceManager
Returns all elastic instances in a SetMultimap, keyed by the ElasticImageConfiguration

Specified by:
getAllElasticAgentsAsMap in interface ElasticInstanceManager
Returns:

getTotalNumElasticRemoteAgents

public int getTotalNumElasticRemoteAgents()
Description copied from interface: ElasticInstanceManager
Return how many license spots are currently being occupied by elastic instances (pending and running)

Specified by:
getTotalNumElasticRemoteAgents in interface ElasticInstanceManager
Returns:
Number of license slots currently occupied by elastic instances (pending and running).

onInstanceIdentified

public void onInstanceIdentified(@NotNull
                                 RemoteElasticInstance instance)
Description copied from interface: ElasticInstanceManager
Tell the manager that the instance is up and running

Specified by:
onInstanceIdentified in interface ElasticInstanceManager
Parameters:
instance - the instance identified

onInstanceRunning

public void onInstanceRunning(@NotNull
                              RemoteElasticInstance instance)
Description copied from interface: ElasticInstanceManager
Invoked when the instance enters the 'running' state

Specified by:
onInstanceRunning in interface ElasticInstanceManager
Parameters:
instance - the instance that entered running state

registerElasticAgentStopped

public void registerElasticAgentStopped(@NotNull
                                        RemoteElasticInstance instance)
Description copied from interface: ElasticInstanceManager
Remove and EC2 instance from the "currently Running map

Specified by:
registerElasticAgentStopped in interface ElasticInstanceManager
Parameters:
instance - - the one to be deleted from the map

addElasticLogEntry

public void addElasticLogEntry(java.lang.String logEntry)
Description copied from interface: ElasticInstanceManager
Add a line to the elastic activity logs

Specified by:
addElasticLogEntry in interface ElasticInstanceManager
Parameters:
logEntry - - the line you want added to the logs

addElasticLogEntry

public void addElasticLogEntry(org.apache.log4j.Logger log,
                               java.lang.String logEntry)
Specified by:
addElasticLogEntry in interface ElasticInstanceManager

getElasticAgentLogs

public java.util.List<java.lang.String> getElasticAgentLogs()
Description copied from interface: ElasticInstanceManager
Retrieve activity logs

Specified by:
getElasticAgentLogs in interface ElasticInstanceManager
Returns:
a copy of the current elastic agent logs

isElasticSupportEnabled

public boolean isElasticSupportEnabled()
Specified by:
isElasticSupportEnabled in interface ElasticInstanceManager
Returns:
true, if elastic support is turned on

getAllowedInstanceTypes

@NotNull
public java.util.Set<com.atlassian.aws.ec2.EC2InstanceType> getAllowedInstanceTypes()
Specified by:
getAllowedInstanceTypes in interface ElasticInstanceManager
Returns:
Set of allowed instance types.

getTunnelPort

public int getTunnelPort()
Description copied from interface: ElasticAgentTunnelPorts

The TCP port upon which Elastic Agents listens for incoming tunnel connections from the Bamboo Server.

Specified by:
getTunnelPort in interface ElasticAgentTunnelPorts

getHTTPProxyPort

public int getHTTPProxyPort()
Description copied from interface: ElasticAgentTunnelPorts

The TCP port upon which the Elastic Agent listens for HTTP traffic intended for the Bamboo Server.

Specified by:
getHTTPProxyPort in interface ElasticAgentTunnelPorts

getJMSProxyPort

public int getJMSProxyPort()
Description copied from interface: ElasticAgentTunnelPorts

The TCP port upon which the Elastic Agent listens for JMS traffic intended for the Bamboo Server.

Specified by:
getJMSProxyPort in interface ElasticAgentTunnelPorts

setTunnelTimeoutMinutes

public void setTunnelTimeoutMinutes(int tunnelTimeoutMinutes)


Copyright © 2012 Atlassian. All Rights Reserved.