程序包 io.github.code.visual.workflow

类 WorkflowEngine

java.lang.Object

io.github.code.visual.workflow.WorkflowEngine

public class WorkflowEngine
extends Object

Core workflow execution engine.

This is the main class users interact with to execute workflows programmatically. Inject it as a Spring Bean and call execute(java.lang.Integer, java.util.Map) or debug(io.github.code.visual.model.DebugRequest).

从以下版本开始:

09/18/2023

作者:

Levi Li

构造器概要

构造器

构造器	说明
WorkflowEngine(org.codehaus.groovy.control.CompilerConfiguration compilerConfig, WorkflowRepository repository, VisualFlowProperties properties, List<WorkflowExecutionListener> listeners)

方法概要

修饰符和类型	方法	说明
List<Diagnostic>	compileScript(String code)	Compile and validate Groovy code without executing it.
WorkflowMetadata	createWorkflow(WorkflowMetadata metadata)
Map<Integer,List<WorkflowTaskLog>>	debug(DebugRequest debugRequest)	Debug a workflow with provided script metadata and input values.
Map<Integer,List<WorkflowTaskLog>>	debug(DebugRequest debugRequest, Consumer<WorkflowTaskLog> onNodeComplete)	Debug a workflow with streaming callback.
void	deleteWorkflow(Integer workflowId)
Map<Integer,List<WorkflowTaskLog>>	execute(Integer workflowId, Map inputVariables)	Execute a workflow by ID.
Map<Integer,List<WorkflowTaskLog>>	execute(String workflowName, Map inputVariables)	Execute a workflow by name.
WorkflowMetadata	getWorkflow(Integer workflowId)
WorkflowMetadata	updateWorkflow(WorkflowMetadata metadata)

从类继承的方法 java.lang.Object

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

构造器详细资料

WorkflowEngine

public WorkflowEngine(org.codehaus.groovy.control.CompilerConfiguration compilerConfig,
 WorkflowRepository repository,
 VisualFlowProperties properties,
 List<WorkflowExecutionListener> listeners)

方法详细资料

execute

public Map<Integer,List<WorkflowTaskLog>> execute(Integer workflowId,
 Map inputVariables)

Execute a workflow by ID.

execute

public Map<Integer,List<WorkflowTaskLog>> execute(String workflowName,
 Map inputVariables)

Execute a workflow by name.

debug

public Map<Integer,List<WorkflowTaskLog>> debug(DebugRequest debugRequest)

Debug a workflow with provided script metadata and input values.

debug

public Map<Integer,List<WorkflowTaskLog>> debug(DebugRequest debugRequest,
 Consumer<WorkflowTaskLog> onNodeComplete)

Debug a workflow with streaming callback. Each node execution result is pushed to the callback in real-time. If breakpointNodeId is set, execution stops after that node completes.

compileScript

public List<Diagnostic> compileScript(String code)

Compile and validate Groovy code without executing it. Returns errors and warnings from the Groovy compiler.

createWorkflow

public WorkflowMetadata createWorkflow(WorkflowMetadata metadata)

getWorkflow

public WorkflowMetadata getWorkflow(Integer workflowId)

updateWorkflow

public WorkflowMetadata updateWorkflow(WorkflowMetadata metadata)

deleteWorkflow

public void deleteWorkflow(Integer workflowId)