memory_process_instance

package
v0.0.0-...-c54ede3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 26, 2023 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func New

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

Types

type ProcessInstance

type ProcessInstance struct {
	Raw                        []byte                                            `json:"raw"`                         // 流程内容
	State                      sepc_pi_types.State                               `json:"state"`                       // 流程实例状态
	Key                        string                                            `json:"key"`                         // 流程实例唯一Key
	Variables                  map[string]any                                    `json:"variables"`                   // 流程实例上下文
	ScheduledFlows             []string                                          `json:"scheduled_flows"`             // 流程序列流
	ElementManager             *memory_element_manager.ElementManager            `json:"element_manager"`             // 阻塞元素管理
	MessageSubscriptionManager *memory_msgsub_manager.MessageSubscriptionManager `json:"msgsub_manager"`              // 消息订阅
	ParentProcessInstanceKey   string                                            `json:"parent_process_instance_key"` // 父级流程实例Key
	// contains filtered or unexported fields
}

pi *ProcessInstance github.com/averyyan/bpmn-engine/bpmn/engine/types.ProcessInstance

func (*ProcessInstance) AppendScheduledFlow

func (pi *ProcessInstance) AppendScheduledFlow(ctx context.Context, flowID string) error

添加flowID到ScheduledFlows 处理并行网关使用

func (*ProcessInstance) GetDefinitions

func (pi *ProcessInstance) GetDefinitions() (*definitions.TDefinitions, error)

获取流程详情

func (*ProcessInstance) GetElementManager

func (pi *ProcessInstance) GetElementManager() engine_types.ElementManager

获取阻塞元素管理

func (*ProcessInstance) GetKey

func (pi *ProcessInstance) GetKey() string

获取流程唯一Key

func (*ProcessInstance) GetMessageSubscriptionManager

func (pi *ProcessInstance) GetMessageSubscriptionManager() engine_types.MessageSubscriptionManager

获取消息订阅管理

func (*ProcessInstance) GetParentProcessInstanceKey

func (pi *ProcessInstance) GetParentProcessInstanceKey() string

获取父级流程实例Key

func (*ProcessInstance) GetScheduledFlows

func (pi *ProcessInstance) GetScheduledFlows(ctx context.Context) []string

获取

func (*ProcessInstance) GetState

func (pi *ProcessInstance) GetState() sepc_pi_types.State

获取流程实例状态

func (*ProcessInstance) GetVariables

func (pi *ProcessInstance) GetVariables() map[string]any

获取流程实例全局上下文

func (*ProcessInstance) HasScheduledFlow

func (pi *ProcessInstance) HasScheduledFlow(ctx context.Context, flowID string) bool

判断是否存在

func (*ProcessInstance) RemoveScheduledFlow

func (pi *ProcessInstance) RemoveScheduledFlow(ctx context.Context, flowID string) error

删除flowID到ScheduledFlows 处理并行网关使用

func (*ProcessInstance) SetActive

func (pi *ProcessInstance) SetActive(ctx context.Context) error

设置流程实例为激活状态

func (*ProcessInstance) SetCompleted

func (pi *ProcessInstance) SetCompleted(ctx context.Context) error

设置流程实例为完成状态

func (*ProcessInstance) SetFailed

func (pi *ProcessInstance) SetFailed(ctx context.Context) error

设置流程实例为失败状态

func (*ProcessInstance) SetParentProcessInstanceKey

func (pi *ProcessInstance) SetParentProcessInstanceKey(ctx context.Context, key string) error

设置父级流程实例

func (*ProcessInstance) SetVariables

func (pi *ProcessInstance) SetVariables(variables map[string]any) error

设置上下文参数

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL