engine

Documentation

Index

• func ContinuePIByKey(ctx context.Context, piKey string) (engine_types.ProcessInstance, error)
• func CreatePIByByte(raw []byte, variables map[string]any) (engine_types.ProcessInstance, error)
• func CreatePIByID(processID string, variables map[string]any) (engine_types.ProcessInstance, error)
• func CreatePIByIDAndRun(ctx context.Context, processID string, variables map[string]any) (engine_types.ProcessInstance, error)
• func Engine() *engineContext
• func GetProcess(processID string) engine_types.Process
• func GetServiceTaskHandler(taskType string) (engine_types.TaskHandler, error)
• func LoadFromEmbed(myfs *embed.FS) error
• func LoadProcessInstance[T engine_types.ProcessInstance](raw []byte) (engine_types.ProcessInstance, error)
• func PublishEventForInstanceContinue(ctx context.Context, piKey string, messageName string, ...) (engine_types.ProcessInstance, error)
• func RegisterPICreateHandler(handler createHandler)
• func RegisterServiceTaskHandler(taskType string, fun engine_types.TaskHandler)
• func SaveProcessInstance(pi engine_types.ProcessInstance) ([]byte, error)

Functions

func ContinuePIByKey

func ContinuePIByKey(ctx context.Context, piKey string) (engine_types.ProcessInstance, error)

func CreatePIByByte

func CreatePIByByte(raw []byte, variables map[string]any) (engine_types.ProcessInstance, error)

创建新的流程实例

func CreatePIByID

func CreatePIByID(processID string, variables map[string]any) (engine_types.ProcessInstance, error)

通过流程ID创建实例

func CreatePIByIDAndRun

func CreatePIByIDAndRun(ctx context.Context, processID string, variables map[string]any) (engine_types.ProcessInstance, error)

func Engine

func Engine() *engineContext

func GetProcess

func GetProcess(processID string) engine_types.Process

获取流程

func GetServiceTaskHandler

func GetServiceTaskHandler(taskType string) (engine_types.TaskHandler, error)

获取 Servcie Task 元素处理函数

func LoadFromEmbed

func LoadFromEmbed(myfs *embed.FS) error

通过嵌入资源

func LoadProcessInstance

func LoadProcessInstance[T engine_types.ProcessInstance](raw []byte) (engine_types.ProcessInstance, error)

导入json文件

func PublishEventForInstanceContinue

func PublishEventForInstanceContinue(
	ctx context.Context,
	piKey string,
	messageName string,
	variables map[string]any,
) (engine_types.ProcessInstance, error)

基于消息名称对流程进行重启

func RegisterPICreateHandler

func RegisterPICreateHandler(handler createHandler)

注册

func RegisterServiceTaskHandler

func RegisterServiceTaskHandler(taskType string, fun engine_types.TaskHandler)

注册 Servcie Task 元素处理函数

func SaveProcessInstance

func SaveProcessInstance(pi engine_types.ProcessInstance) ([]byte, error)

保存为json文件