behavior

package
v0.0.5 Latest Latest
Warning

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

 Go to latest Published: Feb 9, 2025 License: MIT Imports: 23 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	NUMBER_OF_INSTANCES            string = "nrOfInstances"
	NUMBER_OF_ACTIVE_INSTANCES     string = "nrOfActiveInstances"
	NUMBER_OF_COMPLETED_INSTANCES  string = "nrOfCompletedInstances"
	DELETE_REASON_END              string = "MI_END"
	CollectionElementIndexVariable string = "loopCounter"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type AbstractMultiInstanceActivityBehavior added in v0.0.5 

type AbstractMultiInstanceActivityBehavior struct {
	Impl multiInstanceActivityBehavior
	// Instance members
	Activity              MultiInstanceActivity
	InnerActivityBehavior MultiInstanceSupportBehavior
	// contains filtered or unexported fields
}

AbstractMultiInstanceActivityBehavior Implementation of the multi-instance functionality as described in the BPMN 2.0 spec.

func (AbstractMultiInstanceActivityBehavior) Execute added in v0.0.5 

func (f AbstractMultiInstanceActivityBehavior) Execute(execution delegate.DelegateExecution) error

func (AbstractMultiInstanceActivityBehavior) ExecuteOriginalBehavior added in v0.0.5 

func (f AbstractMultiInstanceActivityBehavior) ExecuteOriginalBehavior(execution delegate.DelegateExecution, multiInstanceRootExecution delegate.DelegateExecution, loopCounter int) error

func (AbstractMultiInstanceActivityBehavior) Trigger added in v0.0.5 

func (f AbstractMultiInstanceActivityBehavior) Trigger(execution delegate.DelegateExecution) error

type ExclusiveGatewayActivityBehavior 

type ExclusiveGatewayActivityBehavior struct {
}

func (ExclusiveGatewayActivityBehavior) Execute 

func (exclusive ExclusiveGatewayActivityBehavior) Execute(execution delegate.DelegateExecution) (err error)

排他网关

func (ExclusiveGatewayActivityBehavior) Leave 

func (exclusive ExclusiveGatewayActivityBehavior) Leave(execution delegate.DelegateExecution) (err error)

type HttpServiceTaskActivityBehavior added in v0.0.3 

type HttpServiceTaskActivityBehavior struct {
	ServiceTask model.ServiceTask
	ProcessKey  string
	// contains filtered or unexported fields
}

func (HttpServiceTaskActivityBehavior) Execute added in v0.0.3 

func (user HttpServiceTaskActivityBehavior) Execute(execution delegate.DelegateExecution) error

Execute TODO

func (HttpServiceTaskActivityBehavior) MultiInstanceActivityBehavior added in v0.0.3 

func (f HttpServiceTaskActivityBehavior) MultiInstanceActivityBehavior() multiInstanceActivityBehavior

func (*HttpServiceTaskActivityBehavior) SetMultiInstanceActivityBehavior added in v0.0.3 

func (f *HttpServiceTaskActivityBehavior) SetMultiInstanceActivityBehavior(multiInstanceActivityBehavior multiInstanceActivityBehavior)

type InclusiveGatewayActivityBehavior 

type InclusiveGatewayActivityBehavior struct {
}

func (InclusiveGatewayActivityBehavior) Execute 

func (exclusive InclusiveGatewayActivityBehavior) Execute(execution delegate.DelegateExecution) error

包容网关

func (InclusiveGatewayActivityBehavior) Leave 

func (exclusive InclusiveGatewayActivityBehavior) Leave(execution delegate.DelegateExecution) error

执行逻辑：获取当前所有执行的节点，判断是否可达当前网关可以停止执行，等待完成

type IntermediateCatchConditionalEventActivityBehavior 

type IntermediateCatchConditionalEventActivityBehavior struct {
	IntermediateCatchEventActivityBehavior
	// contains filtered or unexported fields
}

func NewIntermediateCatchConditionalEventActivityBehavior 

func NewIntermediateCatchConditionalEventActivityBehavior(conditionalEventDefinition model.ConditionalEventDefinition) *IntermediateCatchConditionalEventActivityBehavior

func (*IntermediateCatchConditionalEventActivityBehavior) ConditionalEventDefinition 

func (behavior *IntermediateCatchConditionalEventActivityBehavior) ConditionalEventDefinition() model.ConditionalEventDefinition

func (IntermediateCatchConditionalEventActivityBehavior) Execute 

func (behavior IntermediateCatchConditionalEventActivityBehavior) Execute(execution delegate.DelegateExecution) error

func (IntermediateCatchConditionalEventActivityBehavior) MultiInstanceActivityBehavior 

func (f IntermediateCatchConditionalEventActivityBehavior) MultiInstanceActivityBehavior() multiInstanceActivityBehavior

func (*IntermediateCatchConditionalEventActivityBehavior) SetConditionalEventDefinition 

func (behavior *IntermediateCatchConditionalEventActivityBehavior) SetConditionalEventDefinition(conditionalEventDefinition model.ConditionalEventDefinition)

func (*IntermediateCatchConditionalEventActivityBehavior) SetMultiInstanceActivityBehavior 

func (f *IntermediateCatchConditionalEventActivityBehavior) SetMultiInstanceActivityBehavior(multiInstanceActivityBehavior multiInstanceActivityBehavior)

func (IntermediateCatchConditionalEventActivityBehavior) Trigger 

func (behavior IntermediateCatchConditionalEventActivityBehavior) Trigger(execution delegate.DelegateExecution) error

type IntermediateCatchEventActivityBehavior 

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

func (IntermediateCatchEventActivityBehavior) Execute 

func (f IntermediateCatchEventActivityBehavior) Execute(execution delegate.DelegateExecution) error

func (IntermediateCatchEventActivityBehavior) MultiInstanceActivityBehavior 

func (f IntermediateCatchEventActivityBehavior) MultiInstanceActivityBehavior() multiInstanceActivityBehavior

func (*IntermediateCatchEventActivityBehavior) SetMultiInstanceActivityBehavior 

func (f *IntermediateCatchEventActivityBehavior) SetMultiInstanceActivityBehavior(multiInstanceActivityBehavior multiInstanceActivityBehavior)

func (IntermediateCatchEventActivityBehavior) Trigger 

func (f IntermediateCatchEventActivityBehavior) Trigger(execution delegate.DelegateExecution) error

type MultiInstanceActivity added in v0.0.5 

type MultiInstanceActivity interface {
	delegate.FlowElement
	model.LoopCharacteristicsGetter
}

type MultiInstanceSupportBehavior added in v0.0.5 

type MultiInstanceSupportBehavior interface {
	delegate.TriggerableActivityBehavior
	SetMultiInstanceActivityBehavior(multiInstanceActivityBehavior multiInstanceActivityBehavior)
}

type ParallelGatewayActivityBehavior 

type ParallelGatewayActivityBehavior struct {
}

func (ParallelGatewayActivityBehavior) Execute 

func (parallel ParallelGatewayActivityBehavior) Execute(execution delegate.DelegateExecution) error

包容网关

func (ParallelGatewayActivityBehavior) Leave 

func (parallel ParallelGatewayActivityBehavior) Leave(execution delegate.DelegateExecution) error

执行逻辑：获取当前所有执行的节点，判断是否可达当前网关可以停止执行，等待完成

type ParallelMultiInstanceBehavior added in v0.0.5 

type ParallelMultiInstanceBehavior struct {
	AbstractMultiInstanceActivityBehavior
}

type PipelineServiceTaskActivityBehavior added in v0.0.3 

type PipelineServiceTaskActivityBehavior struct {
	ServiceTask model.ServiceTask
	ProcessKey  string
	// contains filtered or unexported fields
}

func (PipelineServiceTaskActivityBehavior) Execute added in v0.0.3 

func (pipeline PipelineServiceTaskActivityBehavior) Execute(execution delegate.DelegateExecution) error

func (PipelineServiceTaskActivityBehavior) MultiInstanceActivityBehavior added in v0.0.3 

func (f PipelineServiceTaskActivityBehavior) MultiInstanceActivityBehavior() multiInstanceActivityBehavior

func (*PipelineServiceTaskActivityBehavior) SetMultiInstanceActivityBehavior added in v0.0.3 

func (f *PipelineServiceTaskActivityBehavior) SetMultiInstanceActivityBehavior(multiInstanceActivityBehavior multiInstanceActivityBehavior)

func (PipelineServiceTaskActivityBehavior) Trigger added in v0.0.3 

func (pipeline PipelineServiceTaskActivityBehavior) Trigger(execution delegate.DelegateExecution) error

Trigger 普通用户节点处理

type SequentialMultiInstanceBehavior added in v0.0.5 

type SequentialMultiInstanceBehavior struct {
	AbstractMultiInstanceActivityBehavior
}

type UserAutoTaskActivityBehavior 

type UserAutoTaskActivityBehavior struct {
	UserTask   model.UserTask
	ProcessKey string
}

func (UserAutoTaskActivityBehavior) Execute 

func (user UserAutoTaskActivityBehavior) Execute(execution delegate.DelegateExecution) (err error)

自动通过用户节点处理

func (UserAutoTaskActivityBehavior) Leave 

func (user UserAutoTaskActivityBehavior) Leave(execution delegate.DelegateExecution)

func (UserAutoTaskActivityBehavior) Trigger 

func (user UserAutoTaskActivityBehavior) Trigger(execution delegate.DelegateExecution) error

普通用户节点处理

type UserTaskActivityBehavior 

type UserTaskActivityBehavior struct {
	UserTask   model.UserTask
	ProcessKey string
	// contains filtered or unexported fields
}

func (UserTaskActivityBehavior) Execute 

func (user UserTaskActivityBehavior) Execute(execution delegate.DelegateExecution) error

Execute 普通用户节点处理

func (UserTaskActivityBehavior) MultiInstanceActivityBehavior 

func (f UserTaskActivityBehavior) MultiInstanceActivityBehavior() multiInstanceActivityBehavior

func (*UserTaskActivityBehavior) SetMultiInstanceActivityBehavior 

func (f *UserTaskActivityBehavior) SetMultiInstanceActivityBehavior(multiInstanceActivityBehavior multiInstanceActivityBehavior)

func (UserTaskActivityBehavior) Trigger 

func (user UserTaskActivityBehavior) Trigger(execution delegate.DelegateExecution) error

Trigger 普通用户节点处理

Source Files

View all Source files

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.