Package com.atlassian.bamboo.buildqueue.manager

Class AgentManagerImpl

java.lang.Object

com.atlassian.bamboo.buildqueue.manager.AgentManagerImpl

All Implemented Interfaces:

AgentManager, LocalAgentManager

public class AgentManagerImpl
extends Object
implements AgentManager, LocalAgentManager

Field Summary

Fields inherited from interface com.atlassian.bamboo.buildqueue.manager.AgentManager

DEFAULT_AGENT_NAME

Constructor Summary

Constructors

Constructor

Description

AgentManagerImpl(AgentDao agentDao, CapabilitySetManager capabilitySetManager, CapabilityManager capabilityManager, com.atlassian.event.api.EventPublisher eventPublisher, BambooLicenseManager bambooLicenseManager, ElasticInstanceManager elasticInstanceManager, ErrorUpdateHandler errorUpdateHandler, BuildLoggerManager buildLoggerManager, FeatureManager featureManager, DeploymentsInProgressService deploymentsInProgressService, ElasticTunnelDefinitionDao elasticTunnelDefinitionDao, EphemeralAgentsService ephemeralAgentsService, EphemeralAgentExecutionService ephemeralAgentExecutionService, EphemeralAgentManagementLogger ephemeralAgentManagementLogger)

Method Summary

Modifier and Type	Method	Description
void	abandonBuild(@NotNull BuildAgent remoteAgent, boolean agentStartingUp)
boolean	allowNewElasticAgent()	Allow an elastic agent to register and come online?
boolean	allowNewElasticAgents(int numOfAgentsToCreate)	Allow a specified number of elastic agents to register and come online?
boolean	allowNewElasticAgentWithId(long id)	Allow an elastic agent with specific id to register and come online?
boolean	allowNewEphemeralAgent()	Allow an ephemeral agent to register and come online?
boolean	allowNewEphemeralAgentWithId(long id)	Allow an ephemeral agent with specific id to register and come online?
boolean	allowNewLocalAgent()	Allow a local agent to come online?
boolean	allowNewRemoteAgent()	Allow a remote agent to register and come online?
boolean	allowNewRemoteAgents(int numOfAgentsToCreate)	Allow a specified number of remote agents to register and come online?
boolean	allowNewRemoteAgentWithId(long id)	Allow a remote agent with specific id to register and come online?
boolean	checkPipelinesAreDisabled()
void	createDefaultAgent()	sets up a default local agent if no local agent exists
void	createLocalAgent(LocalAgentDefinition definition)	Create a new local agent.
void	disableAllAgents()	Disable all pipelines
void	enableAllAgents()	Enable all pipelines
Map<Long,PipelineDefinition>	findAllAgentsForAgentIds(@NotNull Collection<Long> agentIds)	Returns a Map of PipelineDefinitions keyed by their id
@NotNull Collection<BuildAgent>	getActiveAndEnabledAgents()	Returns agents that are enabled and online
@Nullable BuildAgent	getAgent(long agentId)
long	getAgentCount(Class<? extends PipelineDefinition> agentDefinitionClass)	Retrieves the amount of agents of given type stored in the database
@Nullable PipelineDefinition	getAgentDefinition(@NotNull Long agentId)
@Nullable PipelineDefinition	getAgentDefinitionByName(@NotNull String name)	Retrieve a PipelineDefinition by name.
@NotNull List<PipelineDefinition>	getAgentDefinitionsByName(@NotNull String name)	Retrieve PipelineDefinitions by name.
@NotNull List<PipelineDefinition>	getAgentDefinitionsWithNameLike(@NotNull String likeName)	Return a list of agents whose name is like the provided string.
@NotNull List<BuildAgent>	getAllAgents()
@NotNull List<ElasticAgentDefinition>	getAllElasticAgentDefinitions(int firstResult, int maxResults)	Retrieve most recently terminated elastic agent definitions from db, ordered by termination time, descending.
@NotNull List<ElasticAgentDefinition>	getAllElasticAgentDefinitions(@NotNull Collection<String> instanceIds)	Retrieve elastic agent definitions from db.
@NotNull List<LocalBuildAgent>	getAllLocalAgents()	Returns all LocalBuildAgent objects
@NotNull List<BuildAgent>	getAllNonElasticAgents()
List<PipelineDefinition>	getAllPersistedAgentDefinitions()	Retrieves a list of all agent definitions stored in the database.
@NotNull List<BuildAgent>	getAllRemoteAgents()	Gets all remote agents in the system.
@NotNull List<BuildAgent>	getAllRemoteAgents(boolean onlineOnly)	Get remote agents.
int	getAllRemoteAgentsCount(boolean onlineOnly)	Get remote agents count.
@NotNull List<BuildAgent>	getAllStandardAgents()
@NotNull Collection<BuildAgent>	getBusyBuildAgents()	Gets a collection agents that are currently building or cancelling a build
@NotNull Collection<BuildAgent>	getElasticActiveAndEnabledAgents()	Returns elastic agents that are enabled and online
@NotNull Optional<BuildAgent>	getEphemeralAgentByPodName(@NotNull String podName)	Returns a BuildAgent by given pod name (if exists).
@NotNull List<EphemeralAgentPod>	getEphemeralAgentPods()	Returns a list of ephemeral agents related pods in any phase present in the connected cluster at the moment of request.
@NotNull List<EphemeralAgentPod>	getEventuallyConsistentEphemeralAgentPods()	Returns a list of ephemeral agents related pods in any phase present in the connected cluster.
@NotNull Collection<LocalBuildAgent>	getLocalActiveAndEnabledAgents()	Returns local agents that are enabled and online
LocalBuildAgent	getLocalAgent(long pipelineId)	Returns the pipeline that matches the passed id
long	getOfflineAgentCount(Class<? extends PipelineDefinition> agentDefinitionClass)	Retrieves the amount of offline agents of given type stored in the database
@NotNull List<ElasticAgentDefinition>	getOfflineElasticAgentDefinitions(int firstResult, int maxResults)	Retrieve offline elastic agents.
@NotNull List<Long>	getOfflineElasticAgentIds()	Retrieves a list of offline elastic agents IDs.
@NotNull List<Long>	getOfflineEphemeralAgentIds()	Retrieves a list of offline ephemeral agents IDs.
@NotNull List<Long>	getOfflineRemoteAgentIds()	Retrieves a list of offline remote agent IDs.
@NotNull List<BuildAgent>	getOnlineElasticAgents()	Retrieve all online elastic build agents.
int	getOnlineEphemeralAgentCount()	Retrieves the total count of online ephemeral agents currently present in the system.
int	getPendingEphemeralAgentsEstimatedCount()	Get estimated number of pending ephemeral agents.
@NotNull Collection<BuildAgent>	getRemoteActiveAndEnabledAgents()	Returns remote agents that are enabled and online
void	initAgents()	Inits the local agents Must be ran before any other methods.
void	onAgentReturning(@NotNull BuildAgent agent)	Performs any other operations required when an agent goes offline, such as updating the status and shutdown time.
void	removeAgent(long agentId)	Removes the passed agent (any type)
void	removeEphemeralAgent(long agentId)	Removes the agent if the ephemeral one with requested ID is found.
void	removeRemoteAgent(long agentId)	Removes a remote agent
void	saveAnyPipeline(@NotNull PipelineDefinition pipelineDefinition)	Stores a pipeline PipelineDefinition of any type (elastic, local, remote) AgentConfigurationUpdateEvent is fired after the pipeline is saved
void	saveAnyPipeline(@NotNull PipelineDefinition pipelineDefinition, @Nullable AgentConfigurationUpdatedEventFactory eventFactory)	Stores a pipeline PipelineDefinition of any type (elastic, local, remote)
void	saveElasticPipeline(@NotNull ElasticAgentDefinition elasticDefinition)	Stores the elastic PipelineDefinition
void	saveEphemeralPipeline(@NotNull EphemeralAgentDefinition pipelineDefinition)	Stores the ephemeral PipelineDefinition
void	savePipeline(@NotNull PipelineDefinition pipelineDefinition)	Stores the PipelineDefinition.
void	savePipeline(@NotNull PipelineDefinition pipelineDefinition, @Nullable AgentConfigurationUpdatedEventFactory eventFactory)	Stores the PipelineDefinition.
void	saveReturningElasticPipeline(@NotNull ElasticAgentDefinition elasticDefinition)	Stores the elastic PipelineDefinition of a returning elastic agent.
Optional<BuildAgent>	setAgentEnabled(long agentId, boolean enable)
void	startLocalAgents()	Starts all current LocalBuildAgent objects
void	stopAgent(@NotNull BuildAgent agent)	Performs any other operations required when an agent goes offline, such as updating the status and shutdown time.
void	stopEphemeralAgentByPodName(@NotNull String podName)	Stops the ephemeral agent with requested pod name.
void	stopLocalAgents()	Stops all LocalBuildAgent
boolean	updateAgentStatusIfResultReturnPossibleAfterServerRestart(long agentId, ResultKey resultKey, String displayName, long deploymentResultId)	Checks if agent is capable of 'surviving' a server restart, i.e. if agent exists and is configured to reconnect after server restart, allowing it to return build result produced while the server was down.

Methods inherited from class java.lang.Object

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

Constructor Details

AgentManagerImpl

public AgentManagerImpl(AgentDao agentDao,
 CapabilitySetManager capabilitySetManager,
 CapabilityManager capabilityManager,
 com.atlassian.event.api.EventPublisher eventPublisher,
 BambooLicenseManager bambooLicenseManager,
 ElasticInstanceManager elasticInstanceManager,
 ErrorUpdateHandler errorUpdateHandler,
 BuildLoggerManager buildLoggerManager,
 FeatureManager featureManager,
 DeploymentsInProgressService deploymentsInProgressService,
 ElasticTunnelDefinitionDao elasticTunnelDefinitionDao,
 EphemeralAgentsService ephemeralAgentsService,
 EphemeralAgentExecutionService ephemeralAgentExecutionService,
 EphemeralAgentManagementLogger ephemeralAgentManagementLogger)

Method Details

createDefaultAgent

public void createDefaultAgent()

Description copied from interface: AgentManager

sets up a default local agent if no local agent exists

Specified by:

createDefaultAgent in interface AgentManager

initAgents

public void initAgents()

Description copied from interface: AgentManager

Inits the local agents Must be ran before any other methods.

Specified by:

initAgents in interface AgentManager

startLocalAgents

public void startLocalAgents()

Description copied from interface: AgentManager

Starts all current LocalBuildAgent objects

Specified by:

startLocalAgents in interface AgentManager

stopLocalAgents

public void stopLocalAgents()

Description copied from interface: AgentManager

Stops all LocalBuildAgent

Specified by:

stopLocalAgents in interface AgentManager

getAllLocalAgents

@NotNull
public @NotNull List<LocalBuildAgent> getAllLocalAgents()

Description copied from interface: AgentManager

Returns all LocalBuildAgent objects

Specified by:

getAllLocalAgents in interface AgentManager

Returns:

A copied collection of LocalBuildAgent objects, or an empty collection if none exists.

getOnlineElasticAgents

@NotNull
public @NotNull List<BuildAgent> getOnlineElasticAgents()

Description copied from interface: AgentManager

Retrieve all online elastic build agents.

Specified by:

getOnlineElasticAgents in interface AgentManager

Returns:

getAllElasticAgentDefinitions

@NotNull
public @NotNull List<ElasticAgentDefinition> getAllElasticAgentDefinitions(int firstResult,
 int maxResults)

Description copied from interface: AgentManager

Retrieve most recently terminated elastic agent definitions from db, ordered by termination time, descending.

Specified by:

getAllElasticAgentDefinitions in interface AgentManager

Returns:

list of ElasticAgents

getOfflineElasticAgentDefinitions

@NotNull
public @NotNull List<ElasticAgentDefinition> getOfflineElasticAgentDefinitions(int firstResult,
 int maxResults)

Description copied from interface: AgentManager

Retrieve offline elastic agents.

Specified by:

getOfflineElasticAgentDefinitions in interface AgentManager

Returns:

list of ElasticAgents

getAgentCount

public long getAgentCount(Class<? extends PipelineDefinition> agentDefinitionClass)

Description copied from interface: AgentManager

Retrieves the amount of agents of given type stored in the database

Specified by:

getAgentCount in interface AgentManager

Parameters:

agentDefinitionClass - agent type

Returns:

amount of agents

getOfflineAgentCount

public long getOfflineAgentCount(Class<? extends PipelineDefinition> agentDefinitionClass)

Description copied from interface: AgentManager

Retrieves the amount of offline agents of given type stored in the database

Specified by:

getOfflineAgentCount in interface AgentManager

Parameters:

agentDefinitionClass - agent type

Returns:

amount of agents

getAllElasticAgentDefinitions

@NotNull
public @NotNull List<ElasticAgentDefinition> getAllElasticAgentDefinitions(@NotNull
 @NotNull Collection<String> instanceIds)

Description copied from interface: AgentManager

Retrieve elastic agent definitions from db.

Specified by:

getAllElasticAgentDefinitions in interface AgentManager

Parameters:

instanceIds - the instances ids on which the agents were running

Returns:

list of ElasticAgents

getAllRemoteAgents

@NotNull
public @NotNull List<BuildAgent> getAllRemoteAgents(boolean onlineOnly)

Description copied from interface: AgentManager

Get remote agents.

Specified by:

getAllRemoteAgents in interface AgentManager

Parameters:

onlineOnly - - only return those agents which are online currently.

Returns:

list of agents

getAllRemoteAgentsCount

public int getAllRemoteAgentsCount(boolean onlineOnly)

Description copied from interface: AgentManager

Get remote agents count.

Specified by:

getAllRemoteAgentsCount in interface AgentManager

Parameters:

onlineOnly - - only return those agents which are online currently.

getAllRemoteAgents

@NotNull
public @NotNull List<BuildAgent> getAllRemoteAgents()

Description copied from interface: AgentManager

Gets all remote agents in the system. They can be offline.

Specified by:

getAllRemoteAgents in interface AgentManager

Returns:

all remote agents.

getAllAgents

@NotNull
public @NotNull List<BuildAgent> getAllAgents()

Specified by:

getAllAgents in interface AgentManager

getAllNonElasticAgents

@NotNull
public @NotNull List<BuildAgent> getAllNonElasticAgents()

Specified by:

getAllNonElasticAgents in interface AgentManager

getAllStandardAgents

@NotNull
public @NotNull List<BuildAgent> getAllStandardAgents()

Specified by:

getAllStandardAgents in interface AgentManager

Returns:

all standard agents, i.e. not ephemeral and not elastic

getBusyBuildAgents

@NotNull
public @NotNull Collection<BuildAgent> getBusyBuildAgents()

Description copied from interface: AgentManager

Gets a collection agents that are currently building or cancelling a build

Specified by:

getBusyBuildAgents in interface AgentManager

Returns:

Collection of BuildAgent

getActiveAndEnabledAgents

@NotNull
public @NotNull Collection<BuildAgent> getActiveAndEnabledAgents()

Description copied from interface: AgentManager

Returns agents that are enabled and online

Specified by:

getActiveAndEnabledAgents in interface AgentManager

Returns:

Collection of BuildAgent

getRemoteActiveAndEnabledAgents

@NotNull
public @NotNull Collection<BuildAgent> getRemoteActiveAndEnabledAgents()

Description copied from interface: AgentManager

Returns remote agents that are enabled and online

Specified by:

getRemoteActiveAndEnabledAgents in interface AgentManager

Returns:

Collection of BuildAgent

getElasticActiveAndEnabledAgents

@NotNull
public @NotNull Collection<BuildAgent> getElasticActiveAndEnabledAgents()

Description copied from interface: AgentManager

Returns elastic agents that are enabled and online

Specified by:

getElasticActiveAndEnabledAgents in interface AgentManager

Returns:

Collection of BuildAgent

getLocalActiveAndEnabledAgents

@NotNull
public @NotNull Collection<LocalBuildAgent> getLocalActiveAndEnabledAgents()

Description copied from interface: AgentManager

Returns local agents that are enabled and online

Specified by:

getLocalActiveAndEnabledAgents in interface AgentManager

Returns:

Collection of LocalBuildAgent

createLocalAgent

public void createLocalAgent(LocalAgentDefinition definition)
                      throws BambooLicenseException

Description copied from interface: AgentManager

Create a new local agent.

Specified by:

createLocalAgent in interface AgentManager

Parameters:

definition -

Throws:

BambooLicenseException

savePipeline

public void savePipeline(@NotNull
 @NotNull PipelineDefinition pipelineDefinition)

Description copied from interface: AgentManager

Stores the PipelineDefinition. Updates any caches so calls to AgentManager.getLocalAgent(long) will return the LocalBuildAgent returns with the new definition

Specified by:

savePipeline in interface AgentManager

Parameters:

pipelineDefinition - - Must not be null

savePipeline

public void savePipeline(@NotNull
 @NotNull PipelineDefinition pipelineDefinition,
 @Nullable
 @Nullable AgentConfigurationUpdatedEventFactory eventFactory)

Description copied from interface: AgentManager

Stores the PipelineDefinition. Updates any caches so calls to AgentManager.getLocalAgent(long) will return the LocalBuildAgent returns with the new definition

Specified by:

savePipeline in interface AgentManager

Parameters:

pipelineDefinition - - Must not be null

eventFactory - event factory used to create event sent after the pipeline is saved

saveElasticPipeline

public void saveElasticPipeline(@NotNull
 @NotNull ElasticAgentDefinition elasticDefinition)

Description copied from interface: AgentManager

Stores the elastic PipelineDefinition

Specified by:

saveElasticPipeline in interface AgentManager

Parameters:

elasticDefinition - - Must not be null

saveEphemeralPipeline

public void saveEphemeralPipeline(@NotNull
 @NotNull EphemeralAgentDefinition pipelineDefinition)

Description copied from interface: AgentManager

Stores the ephemeral PipelineDefinition

Specified by:

saveEphemeralPipeline in interface AgentManager

Parameters:

pipelineDefinition - - Must not be null

saveReturningElasticPipeline

public void saveReturningElasticPipeline(@NotNull
 @NotNull ElasticAgentDefinition elasticDefinition)

Description copied from interface: AgentManager

Stores the elastic PipelineDefinition of a returning elastic agent.

Specified by:

saveReturningElasticPipeline in interface AgentManager

Parameters:

elasticDefinition - returning elastic agent definition

getAllPersistedAgentDefinitions

public List<PipelineDefinition> getAllPersistedAgentDefinitions()

Description copied from interface: AgentManager

Retrieves a list of all agent definitions stored in the database.

Specified by:

getAllPersistedAgentDefinitions in interface AgentManager

abandonBuild

public void abandonBuild(@NotNull
 @NotNull BuildAgent remoteAgent,
 boolean agentStartingUp)

Specified by:

abandonBuild in interface AgentManager

onAgentReturning

public void onAgentReturning(@NotNull
 @NotNull BuildAgent agent)

Description copied from interface: AgentManager

Performs any other operations required when an agent goes offline, such as updating the status and shutdown time. Called when agent re-registered without being marked as offline.

Specified by:

onAgentReturning in interface AgentManager

Parameters:

agent - to be stopped

stopAgent

public void stopAgent(@NotNull
 @NotNull BuildAgent agent)

Description copied from interface: AgentManager

Performs any other operations required when an agent goes offline, such as updating the status and shutdown time.

Specified by:

stopAgent in interface AgentManager

Parameters:

agent - to be stopped

getLocalAgent

public LocalBuildAgent getLocalAgent(long pipelineId)

Description copied from interface: AgentManager

Returns the pipeline that matches the passed id

Specified by:

getLocalAgent in interface AgentManager

Parameters:

pipelineId -

Returns:

Matching LocalBuildAgent object. Null if pipeline does not exist

getAgent

@Nullable
public @Nullable BuildAgent getAgent(long agentId)

Specified by:

getAgent in interface AgentManager

getAgentDefinition

@Nullable
public @Nullable PipelineDefinition getAgentDefinition(@NotNull
 @NotNull Long agentId)

Specified by:

getAgentDefinition in interface AgentManager

getEphemeralAgentPods

@NotNull
public @NotNull List<EphemeralAgentPod> getEphemeralAgentPods()

Description copied from interface: AgentManager

Returns a list of ephemeral agents related pods in any phase present in the connected cluster at the moment of request.

Specified by:

getEphemeralAgentPods in interface AgentManager

Returns:

a List of EphemeralAgentPod

getEventuallyConsistentEphemeralAgentPods

@NotNull
public @NotNull List<EphemeralAgentPod> getEventuallyConsistentEphemeralAgentPods()

Description copied from interface: AgentManager

Returns a list of ephemeral agents related pods in any phase present in the connected cluster. The results may be stale. The desired order of magnitude of delay is seconds.

Specified by:

getEventuallyConsistentEphemeralAgentPods in interface AgentManager

Returns:

a List of EphemeralAgentPod

getPendingEphemeralAgentsEstimatedCount

public int getPendingEphemeralAgentsEstimatedCount()

Description copied from interface: AgentManager

Get estimated number of pending ephemeral agents.

Specified by:

getPendingEphemeralAgentsEstimatedCount in interface AgentManager

getEphemeralAgentByPodName

@NotNull
public @NotNull Optional<BuildAgent> getEphemeralAgentByPodName(@NotNull
 @NotNull String podName)

Description copied from interface: AgentManager

Returns a BuildAgent by given pod name (if exists).

Specified by:

getEphemeralAgentByPodName in interface AgentManager

stopEphemeralAgentByPodName

public void stopEphemeralAgentByPodName(@NotNull
 @NotNull String podName)

Description copied from interface: AgentManager

Stops the ephemeral agent with requested pod name.

Specified by:

stopEphemeralAgentByPodName in interface AgentManager

Parameters:

podName - name of the pod the ephemeral agent is running on

findAllAgentsForAgentIds

public Map<Long,PipelineDefinition> findAllAgentsForAgentIds(@NotNull
 @NotNull Collection<Long> agentIds)

Description copied from interface: AgentManager

Returns a Map of PipelineDefinitions keyed by their id

Specified by:

findAllAgentsForAgentIds in interface AgentManager

Parameters:

agentIds -

Returns:

agentMap

getAgentDefinitionByName

@Nullable
public @Nullable PipelineDefinition getAgentDefinitionByName(@NotNull
 @NotNull String name)

Description copied from interface: AgentManager

Retrieve a PipelineDefinition by name. Names should be unique.

Specified by:

getAgentDefinitionByName in interface AgentManager

Parameters:

name - of the agent to find

Returns:

the agent that has the given name.

getAgentDefinitionsByName

@NotNull
public @NotNull List<PipelineDefinition> getAgentDefinitionsByName(@NotNull
 @NotNull String name)

Description copied from interface: AgentManager

Retrieve PipelineDefinitions by name. Names should be unique. However, duplicates are possible due to not properly handled unsuccessful registration attempts.

Specified by:

getAgentDefinitionsByName in interface AgentManager

Parameters:

name - of the agent to find

Returns:

the agent that has the given name.

getAgentDefinitionsWithNameLike

@NotNull
public @NotNull List<PipelineDefinition> getAgentDefinitionsWithNameLike(@NotNull
 @NotNull String likeName)

Description copied from interface: AgentManager

Return a list of agents whose name is like the provided string. Uses hibernate's "like" so % to mark wild card.

Specified by:

getAgentDefinitionsWithNameLike in interface AgentManager

Parameters:

likeName - the string to match

Returns:

List of Pipeline Definitions

saveAnyPipeline

public void saveAnyPipeline(@NotNull
 @NotNull PipelineDefinition pipelineDefinition)

Description copied from interface: AgentManager

Stores a pipeline PipelineDefinition of any type (elastic, local, remote) AgentConfigurationUpdateEvent is fired after the pipeline is saved

Specified by:

saveAnyPipeline in interface AgentManager

Parameters:

pipelineDefinition - - Must not be null

saveAnyPipeline

public void saveAnyPipeline(@NotNull
 @NotNull PipelineDefinition pipelineDefinition,
 @Nullable
 @Nullable AgentConfigurationUpdatedEventFactory eventFactory)

Description copied from interface: AgentManager

Stores a pipeline PipelineDefinition of any type (elastic, local, remote)

Specified by:

saveAnyPipeline in interface AgentManager

Parameters:

pipelineDefinition - Must not be null

eventFactory - event factory used to create event sent after the pipeline is saved

disableAllAgents

public void disableAllAgents()

Description copied from interface: AgentManager

Disable all pipelines

Specified by:

disableAllAgents in interface AgentManager

enableAllAgents

public void enableAllAgents()

Description copied from interface: AgentManager

Enable all pipelines

Specified by:

enableAllAgents in interface AgentManager

checkPipelinesAreDisabled

public boolean checkPipelinesAreDisabled()

Specified by:

checkPipelinesAreDisabled in interface AgentManager

Returns:

whether or not all pipelines are disabled

removeAgent

public void removeAgent(long agentId)
                 throws TimeoutException

Description copied from interface: AgentManager

Removes the passed agent (any type)

Specified by:

removeAgent in interface AgentManager

Parameters:

agentId -

Throws:

TimeoutException

removeRemoteAgent

public void removeRemoteAgent(long agentId)

Description copied from interface: AgentManager

Removes a remote agent

Specified by:

removeRemoteAgent in interface AgentManager

removeEphemeralAgent

public void removeEphemeralAgent(long agentId)

Description copied from interface: AgentManager

Removes the agent if the ephemeral one with requested ID is found. If the agent is not ephemeral - nothing happens.

Specified by:

removeEphemeralAgent in interface AgentManager

Parameters:

agentId - agent unique identifier

allowNewRemoteAgent

public boolean allowNewRemoteAgent()

Description copied from interface: AgentManager

Allow a remote agent to register and come online? Based on licensing restrictions. The method takes into consideration the number of agents "reserved" for pending elastic instances.

Specified by:

allowNewRemoteAgent in interface AgentManager

Returns:

true if a new agent is allowed, otherise false

allowNewRemoteAgentWithId

public boolean allowNewRemoteAgentWithId(long id)

Description copied from interface: AgentManager

Allow a remote agent with specific id to register and come online? Based on licensing restrictions. The method takes into consideration the number of agents "reserved" for pending elastic instances.

Specified by:

allowNewRemoteAgentWithId in interface AgentManager

Parameters:

id - agent id

Returns:

true if a new agent is allowed, otherise false

allowNewRemoteAgents

public boolean allowNewRemoteAgents(int numOfAgentsToCreate)

Description copied from interface: AgentManager

Allow a specified number of remote agents to register and come online? Based on licensing restrictions. The method takes into consideration the number of agents "reserved" for pending elastic instances.

Specified by:

allowNewRemoteAgents in interface AgentManager

Returns:

true if a specified number agents is allowed, otherise false

allowNewElasticAgent

public boolean allowNewElasticAgent()

Description copied from interface: AgentManager

Allow an elastic agent to register and come online? Based on licensing restrictions.

Specified by:

allowNewElasticAgent in interface AgentManager

Returns:

true if a new agent is allowed, otherise false

allowNewElasticAgentWithId

public boolean allowNewElasticAgentWithId(long id)

Description copied from interface: AgentManager

Allow an elastic agent with specific id to register and come online? Based on licensing restrictions.

Specified by:

allowNewElasticAgentWithId in interface AgentManager

Parameters:

id - agent id

Returns:

true if a new agent is allowed, otherise false

allowNewEphemeralAgent

public boolean allowNewEphemeralAgent()

Description copied from interface: AgentManager

Allow an ephemeral agent to register and come online? Based on licensing restrictions.

Specified by:

allowNewEphemeralAgent in interface AgentManager

Returns:

true if a new agent is allowed, otherise false

allowNewEphemeralAgentWithId

public boolean allowNewEphemeralAgentWithId(long id)

Description copied from interface: AgentManager

Allow an ephemeral agent with specific id to register and come online? Based on licensing restrictions.

Specified by:

allowNewEphemeralAgentWithId in interface AgentManager

Parameters:

id - agent id

Returns:

true if a new agent is allowed, otherise false

allowNewElasticAgents

public boolean allowNewElasticAgents(int numOfAgentsToCreate)

Description copied from interface: AgentManager

Allow a specified number of elastic agents to register and come online? Based on licensing restrictions.

Specified by:

allowNewElasticAgents in interface AgentManager

Returns:

true if a specified number agents is allowed, otherise false

allowNewLocalAgent

public boolean allowNewLocalAgent()

Description copied from interface: AgentManager

Allow a local agent to come online? Based on licensing restrictions.

Specified by:

allowNewLocalAgent in interface AgentManager

Returns:

true if a new local agent is allowed, otherwise false

updateAgentStatusIfResultReturnPossibleAfterServerRestart

public boolean updateAgentStatusIfResultReturnPossibleAfterServerRestart(long agentId,
 ResultKey resultKey,
 String displayName,
 long deploymentResultId)

Description copied from interface: AgentManager

Checks if agent is capable of 'surviving' a server restart, i.e. if agent exists and is configured to reconnect after server restart, allowing it to return build result produced while the server was down. Sets agent status to 'building' if it is so.

Specified by:

updateAgentStatusIfResultReturnPossibleAfterServerRestart in interface AgentManager

Returns:

true iff agents is capable of surviving a server restart.

setAgentEnabled

public Optional<BuildAgent> setAgentEnabled(long agentId,
 boolean enable)

Specified by:

setAgentEnabled in interface AgentManager

getOfflineRemoteAgentIds

@NotNull
public @NotNull List<Long> getOfflineRemoteAgentIds()

Description copied from interface: AgentManager

Retrieves a list of offline remote agent IDs. Offline remote agents are those that are not currently connected to the server.

Specified by:

getOfflineRemoteAgentIds in interface AgentManager

Returns:

a list of offline remote agents IDs

getOfflineElasticAgentIds

@NotNull
public @NotNull List<Long> getOfflineElasticAgentIds()

Description copied from interface: AgentManager

Retrieves a list of offline elastic agents IDs. Offline elastic agents are those that are not currently connected to the server.

Specified by:

getOfflineElasticAgentIds in interface AgentManager

Returns:

a list of offline elastic agents IDs

getOfflineEphemeralAgentIds

@NotNull
public @NotNull List<Long> getOfflineEphemeralAgentIds()

Description copied from interface: AgentManager

Retrieves a list of offline ephemeral agents IDs. Offline ephemeral agents are those that are not currently connected to the server. As ephemeral agents take care of the self-removal once they finish executing the executable they were launched for, this should return only a small portion of agents that couldn't be removed due to errors or temporary unavailability.

Specified by:

getOfflineEphemeralAgentIds in interface AgentManager

Returns:

a list of offline ephemeral agents IDs

getOnlineEphemeralAgentCount

public int getOnlineEphemeralAgentCount()

Description copied from interface: AgentManager

Retrieves the total count of online ephemeral agents currently present in the system. Ephemeral agents are temporary agents that are created for specific tasks and are typically removed after completing their execution.

Specified by:

getOnlineEphemeralAgentCount in interface AgentManager

Returns:

the total number of ephemeral agents