com.atlassian.bamboo.agent.elastic.server

Class ElasticInstanceManagerImpl

java.lang.Object

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

All Implemented Interfaces:

com.atlassian.bamboo.agent.elastic.server.ElasticInstanceManager, ElasticAgentTunnelPorts

public class ElasticInstanceManagerImpl
extends Object
implements com.atlassian.bamboo.agent.elastic.server.ElasticInstanceManager

Field Summary

Fields inherited from interface com.atlassian.bamboo.agent.elastic.server.ElasticInstanceManager

BAMBOO_CONTROL_TAG, 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

Constructors

Constructor and Description

ElasticInstanceManagerImpl(com.atlassian.bamboo.agent.elastic.aws.AwsAccountBean awsAccountBean, AdministrationConfigurationAccessor administrationConfigurationAccessor, int startupTimeoutSeconds, ScheduledExecutorService executor, KeyStoreFactory keyStoreFactory, SSLContextFactory sslContextFactory, com.atlassian.bamboo.setup.BootstrapManager bootstrapManager, com.atlassian.bamboo.logger.ErrorHandler errorHandler, com.atlassian.bamboo.agent.elastic.server.SpotInstanceConfigurationAccessor spotInstanceConfigurationAccessor)

Method Summary

Methods

Modifier and Type	Method and Description
void	addElasticLogEntry(org.apache.log4j.Logger log, String logEntry)
boolean	cancelSpotRequests(com.atlassian.aws.AWSAccount awsAccount)
void	ensureLoginKeyPairExists(com.atlassian.aws.AWSAccount awsAccount, String keyPair)
int	getAgentSideHttpPort()
int	getAgentSideJmsPort()
com.google.common.collect.SetMultimap<com.atlassian.bamboo.agent.elastic.server.ElasticImageConfiguration,com.atlassian.bamboo.agent.elastic.server.RemoteElasticInstance>	getAllElasticAgentsAsMap()
List<com.atlassian.bamboo.agent.elastic.server.RemoteElasticInstance>	getAllElasticRemoteAgents()
Set<com.atlassian.aws.ec2.EC2InstanceType>	getAllowedInstanceTypes()
List<String>	getElasticAgentLogs()
com.atlassian.bamboo.agent.elastic.server.RemoteElasticInstance	getElasticRemoteAgentByInstanceId(String instanceId)
List<com.atlassian.bamboo.agent.elastic.server.RemoteElasticInstance>	getElasticRemoteAgents()
List<com.atlassian.bamboo.agent.elastic.server.RemoteElasticInstance>	getElasticRemoteAgentsByConfiguration(com.atlassian.bamboo.agent.elastic.server.ElasticImageConfiguration elasticImageConfiguration)
List<com.atlassian.bamboo.agent.elastic.server.RemoteElasticInstance>	getElasticRemoteAgentsByConfiguration(long id)
String	getInstanceLogs(String instanceId)
List<com.atlassian.bamboo.agent.elastic.server.RemoteElasticInstance>	getInstancesWithStartingAgents()
List<com.atlassian.bamboo.agent.elastic.server.RemoteElasticInstance>	getRequestedElasticRemoteAgents()
List<com.atlassian.bamboo.agent.elastic.server.RemoteElasticInstance>	getStartingElasticInstances()
int	getTotalNumElasticRemoteAgents()
int	getTunnelPort()
boolean	isElasticSupportEnabled()
boolean	isInstanceKnown(String instanceId)
com.atlassian.bamboo.agent.elastic.server.RemoteElasticInstance	newElasticAgent(com.atlassian.bamboo.agent.elastic.server.RemoteElasticInstanceListener listener, com.atlassian.aws.AWSAccount awsAccount, com.atlassian.bamboo.buildqueue.manager.AgentManager agentManager, com.atlassian.bamboo.agent.elastic.server.ElasticImageConfiguration elasticImageConfiguration, com.atlassian.aws.ec2.InstanceLaunchConfigurationBuilder instanceLaunchConfigurationBuilder)
void	onInstanceIdentified(com.atlassian.bamboo.agent.elastic.server.RemoteElasticInstance instance)
void	onInstanceRunning(com.atlassian.bamboo.agent.elastic.server.RemoteElasticInstance instance)
void	registerElasticAgentStopped(com.atlassian.bamboo.agent.elastic.server.RemoteElasticInstance instance)
void	setTunnelTimeoutMinutes(int tunnelTimeoutMinutes)
boolean	validateAwsCredentials(com.atlassian.aws.ec2.awssdk.AwsSupportConstants.Region region, String awsAccessID, String awsSecretKey, com.atlassian.bamboo.utils.error.ErrorCollection errorCollection)
boolean	validateAwsCredentials(String awsAccessID, String awsSecretKey, com.atlassian.bamboo.utils.error.ErrorCollection errorCollection)

Methods inherited from class java.lang.Object

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

Constructor Detail

ElasticInstanceManagerImpl

public ElasticInstanceManagerImpl(com.atlassian.bamboo.agent.elastic.aws.AwsAccountBean awsAccountBean,
                          AdministrationConfigurationAccessor administrationConfigurationAccessor,
                          int startupTimeoutSeconds,
                          ScheduledExecutorService executor,
                          KeyStoreFactory keyStoreFactory,
                          SSLContextFactory sslContextFactory,
                          com.atlassian.bamboo.setup.BootstrapManager bootstrapManager,
                          com.atlassian.bamboo.logger.ErrorHandler errorHandler,
                          com.atlassian.bamboo.agent.elastic.server.SpotInstanceConfigurationAccessor spotInstanceConfigurationAccessor)

Method Detail

newElasticAgent

public com.atlassian.bamboo.agent.elastic.server.RemoteElasticInstance newElasticAgent(com.atlassian.bamboo.agent.elastic.server.RemoteElasticInstanceListener listener,
                                                                              com.atlassian.aws.AWSAccount awsAccount,
                                                                              @NotNull
                                                                              com.atlassian.bamboo.buildqueue.manager.AgentManager agentManager,
                                                                              @NotNull
                                                                              com.atlassian.bamboo.agent.elastic.server.ElasticImageConfiguration elasticImageConfiguration,
                                                                              @NotNull
                                                                              com.atlassian.aws.ec2.InstanceLaunchConfigurationBuilder instanceLaunchConfigurationBuilder)
                                                                                throws NoSuchAlgorithmException,
                                                                                       KeyManagementException,
                                                                                       IOException,
                                                                                       CertificateException,
                                                                                       UnrecoverableKeyException,
                                                                                       KeyStoreException

Specified by:

newElasticAgent in interface com.atlassian.bamboo.agent.elastic.server.ElasticInstanceManager

Throws:

NoSuchAlgorithmException

KeyManagementException

IOException

CertificateException

UnrecoverableKeyException

KeyStoreException

ensureLoginKeyPairExists

public void ensureLoginKeyPairExists(com.atlassian.aws.AWSAccount awsAccount,
                            String keyPair)
                              throws com.atlassian.aws.AWSException

Specified by:

ensureLoginKeyPairExists in interface com.atlassian.bamboo.agent.elastic.server.ElasticInstanceManager

Throws:

com.atlassian.aws.AWSException

validateAwsCredentials

public boolean validateAwsCredentials(com.atlassian.aws.ec2.awssdk.AwsSupportConstants.Region region,
                             String awsAccessID,
                             String awsSecretKey,
                             com.atlassian.bamboo.utils.error.ErrorCollection errorCollection)

Specified by:

validateAwsCredentials in interface com.atlassian.bamboo.agent.elastic.server.ElasticInstanceManager

validateAwsCredentials

public boolean validateAwsCredentials(String awsAccessID,
                             String awsSecretKey,
                             com.atlassian.bamboo.utils.error.ErrorCollection errorCollection)

Specified by:

validateAwsCredentials in interface com.atlassian.bamboo.agent.elastic.server.ElasticInstanceManager

getElasticRemoteAgents

@NotNull
public List<com.atlassian.bamboo.agent.elastic.server.RemoteElasticInstance> getElasticRemoteAgents()

Specified by:

getElasticRemoteAgents in interface com.atlassian.bamboo.agent.elastic.server.ElasticInstanceManager

getElasticRemoteAgentsByConfiguration

@NotNull
public List<com.atlassian.bamboo.agent.elastic.server.RemoteElasticInstance> getElasticRemoteAgentsByConfiguration(com.atlassian.bamboo.agent.elastic.server.ElasticImageConfiguration elasticImageConfiguration)

Specified by:

getElasticRemoteAgentsByConfiguration in interface com.atlassian.bamboo.agent.elastic.server.ElasticInstanceManager

getElasticRemoteAgentsByConfiguration

@NotNull
public List<com.atlassian.bamboo.agent.elastic.server.RemoteElasticInstance> getElasticRemoteAgentsByConfiguration(long id)

Specified by:

getElasticRemoteAgentsByConfiguration in interface com.atlassian.bamboo.agent.elastic.server.ElasticInstanceManager

getElasticRemoteAgentByInstanceId

@Nullable
public com.atlassian.bamboo.agent.elastic.server.RemoteElasticInstance getElasticRemoteAgentByInstanceId(String instanceId)

Specified by:

getElasticRemoteAgentByInstanceId in interface com.atlassian.bamboo.agent.elastic.server.ElasticInstanceManager

getRequestedElasticRemoteAgents

@NotNull
public List<com.atlassian.bamboo.agent.elastic.server.RemoteElasticInstance> getRequestedElasticRemoteAgents()

Specified by:

getRequestedElasticRemoteAgents in interface com.atlassian.bamboo.agent.elastic.server.ElasticInstanceManager

getStartingElasticInstances

@NotNull
public List<com.atlassian.bamboo.agent.elastic.server.RemoteElasticInstance> getStartingElasticInstances()

Specified by:

getStartingElasticInstances in interface com.atlassian.bamboo.agent.elastic.server.ElasticInstanceManager

getInstancesWithStartingAgents

@NotNull
public List<com.atlassian.bamboo.agent.elastic.server.RemoteElasticInstance> getInstancesWithStartingAgents()

Specified by:

getInstancesWithStartingAgents in interface com.atlassian.bamboo.agent.elastic.server.ElasticInstanceManager

getAllElasticRemoteAgents

public List<com.atlassian.bamboo.agent.elastic.server.RemoteElasticInstance> getAllElasticRemoteAgents()

Specified by:

getAllElasticRemoteAgents in interface com.atlassian.bamboo.agent.elastic.server.ElasticInstanceManager

getAllElasticAgentsAsMap

public com.google.common.collect.SetMultimap<com.atlassian.bamboo.agent.elastic.server.ElasticImageConfiguration,com.atlassian.bamboo.agent.elastic.server.RemoteElasticInstance> getAllElasticAgentsAsMap()

Specified by:

getAllElasticAgentsAsMap in interface com.atlassian.bamboo.agent.elastic.server.ElasticInstanceManager

getTotalNumElasticRemoteAgents

public int getTotalNumElasticRemoteAgents()

Specified by:

getTotalNumElasticRemoteAgents in interface com.atlassian.bamboo.agent.elastic.server.ElasticInstanceManager

onInstanceIdentified

public void onInstanceIdentified(@NotNull
                        com.atlassian.bamboo.agent.elastic.server.RemoteElasticInstance instance)

Specified by:

onInstanceIdentified in interface com.atlassian.bamboo.agent.elastic.server.ElasticInstanceManager

onInstanceRunning

public void onInstanceRunning(@NotNull
                     com.atlassian.bamboo.agent.elastic.server.RemoteElasticInstance instance)

Specified by:

onInstanceRunning in interface com.atlassian.bamboo.agent.elastic.server.ElasticInstanceManager

cancelSpotRequests

public boolean cancelSpotRequests(@NotNull
                         com.atlassian.aws.AWSAccount awsAccount)

Specified by:

cancelSpotRequests in interface com.atlassian.bamboo.agent.elastic.server.ElasticInstanceManager

registerElasticAgentStopped

public void registerElasticAgentStopped(@NotNull
                               com.atlassian.bamboo.agent.elastic.server.RemoteElasticInstance instance)

Specified by:

registerElasticAgentStopped in interface com.atlassian.bamboo.agent.elastic.server.ElasticInstanceManager

addElasticLogEntry

public void addElasticLogEntry(org.apache.log4j.Logger log,
                      String logEntry)

Specified by:

addElasticLogEntry in interface com.atlassian.bamboo.agent.elastic.server.ElasticInstanceManager

getElasticAgentLogs

public List<String> getElasticAgentLogs()

Specified by:

getElasticAgentLogs in interface com.atlassian.bamboo.agent.elastic.server.ElasticInstanceManager

isElasticSupportEnabled

public boolean isElasticSupportEnabled()

Specified by:

isElasticSupportEnabled in interface com.atlassian.bamboo.agent.elastic.server.ElasticInstanceManager

getAllowedInstanceTypes

@NotNull
public Set<com.atlassian.aws.ec2.EC2InstanceType> getAllowedInstanceTypes()

Specified by:

getAllowedInstanceTypes in interface com.atlassian.bamboo.agent.elastic.server.ElasticInstanceManager

getTunnelPort

public int getTunnelPort()

Specified by:

getTunnelPort in interface ElasticAgentTunnelPorts

getAgentSideHttpPort

public int getAgentSideHttpPort()

Specified by:

getAgentSideHttpPort in interface ElasticAgentTunnelPorts

getAgentSideJmsPort

public int getAgentSideJmsPort()

Specified by:

getAgentSideJmsPort in interface ElasticAgentTunnelPorts

setTunnelTimeoutMinutes

public void setTunnelTimeoutMinutes(int tunnelTimeoutMinutes)

getInstanceLogs

@NotNull
public String getInstanceLogs(@NotNull
                             String instanceId)
                       throws com.atlassian.aws.AWSException

Specified by:

getInstanceLogs in interface com.atlassian.bamboo.agent.elastic.server.ElasticInstanceManager

Throws:

com.atlassian.aws.AWSException

isInstanceKnown

public boolean isInstanceKnown(@NotNull
                      String instanceId)

Specified by:

isInstanceKnown in interface com.atlassian.bamboo.agent.elastic.server.ElasticInstanceManager