Package com.dtolabs.rundeck.core.execution

Class ExecutionServiceImpl

java.lang.Object

com.dtolabs.rundeck.core.execution.ExecutionServiceImpl

All Implemented Interfaces:

FrameworkSupportService, ExecutionService, NodeExecutionService, AppService

public class ExecutionServiceImpl
extends java.lang.Object
implements ExecutionService

NewExecutionServiceImpl is ...

Field Summary

Fields inherited from interface com.dtolabs.rundeck.core.execution.ExecutionService

SERVICE_NAME

Constructor Summary

Constructors

Constructor	Description
ExecutionServiceImpl()

Method Summary

Modifier and Type	Method	Description
DispatcherResult	dispatchToNodes(StepExecutionContext context, Dispatchable item)	Dispatch the command (execution item) to all the nodes within the context.
DispatcherResult	dispatchToNodes(StepExecutionContext context, NodeStepExecutionItem item)	Dispatch the command (execution item) to all the nodes within the context.
NodeExecutorResult	executeCommand(ExecutionContext context, ExecArgList command, INodeEntry node)	Execute a command within the context on the node.
NodeExecutorResult	executeCommand(ExecutionContext context, ExecArgList command, java.io.InputStream inputStream, INodeEntry node)	Execute a command within the context on the node.
NodeExecutorResult	executeCommand(ExecutionContext context, java.lang.String[] command, INodeEntry node)	Execute a command within the context on the node.
NodeStepResult	executeNodeStep(StepExecutionContext context, NodeStepExecutionItem item, INodeEntry node)	Interpret the execution item within the context for the given node.
StepExecutionResult	executeStep(StepExecutionContext context, StepExecutionItem item)	Execute a workflow step item for the given context and return the result.
java.lang.String	fileCopyFile(ExecutionContext context, java.io.File file, INodeEntry node, java.lang.String destinationPath)	Copy file to the node to a specific path
java.lang.String[]	fileCopyFiles(ExecutionContext context, java.io.File basedir, java.util.List<java.io.File> files, java.lang.String remotePath, INodeEntry node)	Copy multiple files to the node to a specific path
java.lang.String	fileCopyFileStream(ExecutionContext context, java.io.InputStream input, INodeEntry node, java.lang.String destinationPath)	Copy inputstream as a file to the node to a specific path
java.lang.String	fileCopyScriptContent(ExecutionContext context, java.lang.String script, INodeEntry node, java.lang.String destinationPath)	Copy string as a file to the node to a specific path
java.lang.String	getName()
protected WorkflowExecutionListener	getWorkflowListener(ExecutionContext executionContext)

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecutionServiceImpl

public ExecutionServiceImpl()

Method Detail

getWorkflowListener

protected WorkflowExecutionListener getWorkflowListener(ExecutionContext executionContext)

executeStep

public StepExecutionResult executeStep(StepExecutionContext context,
                                       StepExecutionItem item)
                                throws StepException

Description copied from interface: ExecutionService

Execute a workflow step item for the given context and return the result.

Specified by:

executeStep in interface ExecutionService

Parameters:

context - context

item - item

Returns:

not-null result

Throws:

StepException - on error

executeNodeStep

public NodeStepResult executeNodeStep(StepExecutionContext context,
                                      NodeStepExecutionItem item,
                                      INodeEntry node)
                               throws NodeStepException

Description copied from interface: ExecutionService

Interpret the execution item within the context for the given node.

Specified by:

executeNodeStep in interface ExecutionService

Parameters:

context - context

item - step item

node - node

Returns:

result

Throws:

NodeStepException - on error

dispatchToNodes

public DispatcherResult dispatchToNodes(StepExecutionContext context,
                                        NodeStepExecutionItem item)
                                 throws DispatcherException,
                                        ExecutionServiceException

Description copied from interface: ExecutionService

Dispatch the command (execution item) to all the nodes within the context.

Specified by:

dispatchToNodes in interface ExecutionService

Parameters:

context - context

item - step item

Returns:

result

Throws:

DispatcherException - on dispatch error

ExecutionServiceException - on service error

dispatchToNodes

public DispatcherResult dispatchToNodes(StepExecutionContext context,
                                        Dispatchable item)
                                 throws DispatcherException,
                                        ExecutionServiceException

Description copied from interface: ExecutionService

Dispatch the command (execution item) to all the nodes within the context.

Specified by:

dispatchToNodes in interface ExecutionService

Parameters:

context - context

item - step item

Returns:

result

Throws:

DispatcherException - on dispatch error

ExecutionServiceException - on service error

fileCopyFileStream

public java.lang.String fileCopyFileStream(ExecutionContext context,
                                           java.io.InputStream input,
                                           INodeEntry node,
                                           java.lang.String destinationPath)
                                    throws FileCopierException

Description copied from interface: ExecutionService

Copy inputstream as a file to the node to a specific path

Specified by:

fileCopyFileStream in interface ExecutionService

Specified by:

fileCopyFileStream in interface NodeExecutionService

Parameters:

context - context

input - input stream

node - node

destinationPath - destination path

Returns:

filepath on the node for the destination file.

Throws:

FileCopierException - on error

fileCopyFile

public java.lang.String fileCopyFile(ExecutionContext context,
                                     java.io.File file,
                                     INodeEntry node,
                                     java.lang.String destinationPath)
                              throws FileCopierException

Description copied from interface: ExecutionService

Copy file to the node to a specific path

Specified by:

fileCopyFile in interface ExecutionService

Specified by:

fileCopyFile in interface NodeExecutionService

Parameters:

context - context

file - input file

node - node

destinationPath - destination path

Returns:

filepath

Throws:

FileCopierException - on error

fileCopyFiles

public java.lang.String[] fileCopyFiles(ExecutionContext context,
                                        java.io.File basedir,
                                        java.util.List<java.io.File> files,
                                        java.lang.String remotePath,
                                        INodeEntry node)
                                 throws FileCopierException

Description copied from interface: ExecutionService

Copy multiple files to the node to a specific path

Specified by:

fileCopyFiles in interface ExecutionService

Parameters:

context - context

basedir - base directory for copied files

files - array of input files

remotePath - remote path destination for files

node - node

Returns:

list of copied paths from the remote node

Throws:

FileCopierException - on error

fileCopyScriptContent

public java.lang.String fileCopyScriptContent(ExecutionContext context,
                                              java.lang.String script,
                                              INodeEntry node,
                                              java.lang.String destinationPath)
                                       throws FileCopierException

Description copied from interface: ExecutionService

Copy string as a file to the node to a specific path

Specified by:

fileCopyScriptContent in interface ExecutionService

Parameters:

context - context

script - script string

node - node

destinationPath - destination path

Returns:

filepath for the copied file on the node

Throws:

FileCopierException - on error

executeCommand

public NodeExecutorResult executeCommand(ExecutionContext context,
                                         java.lang.String[] command,
                                         INodeEntry node)

Description copied from interface: ExecutionService

Execute a command within the context on the node.

Specified by:

executeCommand in interface ExecutionService

Parameters:

context - context

command - command strings

node - node

Returns:

result

executeCommand

public NodeExecutorResult executeCommand(ExecutionContext context,
                                         ExecArgList command,
                                         INodeEntry node)

Description copied from interface: ExecutionService

Execute a command within the context on the node.

Specified by:

executeCommand in interface ExecutionService

Specified by:

executeCommand in interface NodeExecutionService

Parameters:

context - context

command - command

node - node

Returns:

result

executeCommand

public NodeExecutorResult executeCommand(ExecutionContext context,
                                         ExecArgList command,
                                         java.io.InputStream inputStream,
                                         INodeEntry node)

Description copied from interface: ExecutionService

Execute a command within the context on the node.

Specified by:

executeCommand in interface ExecutionService

Parameters:

context - context

command - command

inputStream - input to the process

node - node

Returns:

result

getName

public java.lang.String getName()

Specified by:

getName in interface FrameworkSupportService

Returns:

the name used to identify the service