com.atlassian.bamboo.agent.elastic.server
Interface ElasticInstanceManager

All Superinterfaces:
ElasticAgentTunnelPorts
All Known Implementing Classes:
ElasticInstanceManagerImpl

public interface ElasticInstanceManager
extends ElasticAgentTunnelPorts


Field Summary
static String BAMBOO_CONTROL_TAG
           
static com.atlassian.aws.ec2.EC2InstanceType DEFAULT_INSTANCE_TYPE_32
           
static com.atlassian.aws.ec2.EC2InstanceType DEFAULT_INSTANCE_TYPE_64
           
static String DEFAULT_PRODUCT_FOR_LINUX_PLATFORM
           
static String DEFAULT_PRODUCT_FOR_WINDOWS_PLATFORM
           
static String ELASTIC_BAMBOO_KEY_PAIR
           
static String ELASTIC_BAMBOO_KEY_PAIR_FILE
           
static String ELASTIC_BAMBOO_SECURITY_GROUP
           
 
Method Summary
 void addElasticLogEntry(org.apache.log4j.Logger log, String logEntry)
           
 boolean cancelSpotRequests(com.atlassian.aws.AWSAccount awsAccount)
          Cancel spot instance requests.
 void ensureLoginKeyPairExists(com.atlassian.aws.AWSAccount awsAccount, String keyPair)
          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
 List<RemoteElasticInstance> getAllElasticRemoteAgents()
          Returns all elastic instances.
 Set<com.atlassian.aws.ec2.EC2InstanceType> getAllowedInstanceTypes()
           
 List<String> getElasticAgentLogs()
          Retrieve activity logs
 RemoteElasticInstance getElasticRemoteAgentByInstanceId(String instanceId)
          Retrieve elastic instance of the given ID.
 List<RemoteElasticInstance> getElasticRemoteAgents()
          Retrieve a readonly list of any currently existing EC2 instances
 List<RemoteElasticInstance> getElasticRemoteAgentsByConfiguration(ElasticImageConfiguration elasticImageConfiguration)
           
 List<RemoteElasticInstance> getElasticRemoteAgentsByConfiguration(long id)
           
 List<RemoteElasticInstance> getInstancesWithStartingAgents()
          Returns those elastic instances that have already started but their agents have not yet connected to the bamboo server.
 List<RemoteElasticInstance> getRequestedElasticRemoteAgents()
          Returns the elastic instances which have been requested but not yet identified.
 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)
 boolean isElasticSupportEnabled()
           
 RemoteElasticInstance newElasticAgent(RemoteElasticInstanceListener listener, com.atlassian.aws.AWSAccount awsAccount, AgentManager agentManager, ElasticImageConfiguration elasticImageConfiguration, com.atlassian.aws.ec2.InstanceLaunchConfigurationBuilder instanceLaunchConfigurationBuilder)
           
 void onInstanceIdentified(RemoteElasticInstance remoteElasticInstance)
          Tell the manager that the instance is up and running
 void onInstanceRunning(RemoteElasticInstance remoteElasticInstance)
          Invoked when the instance enters the 'running' state
 void registerElasticAgentStopped(RemoteElasticInstance instance)
          Remove and EC2 instance from the "currently Running map
 boolean validateAwsCredentials(com.atlassian.aws.ec2.awssdk.AwsSupportConstants.Region region, String awsAccessID, String awsSecretKey, ErrorCollection errorCollection)
          Validate a set of supplied AWS credentials.
 boolean validateAwsCredentials(String awsAccessID, String awsSecretKey, ErrorCollection errorCollection)
          Deprecated. since 5.4 use validateAwsCredentials(com.atlassian.aws.ec2.awssdk.AwsSupportConstants.Region, String, String, com.atlassian.bamboo.utils.error.ErrorCollection) instead
 
Methods inherited from interface com.atlassian.bamboo.agent.elastic.tunnel.ElasticAgentTunnelPorts
getAgentSideHttpPort, getAgentSideJmsPort, getTunnelPort
 

Field Detail

DEFAULT_INSTANCE_TYPE_32

static final com.atlassian.aws.ec2.EC2InstanceType DEFAULT_INSTANCE_TYPE_32

DEFAULT_INSTANCE_TYPE_64

static final com.atlassian.aws.ec2.EC2InstanceType DEFAULT_INSTANCE_TYPE_64

DEFAULT_PRODUCT_FOR_LINUX_PLATFORM

static final String DEFAULT_PRODUCT_FOR_LINUX_PLATFORM
See Also:
Constant Field Values

DEFAULT_PRODUCT_FOR_WINDOWS_PLATFORM

static final String DEFAULT_PRODUCT_FOR_WINDOWS_PLATFORM
See Also:
Constant Field Values

BAMBOO_CONTROL_TAG

static final String BAMBOO_CONTROL_TAG
See Also:
Constant Field Values

ELASTIC_BAMBOO_SECURITY_GROUP

static final String ELASTIC_BAMBOO_SECURITY_GROUP
See Also:
Constant Field Values

ELASTIC_BAMBOO_KEY_PAIR

static final String ELASTIC_BAMBOO_KEY_PAIR
See Also:
Constant Field Values

ELASTIC_BAMBOO_KEY_PAIR_FILE

static final String ELASTIC_BAMBOO_KEY_PAIR_FILE
See Also:
Constant Field Values
Method Detail

newElasticAgent

RemoteElasticInstance newElasticAgent(RemoteElasticInstanceListener listener,
                                      com.atlassian.aws.AWSAccount awsAccount,
                                      AgentManager agentManager,
                                      ElasticImageConfiguration elasticImageConfiguration,
                                      com.atlassian.aws.ec2.InstanceLaunchConfigurationBuilder instanceLaunchConfigurationBuilder)
                                      throws NoSuchAlgorithmException,
                                             KeyManagementException,
                                             IOException,
                                             CertificateException,
                                             UnrecoverableKeyException,
                                             KeyStoreException
Throws:
NoSuchAlgorithmException
KeyManagementException
IOException
CertificateException
UnrecoverableKeyException
KeyStoreException

ensureLoginKeyPairExists

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

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

Parameters:
awsAccount - that should contain the key pair
keyPair -
Throws:
com.atlassian.aws.AWSException - if there is a problem communicating with EC2.

validateAwsCredentials

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

Validate a set of supplied AWS credentials.

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.

validateAwsCredentials

@Deprecated
boolean validateAwsCredentials(String awsAccessID,
                                          String awsSecretKey,
                                          ErrorCollection errorCollection)
Deprecated. since 5.4 use validateAwsCredentials(com.atlassian.aws.ec2.awssdk.AwsSupportConstants.Region, String, String, com.atlassian.bamboo.utils.error.ErrorCollection) instead


getElasticRemoteAgents

@NotNull
List<RemoteElasticInstance> getElasticRemoteAgents()
Retrieve a readonly list of any currently existing EC2 instances

Returns:
List of RemoteElasticInstance

getRequestedElasticRemoteAgents

@NotNull
List<RemoteElasticInstance> getRequestedElasticRemoteAgents()
Returns the elastic instances which have been requested but not yet identified.

Returns:
List of elastic instances which have been requested but not yet started up yet..

getStartingElasticInstances

@NotNull
List<RemoteElasticInstance> getStartingElasticInstances()
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.

Returns:
List of elastic instances which have been requested and identified but not yet started up yet..

getAllElasticRemoteAgents

List<RemoteElasticInstance> getAllElasticRemoteAgents()
Returns all elastic instances. It includes requested agents as well as active agents

Returns:

getInstancesWithStartingAgents

@NotNull
List<RemoteElasticInstance> getInstancesWithStartingAgents()
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 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 getElasticRemoteAgents().

Returns:
List of RemoteElasticInstance

getAllElasticAgentsAsMap

com.google.common.collect.SetMultimap<ElasticImageConfiguration,RemoteElasticInstance> getAllElasticAgentsAsMap()
Returns all elastic instances in a SetMultimap, keyed by the ElasticImageConfiguration

Returns:

getTotalNumElasticRemoteAgents

int getTotalNumElasticRemoteAgents()
Return how many license spots are currently being occupied by elastic instances (pending and running)

Returns:
Number of license slots currently occupied by elastic instances (pending and running).

getElasticRemoteAgentByInstanceId

@Nullable
RemoteElasticInstance getElasticRemoteAgentByInstanceId(String instanceId)
Retrieve elastic instance of the given ID.

Parameters:
instanceId - of the instance
Returns:
the elastic remote agent specific to the provided instance id

registerElasticAgentStopped

void registerElasticAgentStopped(@NotNull
                                 RemoteElasticInstance instance)
Remove and EC2 instance from the "currently Running map

Parameters:
instance - - the one to be deleted from the map

onInstanceIdentified

void onInstanceIdentified(@NotNull
                          RemoteElasticInstance remoteElasticInstance)
Tell the manager that the instance is up and running

Parameters:
remoteElasticInstance - the instance identified

onInstanceRunning

void onInstanceRunning(@NotNull
                       RemoteElasticInstance remoteElasticInstance)
Invoked when the instance enters the 'running' state

Parameters:
remoteElasticInstance - the instance that entered running state

addElasticLogEntry

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

getElasticAgentLogs

List<String> getElasticAgentLogs()
Retrieve activity logs

Returns:
a copy of the current elastic agent logs

isElasticSupportEnabled

boolean isElasticSupportEnabled()
Returns:
true, if elastic support is turned on

getAllowedInstanceTypes

@NotNull
Set<com.atlassian.aws.ec2.EC2InstanceType> getAllowedInstanceTypes()
Returns:
Set of allowed instance types.

getElasticRemoteAgentsByConfiguration

@NotNull
List<RemoteElasticInstance> getElasticRemoteAgentsByConfiguration(ElasticImageConfiguration elasticImageConfiguration)

getElasticRemoteAgentsByConfiguration

@NotNull
List<RemoteElasticInstance> getElasticRemoteAgentsByConfiguration(long id)

cancelSpotRequests

boolean cancelSpotRequests(com.atlassian.aws.AWSAccount awsAccount)
Cancel spot instance requests.

Parameters:
awsAccount - account
Returns:
true if at least one request was found and cancelled


Copyright © 2015 Atlassian Software Systems Pty Ltd. All rights reserved.