Versions in this module Expand all Collapse all v0 v0.0.2 Jul 31, 2025 Changes in this version + const CurrentSerializerVersion + type ActivatedJob interface + BpmnProcessId func() string + Complete func() + CreatedAt func() time.Time + ElementId func() string + Fail func(reason string) + InstanceKey func() int64 + Key func() int64 + ProcessDefinitionKey func() int64 + ProcessDefinitionVersion func() int32 + ProcessInstanceKey func() int64 + SetVariable func(key string, value interface{}) + Variable func(key string) interface{} + type ActivityState string + const Active + const Compensated + const Compensating + const Completed + const Completing + const Failed + const Failing + const Ready + const Terminated + const Terminating + const Withdrawn + type BpmnEngine interface + CreateAndRunInstance func(processKey int64, variableContext map[string]interface{}) (*processInstanceInfo, error) + CreateAndRunInstanceById func(processId string, variableContext map[string]interface{}) (*processInstanceInfo, error) + CreateInstance func(processKey int64, variableContext map[string]interface{}) (*processInstanceInfo, error) + CreateInstanceById func(processId string, variableContext map[string]interface{}) (*processInstanceInfo, error) + FindProcessInstance func(processInstanceKey int64) *processInstanceInfo + FindProcessesById func(id string) []*ProcessInfo + LoadFromBytes func(xmlData []byte) (*ProcessInfo, error) + LoadFromFile func(filename string) (*ProcessInfo, error) + Name func() string + NewTaskHandler func() NewTaskHandlerCommand1 + ProcessInstances func() []*processInstanceInfo + RunOrContinueInstance func(processInstanceKey int64) (*processInstanceInfo, error) + type BpmnEngineError struct + Msg string + func (e *BpmnEngineError) Error() string + type BpmnEngineState struct + func New() BpmnEngineState + func NewWithName(name string) BpmnEngineState + func Unmarshal(data []byte) (BpmnEngineState, error) + func (state *BpmnEngineState) AddEventExporter(exporter exporter.EventExporter) + func (state *BpmnEngineState) CreateAndRunInstance(processKey int64, variableContext map[string]interface{}) (*processInstanceInfo, error) + func (state *BpmnEngineState) CreateAndRunInstanceById(processId string, variableContext map[string]interface{}) (*processInstanceInfo, error) + func (state *BpmnEngineState) CreateInstance(processKey int64, variableContext map[string]interface{}) (*processInstanceInfo, error) + func (state *BpmnEngineState) CreateInstanceById(processId string, variableContext map[string]interface{}) (*processInstanceInfo, error) + func (state *BpmnEngineState) FindProcessInstance(processInstanceKey int64) *processInstanceInfo + func (state *BpmnEngineState) FindProcessesById(id string) (infos []*ProcessInfo) + func (state *BpmnEngineState) GetMessageSubscriptions() []MessageSubscription + func (state *BpmnEngineState) GetTimersScheduled() []Timer + func (state *BpmnEngineState) LoadFromBytes(xmlData []byte) (*ProcessInfo, error) + func (state *BpmnEngineState) LoadFromFile(filename string) (*ProcessInfo, error) + func (state *BpmnEngineState) Marshal() []byte + func (state *BpmnEngineState) Name() string + func (state *BpmnEngineState) NewTaskHandler() NewTaskHandlerCommand1 + func (state *BpmnEngineState) ProcessInstances() []*processInstanceInfo + func (state *BpmnEngineState) PublishEventForInstance(processInstanceKey int64, messageName string, variables map[string]interface{}) error + func (state *BpmnEngineState) RunOrContinueInstance(processInstanceKey int64) (*processInstanceInfo, error) + type BpmnEngineUnmarshallingError struct + Err error + Msg string + func (e *BpmnEngineUnmarshallingError) Error() string + type ExpressionEvaluationError struct + Err error + Msg string + func (e *ExpressionEvaluationError) Error() string + type MessageSubscription struct + CreatedAt time.Time + ElementId string + ElementInstanceKey int64 + MessageState ActivityState + Name string + ProcessInstanceKey int64 + ProcessKey int64 + func (m *MessageSubscription) MarshalJSON() ([]byte, error) + func (m *MessageSubscription) SetState(state ActivityState) + func (m *MessageSubscription) UnmarshalJSON(data []byte) error + func (m MessageSubscription) Element() *BPMN20.BaseElement + func (m MessageSubscription) Key() int64 + func (m MessageSubscription) State() ActivityState + type NewTaskHandlerCommand1 interface + Assignee func(assignee string) NewTaskHandlerCommand2 + CandidateGroups func(groups ...string) NewTaskHandlerCommand2 + Id func(id string) NewTaskHandlerCommand2 + Type func(taskType string) NewTaskHandlerCommand2 + type NewTaskHandlerCommand2 interface + Handler func(func(job ActivatedJob)) + type ProcessInfo struct + BpmnProcessId string + ProcessKey int64 + Version int32 + type ProcessInstance interface + GetCreatedAt func() time.Time + GetInstanceKey func() int64 + GetProcessInfo func() *ProcessInfo + GetState func() ActivityState + GetVariable func(key string) interface{} + SetVariable func(key string, value interface{}) + type ProcessInstanceInfoAlias processInstanceInfo + type Timer struct + CreatedAt time.Time + DueAt time.Time + Duration time.Duration + ElementId string + ElementInstanceKey int64 + ProcessInstanceKey int64 + ProcessKey int64 + TimerState TimerState + func (t *Timer) MarshalJSON() ([]byte, error) + func (t *Timer) SetState(state ActivityState) + func (t *Timer) UnmarshalJSON(data []byte) error + func (t Timer) Element() *BPMN20.BaseElement + func (t Timer) Key() int64 + func (t Timer) State() ActivityState + type TimerState string + const TimerCancelled + const TimerCreated + const TimerTriggered + type VariableHolder struct + func NewVarHolder(parent *VariableHolder, variables map[string]interface{}) VariableHolder + func (vh *VariableHolder) GetVariable(key string) interface{} + func (vh *VariableHolder) MarshalJSON() ([]byte, error) + func (vh *VariableHolder) PropagateVariable(key string, value interface{}) + func (vh *VariableHolder) SetVariable(key string, val interface{}) + func (vh *VariableHolder) UnmarshalJSON(data []byte) error + func (vh *VariableHolder) Variables() map[string]interface{}