Package com.atlassian.bamboo.buildqueue.manager

Class RemoteAgentManagerImpl

java.lang.Object

com.atlassian.bamboo.buildqueue.manager.RemoteAgentManagerImpl

All Implemented Interfaces:

RemoteAgentManager, RemotedRemoteAgentManager, DelayedStateInitialization

public class RemoteAgentManagerImpl
extends Object
implements RemoteAgentManager, DelayedStateInitialization

Constructor Summary

Constructors

Constructor	Description
RemoteAgentManagerImpl(int heartbeatTimeoutSeconds, StartupStatisticsBean startupStatisticsBean, com.atlassian.event.api.EventPublisher eventPublisher)

Method Summary

Modifier and Type	Method	Description
void	addRemoteAgentLogEntry(String logEntry)
void	bootstrapping(String agentHostName)	Notifies the RemoteAgentManager that a remote agent has commenced bootstrapping.
void	bootstrappingElastic(String agentHostName, @Nullable String instanceId)	Notifies the RemoteAgentManager that an elastic agent has commenced bootstrapping.
void	bootstrappingEphemeral(String agentHostName)	Notifies the RemoteAgentManager that an ephemeral agent has commenced bootstrapping.
void	checkOfflineAgents()	Runs a check for offline remote agents.
List<String>	getRemoteAgentLog()
void	init()	Initialize the state of the component.
boolean	isRemoteAgentFunctionEnabled()	Checks whether the remote agent functionality is currently enabled.
@NotNull PipelineDefinition	registerAgent(@NotNull PipelineDefinition remoteAgentDefinition)	Initial setup / verification of the agent.
@NotNull RemotableRemoteAgentDefinition	registerAgent(@NotNull RemotableRemoteAgentDefinition remotableRemoteAgentDefinition)	Initial setup / verification of the agent.
void	setHeartbeatCheckInterval(int heartbeatCheckInterval)
void	setHeartbeatInterval(int heartbeatInterval)
void	setRemoteAgentFunctionEnabled(boolean remoteAgentFunctionEnabled)	Controls whether the remote agent functionality of Bamboo is enabled.
void	setUri(String uri)
void	start()
void	stopConnectors()
void	stopRemoteAgent(@NotNull BuildAgent agent)
AgentHeartBeatInfo	updateRemoteAgentStatus(@NotNull Long agentId, @Nullable UUID uuid, @NotNull AgentStatus newStatus, @NotNull SystemInfo systemInfo)	Updates the BuildAgent's status representing a remote agent on the local server.

Methods inherited from class java.lang.Object

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

Constructor Details

RemoteAgentManagerImpl

public RemoteAgentManagerImpl(int heartbeatTimeoutSeconds,
 StartupStatisticsBean startupStatisticsBean,
 com.atlassian.event.api.EventPublisher eventPublisher)

Method Details

init

public void init()

Description copied from interface: DelayedStateInitialization

Initialize the state of the component.

Specified by:

init in interface DelayedStateInitialization

registerAgent

@NotNull
public @NotNull RemotableRemoteAgentDefinition registerAgent(@NotNull
 @NotNull RemotableRemoteAgentDefinition remotableRemoteAgentDefinition)

Description copied from interface: RemotedRemoteAgentManager

Initial setup / verification of the agent. This method may perform checking of whether the remote agent matches the current version on the server / updates etc

Specified by:

registerAgent in interface RemotedRemoteAgentManager

Parameters:

remotableRemoteAgentDefinition - - id may be -1 if the build is new

Returns:

RemoteAgentDefinition with the id filled

registerAgent

@NotNull
public @NotNull PipelineDefinition registerAgent(@NotNull
 @NotNull PipelineDefinition remoteAgentDefinition)
                                          throws BambooLicenseException

Description copied from interface: RemoteAgentManager

Initial setup / verification of the agent. This method may perform checking of whether the remote agent matches the current version on the server / updates etc

Specified by:

registerAgent in interface RemoteAgentManager

Parameters:

remoteAgentDefinition - - id may be -1 if the build is new

Returns:

RemoteAgentDefinition with the id filled

Throws:

BambooLicenseException

updateRemoteAgentStatus

public AgentHeartBeatInfo updateRemoteAgentStatus(@NotNull
 @NotNull Long agentId,
 @Nullable
 @Nullable UUID uuid,
 @NotNull
 @NotNull AgentStatus newStatus,
 @NotNull
 @NotNull SystemInfo systemInfo)

Description copied from interface: RemoteAgentManager

Updates the BuildAgent's status representing a remote agent on the local server.

Specified by:

updateRemoteAgentStatus in interface RemoteAgentManager

Parameters:

agentId - ID of the agent

uuid - UUID of the agent

newStatus - agent status

systemInfo - agent system info

Returns:

current heart beat info

checkOfflineAgents

public void checkOfflineAgents()

Description copied from interface: RemoteAgentManager

Runs a check for offline remote agents.

Specified by:

checkOfflineAgents in interface RemoteAgentManager

setRemoteAgentFunctionEnabled

public void setRemoteAgentFunctionEnabled(boolean remoteAgentFunctionEnabled)
                                   throws Exception

Description copied from interface: RemoteAgentManager

Controls whether the remote agent functionality of Bamboo is enabled.

Specified by:

setRemoteAgentFunctionEnabled in interface RemoteAgentManager

Parameters:

remoteAgentFunctionEnabled - true if remote agent functionality should be enabled; false otherwise.

Throws:

Exception - on any error

isRemoteAgentFunctionEnabled

public boolean isRemoteAgentFunctionEnabled()

Description copied from interface: RemoteAgentManager

Checks whether the remote agent functionality is currently enabled.

Specified by:

isRemoteAgentFunctionEnabled in interface RemoteAgentManager

Returns:

true, if remote agent functionality is enabled, false otherwise

stopRemoteAgent

public void stopRemoteAgent(@NotNull
 @NotNull BuildAgent agent)

Specified by:

stopRemoteAgent in interface RemoteAgentManager

bootstrapping

public void bootstrapping(String agentHostName)

Description copied from interface: RemoteAgentManager

Notifies the RemoteAgentManager that a remote agent has commenced bootstrapping.

Specified by:

bootstrapping in interface RemoteAgentManager

Parameters:

agentHostName - The host name or IP address of the host on which the remote agent is running. null if unknown.

bootstrappingEphemeral

public void bootstrappingEphemeral(String agentHostName)

Description copied from interface: RemoteAgentManager

Notifies the RemoteAgentManager that an ephemeral agent has commenced bootstrapping.

Specified by:

bootstrappingEphemeral in interface RemoteAgentManager

Parameters:

agentHostName - The host name or IP address of the host on which the remote agent is running. null if unknown.

bootstrappingElastic

public void bootstrappingElastic(String agentHostName,
 @Nullable
 @Nullable String instanceId)

Description copied from interface: RemoteAgentManager

Notifies the RemoteAgentManager that an elastic agent has commenced bootstrapping.

Specified by:

bootstrappingElastic in interface RemoteAgentManager

Parameters:

agentHostName - The host name or IP address of the host on which the remote agent is running. null if unknown.

instanceId - the instance the elastic agent is loading on

addRemoteAgentLogEntry

public void addRemoteAgentLogEntry(String logEntry)

Specified by:

addRemoteAgentLogEntry in interface RemoteAgentManager

stopConnectors

public void stopConnectors()
                    throws Exception

Specified by:

stopConnectors in interface RemoteAgentManager

Throws:

Exception

start

public void start()
           throws Exception

Specified by:

start in interface RemoteAgentManager

Throws:

Exception

getRemoteAgentLog

public List<String> getRemoteAgentLog()

Specified by:

getRemoteAgentLog in interface RemoteAgentManager

setHeartbeatCheckInterval

public void setHeartbeatCheckInterval(int heartbeatCheckInterval)

setHeartbeatInterval

public void setHeartbeatInterval(int heartbeatInterval)

setUri

public void setUri(String uri)