Package com.atlassian.bamboo.agent.elastic.server

Class ElasticFunctionalityFacadeImpl

java.lang.Object

com.atlassian.bamboo.agent.elastic.server.ElasticFunctionalityFacadeImpl

All Implemented Interfaces:

ElasticFunctionalityFacade

public class ElasticFunctionalityFacadeImpl
extends Object
implements ElasticFunctionalityFacade

Nested Class Summary

Nested classes/interfaces inherited from interface com.atlassian.bamboo.agent.elastic.server.ElasticFunctionalityFacade

ElasticFunctionalityFacade.Ec2PrivateKeyValidationStatus

Field Summary

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

DEFAULT_ALLOWED_AGENTS

Constructor Summary

Constructors

Constructor	Description
ElasticFunctionalityFacadeImpl()

Method Summary

Modifier and Type	Method	Description
void	addElasticLogEntry(org.apache.log4j.Logger log, String logEntry)
void	addElasticLogEntry(org.apache.logging.log4j.Logger log, String logEntry)
void	adjustElasticInstanceNumbers(@NotNull ElasticInstanceSchedule instanceSchedule)	Given the ElasticInstanceSchedule startup or bring down the correct number of agents
protected void	attemptShutdownInstances(Collection<RemoteElasticInstance> instances, int agentsToShutdown, ElasticImageConfiguration elasticImageConfiguration)
void	cleanupCredentials()	Cleanup EC2 credentials and disable EC2 support
@NotNull String	getKeyPairName()
int	getMaxConcurrentInstances()
@NotNull io.atlassian.fugue.Either<ElasticFunctionalityFacade.Ec2PrivateKeyValidationStatus,Optional<String>>	getPassword(RemoteElasticInstance instance)
@NotNull String	getPkFileLocation()
@NotNull io.atlassian.fugue.Either<ElasticFunctionalityFacade.Ec2PrivateKeyValidationStatus,File>	getPrivateKeyLocation()	Returns the location of the AWS private key
boolean	isElasticSupportEnabled()
boolean	isElasticSupportPossible(@NotNull ErrorCollection errorCollection)
void	persistTunnelDataOfInstance(@NotNull ElasticAgentDefinition pipelineDefinition)	Persist data related to tunnel configuration of an elastic instance.
void	postConstruct()
void	recheckElasticSupportEnabledFlag()
void	restoreAgent(@NotNull ElasticAgentDefinition elasticAgentDefinition, @NotNull com.amazonaws.services.ec2.model.Instance instance, @NotNull com.atlassian.aws.AWSAccount awsAccount)
void	setElasticSupportEnabled(boolean elasticSupportEnabled)	Enable/disable Elastic Bamboo functionality
void	shutdownAllInstances()
void	shutdownInstance(@NotNull RemoteElasticInstance elasticInstance)
void	shutdownInstance(String instanceId)
void	startupAgents(@NotNull Collection<ElasticImageConfiguration> elasticImageConfigurations)	Starts the given number of agents
void	updateAgentPendingStatus(@NotNull String instanceId)	Set the agent pending status to true for the given instance id
boolean	validateAgentCreation(int numAgentsRequired, ErrorCollection errorCollection)	Validates whether the requested number of agents can be created and adds any errors to the error collection.

Methods inherited from class java.lang.Object

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

Constructor Detail

ElasticFunctionalityFacadeImpl

public ElasticFunctionalityFacadeImpl()

Method Detail

postConstruct

@PostConstruct
public void postConstruct()

recheckElasticSupportEnabledFlag

public void recheckElasticSupportEnabledFlag()

Specified by:

recheckElasticSupportEnabledFlag in interface ElasticFunctionalityFacade

shutdownInstance

public void shutdownInstance(@NotNull
                             @NotNull RemoteElasticInstance elasticInstance)

Specified by:

shutdownInstance in interface ElasticFunctionalityFacade

shutdownInstance

public void shutdownInstance(String instanceId)
                      throws com.atlassian.aws.AWSException

Specified by:

shutdownInstance in interface ElasticFunctionalityFacade

Throws:

com.atlassian.aws.AWSException

shutdownAllInstances

public void shutdownAllInstances()

Specified by:

shutdownAllInstances in interface ElasticFunctionalityFacade

startupAgents

@Transactional
public void startupAgents(@NotNull
                          @NotNull Collection<ElasticImageConfiguration> elasticImageConfigurations)
                   throws com.atlassian.aws.AWSException

Starts the given number of agents

Specified by:

startupAgents in interface ElasticFunctionalityFacade

Throws:

com.atlassian.aws.AWSException

restoreAgent

public void restoreAgent(@NotNull
                         @NotNull ElasticAgentDefinition elasticAgentDefinition,
                         @NotNull
                         @NotNull com.amazonaws.services.ec2.model.Instance instance,
                         @NotNull
                         @NotNull com.atlassian.aws.AWSAccount awsAccount)

Specified by:

restoreAgent in interface ElasticFunctionalityFacade

persistTunnelDataOfInstance

@Nullable
public void persistTunnelDataOfInstance(@NotNull
                                        @NotNull ElasticAgentDefinition pipelineDefinition)

Description copied from interface: ElasticFunctionalityFacade

Persist data related to tunnel configuration of an elastic instance.

Specified by:

persistTunnelDataOfInstance in interface ElasticFunctionalityFacade

isElasticSupportEnabled

public boolean isElasticSupportEnabled()

Specified by:

isElasticSupportEnabled in interface ElasticFunctionalityFacade

Returns:

true, if elastic support is turned on

isElasticSupportPossible

public boolean isElasticSupportPossible(@NotNull
                                        @NotNull ErrorCollection errorCollection)

Specified by:

isElasticSupportPossible in interface ElasticFunctionalityFacade

Returns:

true, if all preconditions for turning elastic support on are met

setElasticSupportEnabled

public void setElasticSupportEnabled(boolean elasticSupportEnabled)

Description copied from interface: ElasticFunctionalityFacade

Enable/disable Elastic Bamboo functionality

Specified by:

setElasticSupportEnabled in interface ElasticFunctionalityFacade

Parameters:

elasticSupportEnabled - Specifies if Elastc Baboo shall be enabled or disabled.

validateAgentCreation

public boolean validateAgentCreation(int numAgentsRequired,
                                     ErrorCollection errorCollection)

Description copied from interface: ElasticFunctionalityFacade

Validates whether the requested number of agents can be created and adds any errors to the error collection.

Specified by:

validateAgentCreation in interface ElasticFunctionalityFacade

Parameters:

numAgentsRequired - - number of agents to be created

errorCollection - - error collection to add any validation errors to.

updateAgentPendingStatus

public void updateAgentPendingStatus(@NotNull
                                     @NotNull String instanceId)

Description copied from interface: ElasticFunctionalityFacade

Set the agent pending status to true for the given instance id

Specified by:

updateAgentPendingStatus in interface ElasticFunctionalityFacade

addElasticLogEntry

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

Specified by:

addElasticLogEntry in interface ElasticFunctionalityFacade

addElasticLogEntry

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

Specified by:

addElasticLogEntry in interface ElasticFunctionalityFacade

adjustElasticInstanceNumbers

@Transactional
public void adjustElasticInstanceNumbers(@NotNull
                                         @NotNull ElasticInstanceSchedule instanceSchedule)
                                  throws com.atlassian.aws.AWSException

Description copied from interface: ElasticFunctionalityFacade

Given the ElasticInstanceSchedule startup or bring down the correct number of agents

Specified by:

adjustElasticInstanceNumbers in interface ElasticFunctionalityFacade

Throws:

com.atlassian.aws.AWSException

attemptShutdownInstances

protected void attemptShutdownInstances(Collection<RemoteElasticInstance> instances,
                                        int agentsToShutdown,
                                        ElasticImageConfiguration elasticImageConfiguration)

getMaxConcurrentInstances

public int getMaxConcurrentInstances()

Specified by:

getMaxConcurrentInstances in interface ElasticFunctionalityFacade

Returns:

max number of elastic instances allowed for this instance. It's based on license restrictions.

getPkFileLocation

@NotNull
public @NotNull String getPkFileLocation()

Specified by:

getPkFileLocation in interface ElasticFunctionalityFacade

getPrivateKeyLocation

@NotNull
public @NotNull io.atlassian.fugue.Either<ElasticFunctionalityFacade.Ec2PrivateKeyValidationStatus,File> getPrivateKeyLocation()

Description copied from interface: ElasticFunctionalityFacade

Returns the location of the AWS private key

Specified by:

getPrivateKeyLocation in interface ElasticFunctionalityFacade

Returns:

getPassword

@NotNull
public @NotNull io.atlassian.fugue.Either<ElasticFunctionalityFacade.Ec2PrivateKeyValidationStatus,Optional<String>> getPassword(RemoteElasticInstance instance)

Specified by:

getPassword in interface ElasticFunctionalityFacade

getKeyPairName

@NotNull
public @NotNull String getKeyPairName()

Specified by:

getKeyPairName in interface ElasticFunctionalityFacade

cleanupCredentials

public void cleanupCredentials()

Description copied from interface: ElasticFunctionalityFacade

Cleanup EC2 credentials and disable EC2 support

Specified by:

cleanupCredentials in interface ElasticFunctionalityFacade