bpmn_engine

Documentation

Index

• type ActivatedJob
• type BpmnEngine
• type BpmnEngineError
  • func (e *BpmnEngineError) Error() string
• type BpmnEngineState
  • func New(name string) BpmnEngineState
  • func (state *BpmnEngineState) AddEventExporter(exporter exporter.EventExporter)
  • func (state *BpmnEngineState) AddTaskHandler(taskId string, handler func(job ActivatedJob))
  • func (state *BpmnEngineState) CreateAndRunInstance(processKey int64, variableContext map[string]interface{}) (*ProcessInstanceInfo, error)
  • func (state *BpmnEngineState) CreateInstance(processKey int64, variableContext map[string]interface{}) (*ProcessInstanceInfo, error)
  • func (state *BpmnEngineState) FindProcessInstanceById(processInstanceKey int64) *ProcessInstanceInfo
  • func (state *BpmnEngineState) GetMessageSubscriptions() []MessageSubscription
  • func (state *BpmnEngineState) GetName() string
  • func (state *BpmnEngineState) GetProcessInstances() []*ProcessInstanceInfo
  • func (state *BpmnEngineState) LoadFromBytes(xmlData []byte) (*ProcessInfo, error)
  • func (state *BpmnEngineState) LoadFromFile(filename string) (*ProcessInfo, error)
  • func (state *BpmnEngineState) PublishEventForInstance(processInstanceKey int64, messageName string) error
  • func (state *BpmnEngineState) RunOrContinueInstance(processInstanceKey int64) (*ProcessInstanceInfo, error)
• type CatchEvent
• type MessageSubscription
• type ProcessInfo
• type ProcessInstance
• type ProcessInstanceInfo
  • func (pii *ProcessInstanceInfo) GetCreatedAt() time.Time
  • func (pii *ProcessInstanceInfo) GetInstanceKey() int64
  • func (pii *ProcessInstanceInfo) GetProcessInfo() *ProcessInfo
  • func (pii *ProcessInstanceInfo) GetState() process_instance.State
  • func (pii *ProcessInstanceInfo) GetVariable(key string) interface{}
  • func (pii *ProcessInstanceInfo) Purge()
  • func (pii *ProcessInstanceInfo) SetVariable(key string, value interface{})
• type Timer
• type TimerState

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"
)