com.dtolabs.rundeck.core.execution.workflow

Class BaseWorkflowExecutor

java.lang.Object

com.dtolabs.rundeck.core.execution.workflow.BaseWorkflowExecutor

All Implemented Interfaces:

WorkflowExecutor

Direct Known Subclasses:

EngineWorkflowExecutor, NodeFirstWorkflowExecutor, ParallelWorkflowExecutor, StepFirstWorkflowExecutor

public abstract class BaseWorkflowExecutor
extends java.lang.Object
implements WorkflowExecutor

BaseWorkflowStrategy is ...

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BaseWorkflowExecutor.StepResultCapture

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.lang.String	DATA_CONTEXT_PREFIX
protected static java.lang.String	OPTION_KEY
protected static java.lang.String	SECURE_OPTION_KEY
protected static java.lang.String	SECURE_OPTION_VALUE

Fields inherited from interface com.dtolabs.rundeck.core.execution.workflow.WorkflowExecutor

NODE_FIRST, PARALLEL, STEP_FIRST

Constructor Summary

Constructors

Constructor and Description
BaseWorkflowExecutor(Framework framework)

Method Summary

Methods

Modifier and Type	Method and Description
protected StepExecutionContext	addNodeStepFailureContextData(StepExecutionResult dispatcherStepResult, StepExecutionContext handlerExecContext) Add any node-specific step failure information to the node-specific data contexts
protected StepExecutionContext	addStepFailureContextData(StepExecutionResult stepResult, StepExecutionContext handlerExecContext) Add step result failure information to the data context
protected java.util.Map<java.lang.String,java.util.Collection<StepExecutionResult>>	convertFailures(java.util.Map<java.lang.Integer,StepExecutionResult> failedMap) Convert map of step execution results keyed by step number, to a collection of step execution results keyed by node name
protected java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>>	createPrintableDataContext(java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>> dataContext) Creates a copy of the given data context with the secure option values obfuscated.
protected java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>>	createPrintableDataContext(java.lang.String optionKey, java.lang.String secureOptionKey, java.lang.String secureOptionValue, java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>> dataContext) Creates a copy of the given data context with the secure option values obfuscated.
protected StepExecutionResult	executeWFItem(StepExecutionContext executionContext, java.util.Map<java.lang.Integer,StepExecutionResult> failedMap, int c, StepExecutionItem cmd) Execute a workflow item, returns true if the item succeeds.
WorkflowExecutionResult	executeWorkflow(StepExecutionContext executionContext, WorkflowExecutionItem item)
abstract WorkflowExecutionResult	executeWorkflowImpl(StepExecutionContext executionContext, WorkflowExecutionItem item)
protected WorkflowStatusResult	executeWorkflowItemsForNodeSet(StepExecutionContext executionContext, java.util.Map<java.lang.Integer,StepExecutionResult> failedMap, java.util.List<StepExecutionResult> resultList, java.util.List<StepExecutionItem> iWorkflowCmdItems, boolean keepgoing) Execute the sequence of ExecutionItems within the context, and with the given keepgoing value
protected WorkflowStatusResult	executeWorkflowItemsForNodeSet(StepExecutionContext executionContext, java.util.Map<java.lang.Integer,StepExecutionResult> failedMap, java.util.List<StepExecutionResult> resultList, java.util.List<StepExecutionItem> iWorkflowCmdItems, boolean keepgoing, int beginStepIndex) Execute the sequence of ExecutionItems within the context, and with the given keepgoing value
BaseWorkflowExecutor.StepResultCapture	executeWorkflowStep(StepExecutionContext executionContext, java.util.Map<java.lang.Integer,StepExecutionResult> failedMap, java.util.List<StepExecutionResult> resultList, boolean keepgoing, WorkflowExecutionListener wlistener, int c, StepExecutionItem cmd) Execute a step and handle flow control and error handler.
protected StepExecutionResult	executeWorkflowStep(WorkflowExecutionListener wlistener, StepExecutionItem cmd, StepExecutionContext executionContext, java.util.Map<java.lang.Integer,StepExecutionResult> stepFailedMap, int stepNum) Deprecated. use executeWorkflowStep(StepExecutionContext, Map, List, boolean, WorkflowExecutionListener, int, StepExecutionItem)
protected WorkflowExecutionListener	getWorkflowListener(ExecutionContext executionContext)
protected static NodeStepResult	nodeStepResultFromNodeStepException(INodeEntry node, NodeStepException nodeStepException)
protected StepExecutionContext	replaceFailedNodesListenerInContext(StepExecutionContext executionContext, FailedNodesListener captureFailedNodesListener)

Methods inherited from class java.lang.Object

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

Field Detail

DATA_CONTEXT_PREFIX

protected static final java.lang.String DATA_CONTEXT_PREFIX

See Also:

Constant Field Values

OPTION_KEY

protected static final java.lang.String OPTION_KEY

See Also:

Constant Field Values

SECURE_OPTION_KEY

protected static final java.lang.String SECURE_OPTION_KEY

See Also:

Constant Field Values

SECURE_OPTION_VALUE

protected static final java.lang.String SECURE_OPTION_VALUE

See Also:

Constant Field Values

Constructor Detail

BaseWorkflowExecutor

public BaseWorkflowExecutor(Framework framework)

Method Detail

executeWorkflowStep

protected StepExecutionResult executeWorkflowStep(WorkflowExecutionListener wlistener,
                                      StepExecutionItem cmd,
                                      StepExecutionContext executionContext,
                                      java.util.Map<java.lang.Integer,StepExecutionResult> stepFailedMap,
                                      int stepNum)

Deprecated. use executeWorkflowStep(StepExecutionContext, Map, List, boolean, WorkflowExecutionListener, int, StepExecutionItem)

Executes a step

Parameters:

wlistener - listener

cmd - step

executionContext - context

stepFailedMap - failures

stepNum - index

Returns:

result

executeWorkflow

public final WorkflowExecutionResult executeWorkflow(StepExecutionContext executionContext,
                                      WorkflowExecutionItem item)

Specified by:

executeWorkflow in interface WorkflowExecutor

getWorkflowListener

protected WorkflowExecutionListener getWorkflowListener(ExecutionContext executionContext)

executeWorkflowImpl

public abstract WorkflowExecutionResult executeWorkflowImpl(StepExecutionContext executionContext,
                                          WorkflowExecutionItem item)

executeWFItem

protected StepExecutionResult executeWFItem(StepExecutionContext executionContext,
                                java.util.Map<java.lang.Integer,StepExecutionResult> failedMap,
                                int c,
                                StepExecutionItem cmd)

Execute a workflow item, returns true if the item succeeds. This method will throw an exception if the workflow item fails and the Workflow is has keepgoing==false.

Parameters:

executionContext - context

failedMap - List to add any messages if the item fails

c - index of the WF item

cmd - WF item descriptor

Returns:

true if the execution succeeds, false otherwise

executeWorkflowItemsForNodeSet

protected WorkflowStatusResult executeWorkflowItemsForNodeSet(StepExecutionContext executionContext,
                                                  java.util.Map<java.lang.Integer,StepExecutionResult> failedMap,
                                                  java.util.List<StepExecutionResult> resultList,
                                                  java.util.List<StepExecutionItem> iWorkflowCmdItems,
                                                  boolean keepgoing)

Execute the sequence of ExecutionItems within the context, and with the given keepgoing value

Parameters:

executionContext - context

failedMap - failures

resultList - results

iWorkflowCmdItems - list of steps

keepgoing - true to keepgoing on step failure

Returns:

true if successful

executeWorkflowItemsForNodeSet

protected WorkflowStatusResult executeWorkflowItemsForNodeSet(StepExecutionContext executionContext,
                                                  java.util.Map<java.lang.Integer,StepExecutionResult> failedMap,
                                                  java.util.List<StepExecutionResult> resultList,
                                                  java.util.List<StepExecutionItem> iWorkflowCmdItems,
                                                  boolean keepgoing,
                                                  int beginStepIndex)

Execute the sequence of ExecutionItems within the context, and with the given keepgoing value

Parameters:

executionContext - context

failedMap - failures

resultList - results

iWorkflowCmdItems - list of steps

keepgoing - true to keepgoing on step failure

beginStepIndex - beginning step index

Returns:

true if successful

addStepFailureContextData

protected StepExecutionContext addStepFailureContextData(StepExecutionResult stepResult,
                                             StepExecutionContext handlerExecContext)

Add step result failure information to the data context

Parameters:

stepResult - result

handlerExecContext - context

Returns:

new context

addNodeStepFailureContextData

protected StepExecutionContext addNodeStepFailureContextData(StepExecutionResult dispatcherStepResult,
                                                 StepExecutionContext handlerExecContext)

Add any node-specific step failure information to the node-specific data contexts

Parameters:

dispatcherStepResult - result

handlerExecContext - context

Returns:

new context

replaceFailedNodesListenerInContext

protected StepExecutionContext replaceFailedNodesListenerInContext(StepExecutionContext executionContext,
                                                       FailedNodesListener captureFailedNodesListener)

convertFailures

protected java.util.Map<java.lang.String,java.util.Collection<StepExecutionResult>> convertFailures(java.util.Map<java.lang.Integer,StepExecutionResult> failedMap)

Convert map of step execution results keyed by step number, to a collection of step execution results keyed by node name

Parameters:

failedMap - failures

Returns:

converted

nodeStepResultFromNodeStepException

protected static NodeStepResult nodeStepResultFromNodeStepException(INodeEntry node,
                                                 NodeStepException nodeStepException)

Parameters:

node - node

nodeStepException - exception

Returns:

a failure result with components from an exception

createPrintableDataContext

protected java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>> createPrintableDataContext(java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>> dataContext)

Creates a copy of the given data context with the secure option values obfuscated. This does not modify the original data context. "secureOption" map values will always be obfuscated. "option" entries that are also in "secureOption" will have their values obfuscated. All other maps within the data context will be added directly to the copy.

Parameters:

dataContext - data

Returns:

printable data

createPrintableDataContext

protected java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>> createPrintableDataContext(java.lang.String optionKey,
                                                                                                          java.lang.String secureOptionKey,
                                                                                                          java.lang.String secureOptionValue,
                                                                                                          java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>> dataContext)

Creates a copy of the given data context with the secure option values obfuscated. This does not modify the original data context. "secureOption" map values will always be obfuscated. "option" entries that are also in "secureOption" will have their values obfuscated. All other maps within the data context will be added directly to the copy.

Parameters:

optionKey - key

secureOptionKey - secure key

secureOptionValue - secure value

dataContext - data

Returns:

printable data

executeWorkflowStep

public BaseWorkflowExecutor.StepResultCapture executeWorkflowStep(StepExecutionContext executionContext,
                                                         java.util.Map<java.lang.Integer,StepExecutionResult> failedMap,
                                                         java.util.List<StepExecutionResult> resultList,
                                                         boolean keepgoing,
                                                         WorkflowExecutionListener wlistener,
                                                         int c,
                                                         StepExecutionItem cmd)

Execute a step and handle flow control and error handler.

Parameters:

executionContext - context

failedMap - map for placing failure results

resultList - list of step results

keepgoing - true if the workflow should keepgoing on error

wlistener - listener

c - step number

cmd - step

Returns:

result and flow control