Package com.atlassian.bamboo.plan

Class DelegatingPlanExecutionManager

java.lang.Object

com.atlassian.bamboo.plan.DelegatingPlanExecutionManager

All Implemented Interfaces:

ExecutionStatusProvider, PlanExecutionManager

public class DelegatingPlanExecutionManager
extends Object
implements PlanExecutionManager

Constructor Summary

Constructors

Constructor	Description
DelegatingPlanExecutionManager(@NotNull PlanExecutionManager target, @NotNull com.atlassian.bamboo.plan.PlanExecutionManagerCallWatcher planExecutionManagerCallWatcher)

Method Summary

Modifier and Type	Method	Description
@NotNull List<CurrentlyBuilding>	getCurrentlyBuildingForPlan(PlanKey planKey)	Returns all for specified PlanKey In case plan is a Chain instance, all currently running jobs will be returned
@NotNull List<CurrentlyBuilding>	getCurrentlyBuildingForPlanResult(PlanResultKey planKey)	Returns all CurrentlyBuilding for specified PlanResultKey In case plan is a Chain instance, all currently running jobs will be returned, however, chain itself will be not included in the list (effectively CurrentlyBuilding for all chain's children jobs will be returned)
@NotNull Collection<? extends ExecutionStatus>	getExecutionStatus(@NotNull PlanKey planKey)	Returns a collection of current ExecutionStatuss for PlanKey
@Nullable ExecutionStatus	getExecutionStatus(@NotNull PlanResultKey planResultKey)	Returns a ExecutionStatus for the given PlanResultKey
@Nullable BuildExecution	getJobExecution(@NotNull PlanResultKey planResultKey)	Get the state of a single Job being executed
boolean	isBuildingAllowed(@NotNull ImmutableChain chain)	Checks if a particular build is allowed to be built.
boolean	isBusy()
boolean	isBusy(@NotNull PlanKey planKey)	Tests if the Plan represented by PlanKey is busy starting
int	numberOfExecutions(@NotNull PlanKey planKey)	Returns the number of current ExecutionStatuss available for PlanKey
Future<Boolean>	shutdown()
@NotNull ExecutionRequestResult	start(@NotNull ImmutableChain chain, @NotNull BuildDetectionAction buildDetectionAction, @NotNull AcquisitionPolicy acquisitionPolicy)	Execute the ImmutableChain with the provided BuildDetectionAction and AcquisitionPolicy
@NotNull ExecutionRequestResult	start(@NotNull ImmutableChain chain, @NotNull BuildDetectionAction buildDetectionAction, @NotNull AcquisitionPolicy acquisitionPolicy, PlanExecutionLaunchControl.ReleaseLocksActions releaseLocksActions)	Execute the ImmutableChain with the provided BuildDetectionAction and AcquisitionPolicy
@NotNull ExecutionRequestResult	start(@NotNull ImmutableChain chain, @Nullable PlanExecutionConfig planExecutionConfig, @NotNull String triggerReasonPluginKey, @NotNull String planTriggerPluginKey, @NotNull Map<String,String> params, @NotNull Map<String,String> variables, @NotNull AcquisitionPolicy acquisitionPolicy)	Execute the provided Plan with a custom TriggerReason, PlanTrigger, parameters and variables
@NotNull ExecutionRequestResult	start(@NotNull Triggerable triggerable, @NotNull BuildDetectionAction buildDetectionAction, @NotNull AcquisitionPolicy acquisitionPolicy)	Execute the Triggerable with the provided BuildDetectionAction and AcquisitionPolicy
@NotNull ExecutionRequestResult	start(@NotNull Triggerable triggerable, @NotNull BuildDetectionAction buildDetectionAction, @NotNull AcquisitionPolicy acquisitionPolicy, PlanExecutionLaunchControl.ReleaseLocksActions releaseLocksActions)	Execute the Triggerable with the provided BuildDetectionAction and AcquisitionPolicy
@NotNull ExecutionRequestResult	startManualExecution(@NotNull ImmutableChain chain, PlanExecutionConfig planExecutionConfig, @NotNull com.atlassian.user.User user, @NotNull String triggerReasonPluginKey, @NotNull String planTriggerPluginKey, @NotNull Map<String,String> params, @NotNull Map<String,String> variables)	Attempts to start a manual execution of a given Plan controlled by PlanExecutionConfig PlanExecutionConfig allows to control manual stages execution as well as enforcing execution of manual stages
@NotNull ExecutionRequestResult	startManualExecution(@NotNull ImmutableChain chain, PlanExecutionConfig planExecutionConfig, @NotNull com.atlassian.user.User user, @NotNull Map<String,String> params, @NotNull Map<String,String> variables)	Attempts to start a manual execution of a given Plan controlled by PlanExecutionConfig PlanExecutionConfig allows to control manual stages execution as well as enforcing execution of manual stages
@NotNull ExecutionRequestResult	startManualExecution(@NotNull ImmutableChain chain, @NotNull com.atlassian.user.User user, @NotNull Map<String,String> params, @NotNull Map<String,String> variables)	Attempts to start a manual execution of the given Plan
void	stopPlan(@NotNull PlanKey planKey, boolean abandonResult, String userName)
void	stopPlan(@NotNull PlanResultKey planResultKey, boolean abandonResult, String userName)
void	stopRequest(@NotNull PlanKey planKey)	Stops a build requests for the given PlanKey

Methods inherited from class java.lang.Object

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

Constructor Details

DelegatingPlanExecutionManager

public DelegatingPlanExecutionManager(@NotNull
 @NotNull PlanExecutionManager target,
 @NotNull
 @NotNull com.atlassian.bamboo.plan.PlanExecutionManagerCallWatcher planExecutionManagerCallWatcher)

Method Details

isBusy

public boolean isBusy()

Specified by:

isBusy in interface PlanExecutionManager

Returns:

if the server is busy building

isBusy

public boolean isBusy(@NotNull
 @NotNull PlanKey planKey)

Description copied from interface: PlanExecutionManager

Tests if the Plan represented by PlanKey is busy starting

Specified by:

isBusy in interface PlanExecutionManager

Parameters:

planKey -

Returns:

busy

start

@NotNull
public @NotNull ExecutionRequestResult start(@NotNull
 @NotNull ImmutableChain chain,
 @NotNull
 @NotNull BuildDetectionAction buildDetectionAction,
 @NotNull
 @NotNull AcquisitionPolicy acquisitionPolicy)

Description copied from interface: PlanExecutionManager

Execute the ImmutableChain with the provided BuildDetectionAction and AcquisitionPolicy

Calls to this method will acquire a lock according to the AcquisitionPolicy on a per Plan granularity

Specified by:

start in interface PlanExecutionManager

Parameters:

chain -

buildDetectionAction -

acquisitionPolicy -

Returns:

planExecutionResult

start

@NotNull
public @NotNull ExecutionRequestResult start(@NotNull
 @NotNull ImmutableChain chain,
 @NotNull
 @NotNull BuildDetectionAction buildDetectionAction,
 @NotNull
 @NotNull AcquisitionPolicy acquisitionPolicy,
 @NotNull
 PlanExecutionLaunchControl.ReleaseLocksActions releaseLocksActions)

Description copied from interface: PlanExecutionManager

Execute the ImmutableChain with the provided BuildDetectionAction and AcquisitionPolicy

Calls to this method will acquire a lock according to the AcquisitionPolicy on a per Plan granularity

Specified by:

start in interface PlanExecutionManager

Parameters:

chain -

buildDetectionAction -

acquisitionPolicy -

releaseLocksActions - actions used for releasing repositories caches locks

Returns:

planExecutionResult

start

@NotNull
public @NotNull ExecutionRequestResult start(@NotNull
 @NotNull Triggerable triggerable,
 @NotNull
 @NotNull BuildDetectionAction buildDetectionAction,
 @NotNull
 @NotNull AcquisitionPolicy acquisitionPolicy)

Description copied from interface: PlanExecutionManager

Execute the Triggerable with the provided BuildDetectionAction and AcquisitionPolicy

Calls to this method will acquire a lock according to the AcquisitionPolicy on a per Plan granularity

Specified by:

start in interface PlanExecutionManager

Parameters:

triggerable -

buildDetectionAction -

acquisitionPolicy -

Returns:

planExecutionResult

start

@NotNull
public @NotNull ExecutionRequestResult start(@NotNull
 @NotNull Triggerable triggerable,
 @NotNull
 @NotNull BuildDetectionAction buildDetectionAction,
 @NotNull
 @NotNull AcquisitionPolicy acquisitionPolicy,
 @NotNull
 PlanExecutionLaunchControl.ReleaseLocksActions releaseLocksActions)

Description copied from interface: PlanExecutionManager

Execute the Triggerable with the provided BuildDetectionAction and AcquisitionPolicy

Calls to this method will acquire a lock according to the AcquisitionPolicy on a per Plan granularity

Specified by:

start in interface PlanExecutionManager

Parameters:

triggerable -

buildDetectionAction -

acquisitionPolicy -

releaseLocksActions - actions used for releasing repositories caches locks

Returns:

planExecutionResult

start

@NotNull
public @NotNull ExecutionRequestResult start(@NotNull
 @NotNull ImmutableChain chain,
 @Nullable
 @Nullable PlanExecutionConfig planExecutionConfig,
 @NotNull
 @NotNull String triggerReasonPluginKey,
 @NotNull
 @NotNull String planTriggerPluginKey,
 @NotNull
 @NotNull Map<String,String> params,
 @NotNull
 @NotNull Map<String,String> variables,
 @NotNull
 @NotNull AcquisitionPolicy acquisitionPolicy)

Description copied from interface: PlanExecutionManager

Execute the provided Plan with a custom TriggerReason, PlanTrigger, parameters and variables

Specified by:

start in interface PlanExecutionManager

Parameters:

chain -

planExecutionConfig - extended configuration for execution

triggerReasonPluginKey - full plugin key for a TriggerReason

planTriggerPluginKey - full plugin key for a PlanTrigger

params - custom params

variables - overriden variables

acquisitionPolicy - to aquire the lock

Returns:

planExecutionResult

startManualExecution

@NotNull
public @NotNull ExecutionRequestResult startManualExecution(@NotNull
 @NotNull ImmutableChain chain,
 @NotNull
 @NotNull com.atlassian.user.User user,
 @NotNull
 @NotNull Map<String,String> params,
 @NotNull
 @NotNull Map<String,String> variables)

Description copied from interface: PlanExecutionManager

Attempts to start a manual execution of the given Plan

Specified by:

startManualExecution in interface PlanExecutionManager

Parameters:

chain -

user -

params - - additional execution parameters set in code to parametrized build - not exposed to user

variables - - user defined variables that could be parametrized in manual execution - contain only values changed by user in UI

Returns:

executionRequestResult

startManualExecution

@NotNull
public @NotNull ExecutionRequestResult startManualExecution(@NotNull
 @NotNull ImmutableChain chain,
 PlanExecutionConfig planExecutionConfig,
 @NotNull
 @NotNull com.atlassian.user.User user,
 @NotNull
 @NotNull Map<String,String> params,
 @NotNull
 @NotNull Map<String,String> variables)

Description copied from interface: PlanExecutionManager

Attempts to start a manual execution of a given Plan controlled by PlanExecutionConfig PlanExecutionConfig allows to control manual stages execution as well as enforcing execution of manual stages

Specified by:

startManualExecution in interface PlanExecutionManager

Parameters:

chain -

planExecutionConfig -

user -

params -

variables -

Returns:

startManualExecution

@NotNull
public @NotNull ExecutionRequestResult startManualExecution(@NotNull
 @NotNull ImmutableChain chain,
 PlanExecutionConfig planExecutionConfig,
 @NotNull
 @NotNull com.atlassian.user.User user,
 @NotNull
 @NotNull String triggerReasonPluginKey,
 @NotNull
 @NotNull String planTriggerPluginKey,
 @NotNull
 @NotNull Map<String,String> params,
 @NotNull
 @NotNull Map<String,String> variables)

Description copied from interface: PlanExecutionManager

Attempts to start a manual execution of a given Plan controlled by PlanExecutionConfig PlanExecutionConfig allows to control manual stages execution as well as enforcing execution of manual stages

Specified by:

startManualExecution in interface PlanExecutionManager

Parameters:

chain -

planExecutionConfig -

user -

triggerReasonPluginKey -

planTriggerPluginKey -

params -

variables -

Returns:

isBuildingAllowed

public boolean isBuildingAllowed(@NotNull
 @NotNull ImmutableChain chain)

Description copied from interface: PlanExecutionManager

Checks if a particular build is allowed to be built. It checks if it exists, not suspened, and that there is no global flag that has stopped building

Specified by:

isBuildingAllowed in interface PlanExecutionManager

Parameters:

chain -

Returns:

true if plan is allowed to be built

getCurrentlyBuildingForPlan

@NotNull
public @NotNull List<CurrentlyBuilding> getCurrentlyBuildingForPlan(PlanKey planKey)

Description copied from interface: PlanExecutionManager

Returns all for specified PlanKey In case plan is a Chain instance, all currently running jobs will be returned

Specified by:

getCurrentlyBuildingForPlan in interface PlanExecutionManager

Parameters:

planKey -

Returns:

getCurrentlyBuildingForPlanResult

@NotNull
public @NotNull List<CurrentlyBuilding> getCurrentlyBuildingForPlanResult(PlanResultKey planKey)

Description copied from interface: PlanExecutionManager

Returns all CurrentlyBuilding for specified PlanResultKey In case plan is a Chain instance, all currently running jobs will be returned, however, chain itself will be not included in the list (effectively CurrentlyBuilding for all chain's children jobs will be returned)

Specified by:

getCurrentlyBuildingForPlanResult in interface PlanExecutionManager

Parameters:

planKey -

Returns:

stopPlan

public void stopPlan(@NotNull
 @NotNull PlanResultKey planResultKey,
 boolean abandonResult,
 String userName)

Specified by:

stopPlan in interface PlanExecutionManager

stopPlan

public void stopPlan(@NotNull
 @NotNull PlanKey planKey,
 boolean abandonResult,
 String userName)
              throws InterruptedException

Specified by:

stopPlan in interface PlanExecutionManager

Throws:

InterruptedException

stopRequest

public void stopRequest(@NotNull
 @NotNull PlanKey planKey)

Description copied from interface: PlanExecutionManager

Stops a build requests for the given PlanKey

Specified by:

stopRequest in interface PlanExecutionManager

Parameters:

planKey -

numberOfExecutions

public int numberOfExecutions(@NotNull
 @NotNull PlanKey planKey)

Description copied from interface: ExecutionStatusProvider

Returns the number of current ExecutionStatuss available for PlanKey

Specified by:

numberOfExecutions in interface ExecutionStatusProvider

Parameters:

planKey -

Returns:

noOfExecutions

getExecutionStatus

@NotNull
public @NotNull Collection<? extends ExecutionStatus> getExecutionStatus(@NotNull
 @NotNull PlanKey planKey)

Description copied from interface: ExecutionStatusProvider

Returns a collection of current ExecutionStatuss for PlanKey

Specified by:

getExecutionStatus in interface ExecutionStatusProvider

Parameters:

planKey -

Returns:

executionStatuses

getExecutionStatus

@Nullable
public @Nullable ExecutionStatus getExecutionStatus(@NotNull
 @NotNull PlanResultKey planResultKey)

Description copied from interface: ExecutionStatusProvider

Returns a ExecutionStatus for the given PlanResultKey

Specified by:

getExecutionStatus in interface ExecutionStatusProvider

Parameters:

planResultKey -

Returns:

executionStatus

getJobExecution

@Nullable
public @Nullable BuildExecution getJobExecution(@NotNull
 @NotNull PlanResultKey planResultKey)

Description copied from interface: ExecutionStatusProvider

Get the state of a single Job being executed

Specified by:

getJobExecution in interface ExecutionStatusProvider

Parameters:

planResultKey -

Returns:

shutdown

public Future<Boolean> shutdown()

Specified by:

shutdown in interface PlanExecutionManager