public class PlanExecutionManagerImpl extends Object implements PlanExecutionManager
BuildDetectionAction
, it all depends which interface is implemented:
UnconditionalBuildDetectionAction
- meaning: if this action is created we know we want to start a build. (example: scheduled build, dependant build...)DelayedChangeDetectionAction
- special case of 1) with added feature of calling thread not being blocked by change detection (manual builds, restarted builds...)ConditionalBuildDetectionAction
- we don't know a priori if we wan't to start a build (trigger by vcs change)inChangeDetectionLock { inBuildCountLock { checkIfCountNotExceeded createResultWithoutChanges } doChangeDetection }
inBuildCountLock { checkIfCountNotExceeded createResultWithoutChanges; inNewThread { inChangeDetectionLock { doChangeDetection } } }
inChangeDetectionLock { inBuildCountLock { checkIfCountNotExceeded } doChangeDetection inBuildCountLock { checkIfCountNotExceeded createResultWithChanges } }
Constructor and Description |
---|
PlanExecutionManagerImpl(BuildExecutionManager buildExecutionManager,
PlanExecutionPermitter planExecutionPermitter,
ExecutionStatusProvider executionStatusProvider,
PlanManager planManager,
StopBuildManager stopBuildManager,
TriggerManager triggerManager,
PlanExecutionLockService planExecutionLockService,
com.atlassian.event.api.EventPublisher eventPublisher,
ErrorHandler errorHandler,
DeploymentPermitter deploymentPermitter,
com.atlassian.bamboo.plan.PlanExecutionManagerCallWatcher planExecutionManagerCallWatcher) |
Modifier and Type | Method and Description |
---|---|
List<CurrentlyBuilding> |
getCurrentlyBuildingForPlan(PlanKey planKey)
|
List<CurrentlyBuilding> |
getCurrentlyBuildingForPlanResult(PlanResultKey planResultKey)
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) |
Collection<? extends ExecutionStatus> |
getExecutionStatus(PlanKey planKey)
Returns a collection of current
ExecutionStatus s for PlanKey |
ExecutionStatus |
getExecutionStatus(PlanResultKey planResultKey)
Returns a
ExecutionStatus for the given PlanResultKey |
BuildExecution |
getJobExecution(PlanResultKey planResultKey)
Get the state of a single Job being executed
|
boolean |
isBuildingAllowed(ImmutableChain chain)
Checks if a particular build is allowed to be built.
|
boolean |
isBusy() |
boolean |
isBusy(PlanKey planKey)
|
int |
numberOfExecutions(PlanKey planKey)
Returns the number of current
ExecutionStatus s available for PlanKey |
Future<Boolean> |
shutdown() |
ExecutionRequestResult |
start(ImmutableChain chain,
BuildDetectionAction buildDetectionAction,
AcquisitionPolicy acquisitionPolicy)
|
ExecutionRequestResult |
start(ImmutableChain chain,
PlanExecutionConfig planExecutionConfig,
String triggerReasonPluginKey,
String planTriggerPluginKey,
Map<String,String> params,
Map<String,String> variables,
AcquisitionPolicy acquisitionPolicy)
|
ExecutionRequestResult |
start(Triggerable triggerable,
BuildDetectionAction buildDetectionAction,
AcquisitionPolicy acquisitionPolicy)
|
ExecutionRequestResult |
startManualExecution(ImmutableChain chain,
PlanExecutionConfig planExecutionConfig,
com.atlassian.user.User user,
Map<String,String> params,
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 |
ExecutionRequestResult |
startManualExecution(ImmutableChain chain,
PlanExecutionConfig planExecutionConfig,
com.atlassian.user.User user,
String triggerReasonPluginKey,
String planTriggerPluginKey,
Map<String,String> params,
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 |
ExecutionRequestResult |
startManualExecution(ImmutableChain chain,
com.atlassian.user.User user,
Map<String,String> params,
Map<String,String> variables)
Attempts to start a manual execution of the given
Plan |
void |
stopPlan(PlanKey planKey,
boolean abandonResult,
String userName) |
void |
stopPlan(PlanResultKey planResultKey,
boolean abandonResult,
String userName) |
void |
stopRequest(PlanKey planKey)
Stops a build requests for the given
PlanKey |
public PlanExecutionManagerImpl(BuildExecutionManager buildExecutionManager, PlanExecutionPermitter planExecutionPermitter, ExecutionStatusProvider executionStatusProvider, PlanManager planManager, StopBuildManager stopBuildManager, TriggerManager triggerManager, PlanExecutionLockService planExecutionLockService, com.atlassian.event.api.EventPublisher eventPublisher, ErrorHandler errorHandler, DeploymentPermitter deploymentPermitter, com.atlassian.bamboo.plan.PlanExecutionManagerCallWatcher planExecutionManagerCallWatcher)
public int numberOfExecutions(@NotNull PlanKey planKey)
ExecutionStatusProvider
ExecutionStatus
s available for PlanKey
numberOfExecutions
in interface ExecutionStatusProvider
@NotNull public Collection<? extends ExecutionStatus> getExecutionStatus(@NotNull PlanKey planKey)
ExecutionStatusProvider
ExecutionStatus
s for PlanKey
getExecutionStatus
in interface ExecutionStatusProvider
@Nullable public ExecutionStatus getExecutionStatus(@NotNull PlanResultKey planResultKey)
ExecutionStatusProvider
ExecutionStatus
for the given PlanResultKey
getExecutionStatus
in interface ExecutionStatusProvider
public BuildExecution getJobExecution(@NotNull PlanResultKey planResultKey)
ExecutionStatusProvider
getJobExecution
in interface ExecutionStatusProvider
@NotNull public ExecutionRequestResult startManualExecution(@NotNull ImmutableChain chain, @NotNull com.atlassian.user.User user, @NotNull Map<String,String> params, @NotNull Map<String,String> variables)
PlanExecutionManager
Plan
startManualExecution
in interface PlanExecutionManager
params
- - additional execution parameters set in code to parametrized build - not exposed to uservariables
- - user defined variables that could be parametrized in manual execution - contain only values
changed by user in UI@NotNull public ExecutionRequestResult startManualExecution(@NotNull ImmutableChain chain, @Nullable PlanExecutionConfig planExecutionConfig, @NotNull com.atlassian.user.User user, @NotNull Map<String,String> params, @NotNull Map<String,String> variables)
PlanExecutionManager
Plan
controlled by PlanExecutionConfig
PlanExecutionConfig
allows to control manual stages execution as well as enforcing execution of manual stagesstartManualExecution
in interface PlanExecutionManager
@NotNull public ExecutionRequestResult startManualExecution(@NotNull ImmutableChain chain, @Nullable PlanExecutionConfig planExecutionConfig, @NotNull com.atlassian.user.User user, @NotNull String triggerReasonPluginKey, @Nullable String planTriggerPluginKey, @NotNull Map<String,String> params, @NotNull Map<String,String> variables)
PlanExecutionManager
Plan
controlled by PlanExecutionConfig
PlanExecutionConfig
allows to control manual stages execution as well as enforcing execution of manual stagesstartManualExecution
in interface PlanExecutionManager
public boolean isBusy(@NotNull PlanKey planKey)
PlanExecutionManager
isBusy
in interface PlanExecutionManager
public boolean isBusy()
isBusy
in interface PlanExecutionManager
@NotNull public 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)
PlanExecutionManager
start
in interface PlanExecutionManager
planExecutionConfig
- extended configuration for executiontriggerReasonPluginKey
- full plugin key for a TriggerReason
planTriggerPluginKey
- full plugin key for a PlanTrigger
params
- custom paramsvariables
- overriden variablesacquisitionPolicy
- to aquire the lockpublic ExecutionRequestResult start(@NotNull ImmutableChain chain, @NotNull BuildDetectionAction buildDetectionAction, @NotNull AcquisitionPolicy acquisitionPolicy)
PlanExecutionManager
ImmutableChain
with the provided BuildDetectionAction
and AcquisitionPolicy
Calls to this method will acquire a lock according to the AcquisitionPolicy
on a per Plan
granularity
start
in interface PlanExecutionManager
@NotNull public ExecutionRequestResult start(@NotNull Triggerable triggerable, @NotNull BuildDetectionAction buildDetectionAction, @NotNull AcquisitionPolicy acquisitionPolicy)
PlanExecutionManager
Triggerable
with the provided BuildDetectionAction
and AcquisitionPolicy
Calls to this method will acquire a lock according to the AcquisitionPolicy
on a per Plan
granularity
start
in interface PlanExecutionManager
public boolean isBuildingAllowed(@NotNull ImmutableChain chain)
PlanExecutionManager
isBuildingAllowed
in interface PlanExecutionManager
@NotNull public List<CurrentlyBuilding> getCurrentlyBuildingForPlan(PlanKey planKey)
PlanExecutionManager
PlanKey
In case plan is a Chain
instance, all
currently running jobs will be returnedgetCurrentlyBuildingForPlan
in interface PlanExecutionManager
@NotNull public List<CurrentlyBuilding> getCurrentlyBuildingForPlanResult(PlanResultKey planResultKey)
PlanExecutionManager
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)getCurrentlyBuildingForPlanResult
in interface PlanExecutionManager
public void stopPlan(@NotNull PlanResultKey planResultKey, boolean abandonResult, String userName)
stopPlan
in interface PlanExecutionManager
public void stopPlan(@NotNull PlanKey planKey, boolean abandonResult, String userName) throws InterruptedException
stopPlan
in interface PlanExecutionManager
InterruptedException
public void stopRequest(@NotNull PlanKey planKey)
PlanExecutionManager
PlanKey
stopRequest
in interface PlanExecutionManager
public Future<Boolean> shutdown()
shutdown
in interface PlanExecutionManager
Copyright © 2018 Atlassian Software Systems Pty Ltd. All rights reserved.