bpmn_engine

package
v0.2.4 Latest Latest
Warning

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

 Go to latest Published: Sep 20, 2023 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ActivatedJob 

type ActivatedJob interface {
	ProcessInstance

	// Get job unique key
	GetKey() int64

	GetProcessInstanceKey() int64

	GetBpmnProcessId() string

	// the version of the job process definition
	GetProcessDefinitionVersion() int32

	// the key of the job process definition
	GetProcessDefinitionKey() int64

	// Get element id of the job
	GetElementId() string

	// Fail marks the job to fail
	Fail(reason string)

	// Complete mark the job to succeed
	Complete()
}

ActivatedJob represents an abstraction for the activated job don't forget to call Fail or Complete when your task worker job is complete or not.

type BpmnEngine 

type BpmnEngine interface {
	LoadFromFile(filename string) (*ProcessInfo, error)
	LoadFromBytes(xmlData []byte) (*ProcessInfo, error)
	AddTaskHandler(taskId string, handler func(job ActivatedJob))
	CreateInstance(processKey int64, variableContext map[string]interface{}) (*ProcessInstanceInfo, error)
	CreateAndRunInstance(processKey int64, variableContext map[string]interface{}) (*ProcessInstanceInfo, error)
	RunOrContinueInstance(processInstanceKey int64) (*ProcessInstanceInfo, error)
	GetName() string
	GetProcessInstances() []*ProcessInstanceInfo
	FindProcessInstanceById(processInstanceKey int64) *ProcessInstanceInfo
}

type BpmnEngineError 

type BpmnEngineError struct {
	Msg string
}

func (*BpmnEngineError) Error 

func (e *BpmnEngineError) Error() string

type BpmnEngineState 

type BpmnEngineState struct {
	// contains filtered or unexported fields
}

func New 

func New(name string) BpmnEngineState

New creates an engine with an arbitrary name of the engine; useful in case you have multiple ones, in order to distinguish them.

func (*BpmnEngineState) AddEventExporter 

func (state *BpmnEngineState) AddEventExporter(exporter exporter.EventExporter)

AddEventExporter registers an EventExporter instance

func (*BpmnEngineState) AddTaskHandler 

func (state *BpmnEngineState) AddTaskHandler(taskId string, handler func(job ActivatedJob))

AddTaskHandler registers a handler function to be called for service tasks with a given taskId

func (*BpmnEngineState) CreateAndRunInstance 

func (state *BpmnEngineState) CreateAndRunInstance(processKey int64, variableContext map[string]interface{}) (*ProcessInstanceInfo, error)

CreateAndRunInstance creates a new instance and executes it immediately. The provided variableContext can be nil or refers to a variable map, which is provided to every service task handler function.

func (*BpmnEngineState) CreateInstance 

func (state *BpmnEngineState) CreateInstance(processKey int64, variableContext map[string]interface{}) (*ProcessInstanceInfo, error)

CreateInstance creates a new instance for a process with given processKey will return (nil, nil), when no process with given was found

func (*BpmnEngineState) FindProcessInstanceById 

func (state *BpmnEngineState) FindProcessInstanceById(processInstanceKey int64) *ProcessInstanceInfo

FindProcessInstanceById searches for a give processInstanceKey and returns the corresponding ProcessInstanceInfo otherwise nil

func (*BpmnEngineState) GetMessageSubscriptions 

func (state *BpmnEngineState) GetMessageSubscriptions() []MessageSubscription

func (*BpmnEngineState) GetName 

func (state *BpmnEngineState) GetName() string

GetName returns the name of the engine, only useful in case you control multiple ones

func (*BpmnEngineState) GetProcessInstances 

func (state *BpmnEngineState) GetProcessInstances() []*ProcessInstanceInfo

GetProcessInstances returns a list of instance information.

func (*BpmnEngineState) LoadFromBytes 

func (state *BpmnEngineState) LoadFromBytes(xmlData []byte) (*ProcessInfo, error)

LoadFromBytes loads a given BPMN file by xmlData byte array into the engine and returns ProcessInfo details for the deployed workflow

func (*BpmnEngineState) LoadFromFile 

func (state *BpmnEngineState) LoadFromFile(filename string) (*ProcessInfo, error)

LoadFromFile loads a given BPMN file by filename into the engine and returns ProcessInfo details for the deployed workflow

func (*BpmnEngineState) PublishEventForInstance 

func (state *BpmnEngineState) PublishEventForInstance(processInstanceKey int64, messageName string) error

func (*BpmnEngineState) RunOrContinueInstance 

func (state *BpmnEngineState) RunOrContinueInstance(processInstanceKey int64) (*ProcessInstanceInfo, error)

RunOrContinueInstance runs or continues a process instance by a given processInstanceKey. returns the process instances, when found does nothing, if process is already in ProcessInstanceCompleted State returns nil, when no process instance was found Additionally, every time this method is called, former completed instances are 'garbage collected'.

type CatchEvent 

type CatchEvent struct {
	Name       string
	CaughtAt   time.Time
	IsConsumed bool
}

type MessageSubscription 

type MessageSubscription struct {
	ElementId          string
	ElementInstanceKey int64
	ProcessInstanceKey int64
	Name               string
	State              activity.LifecycleState
	CreatedAt          time.Time
}

type ProcessInfo 

type ProcessInfo struct {
	BpmnProcessId string // The ID as defined in the BPMN file
	Version       int32  // A version of the process, default=1, incremented, when another process with the same ID is loaded
	ProcessKey    int64  // The engines key for this given process with version
	// contains filtered or unexported fields
}

type ProcessInstance 

type ProcessInstance interface {
	GetProcessInfo() *ProcessInfo
	GetInstanceKey() int64
	GetVariable(key string) interface{}
	SetVariable(key string, value interface{})
	GetCreatedAt() time.Time
	GetState() process_instance.State
	Purge()
}

type ProcessInstanceInfo 

type ProcessInstanceInfo struct {
	// contains filtered or unexported fields
}

func (*ProcessInstanceInfo) GetCreatedAt 

func (pii *ProcessInstanceInfo) GetCreatedAt() time.Time

func (*ProcessInstanceInfo) GetInstanceKey 

func (pii *ProcessInstanceInfo) GetInstanceKey() int64

func (*ProcessInstanceInfo) GetProcessInfo 

func (pii *ProcessInstanceInfo) GetProcessInfo() *ProcessInfo

func (*ProcessInstanceInfo) GetState 

func (pii *ProcessInstanceInfo) GetState() process_instance.State

GetState returns one of [ProcessInstanceReady,ProcessInstanceActive,ProcessInstanceCompleted] 

┌─────┐
│Ready│
└──┬──┘

┌───▽──┐ │Active│ └───┬──┘ ┌────▽────┐ │Completed│ └─────────┘

func (*ProcessInstanceInfo) GetVariable 

func (pii *ProcessInstanceInfo) GetVariable(key string) interface{}

func (*ProcessInstanceInfo) Purge 

func (pii *ProcessInstanceInfo) Purge()

func (*ProcessInstanceInfo) SetVariable 

func (pii *ProcessInstanceInfo) SetVariable(key string, value interface{})

type Timer 

type Timer struct {
	ElementId          string
	ElementInstanceKey int64
	ProcessInstanceKey int64
	State              TimerState
	CreatedAt          time.Time
	DueDate            time.Time
}

type TimerState 

type TimerState string
const (
	TimerCreated   TimerState = "CREATED"
	TimerTriggered TimerState = "TRIGGERED"
	TimerCancelled TimerState = "CANCELLED"
)

Source Files

View all Source files

Directories

Path Synopsis
zeebe

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.