Documentation ¶
Index ¶
- Variables
- func ConvertXMLToElement(model *Definitions)
- func Converter(bytes []byte) Process
- func ConverterBpmn(bytes model.Bytearry) Process
- func FindCurrentTask(bytearries model.Bytearry, taskDefineKey string) FlowElement
- func GetAgenda() engine.ActivitiEngineAgenda
- func GetBpmn(bytes model.Bytearry) Process
- func GetProcessInstanceManager() ProcessInstanceManager
- func SetCommandContext(commandContext CommandContext)
- func SetServiceImpl(service ServiceImpl)
- type AbstractCommandInterceptor
- type AbstractOperation
- type Command
- type CommandContext
- type CommandContextFactory
- type CommandContextInterceptor
- type CommandExecutor
- type CommandExecutorImpl
- type CommandInterceptor
- type CommandInvoker
- type Context
- type ContinueProcessOperation
- type DefaultActivitiEngineAgenda
- func (agenda *DefaultActivitiEngineAgenda) GetNextOperation() engine.Operation
- func (agenda *DefaultActivitiEngineAgenda) IsEmpty() bool
- func (agenda *DefaultActivitiEngineAgenda) PlanContinueProcessOperation(execution engine.ExecutionEntity)
- func (agenda *DefaultActivitiEngineAgenda) PlanEndExecutionOperation(execution engine.ExecutionEntity)
- func (agenda *DefaultActivitiEngineAgenda) PlanOperation(operation engine.Operation)
- func (agenda *DefaultActivitiEngineAgenda) PlanTakeOutgoingSequenceFlowsOperation(execution engine.ExecutionEntity, valuateConditions bool)
- func (agenda *DefaultActivitiEngineAgenda) PlanTriggerExecutionOperation(execution engine.ExecutionEntity)
- type EndExecutionOperation
- type ExclusiveGatewayActivityBehavior
- type FlowNodeActivityBehavior
- type InclusiveGatewayActivityBehavior
- type ProcessEngineConfiguration
- type ProcessUtils
- type ServiceImpl
- type TakeOutgoingSequenceFlowsOperation
- type TransactionContextInterceptor
- type TriggerExecutionOperation
- type TriggerableActivityBehavior
- type UserAutoTaskActivityBehavior
- type UserTaskActivityBehavior
Constants ¶
This section is empty.
Variables ¶
View Source
var (
Stack list.List
)
Functions ¶
func ConverterBpmn ¶
func FindCurrentTask ¶
func GetAgenda ¶
func GetAgenda() engine.ActivitiEngineAgenda
func GetProcessInstanceManager ¶
func GetProcessInstanceManager() ProcessInstanceManager
func SetCommandContext ¶
func SetCommandContext(commandContext CommandContext)
func SetServiceImpl ¶
func SetServiceImpl(service ServiceImpl)
Types ¶
type AbstractCommandInterceptor ¶
type AbstractCommandInterceptor struct {
Next CommandInterceptor
}
type AbstractOperation ¶
type AbstractOperation struct { CommandContext CommandContext Execution engine.ExecutionEntity }
type Command ¶
type Command interface {
Execute(interceptor CommandContext) (interface{}, error)
}
type CommandContext ¶
type CommandContext struct { Command Command Agenda engine.ActivitiEngineAgenda ProcessEngineConfiguration ProcessEngineConfiguration }
func GetCommandContext ¶
func GetCommandContext() (CommandContext, error)
type CommandContextFactory ¶
type CommandContextFactory struct { }
func (CommandContextFactory) CreateCommandContext ¶
func (factory CommandContextFactory) CreateCommandContext(command Command) CommandContext
type CommandContextInterceptor ¶
type CommandContextInterceptor struct { Next CommandInterceptor ProcessEngineConfiguration *ProcessEngineConfiguration CommandContextFactory CommandContextFactory }
func (CommandContextInterceptor) Execute ¶
func (commandContext CommandContextInterceptor) Execute(command Command) (interface{}, error)
func (*CommandContextInterceptor) SetNext ¶
func (commandContext *CommandContextInterceptor) SetNext(next CommandInterceptor)
type CommandExecutor ¶
type CommandExecutorImpl ¶
type CommandExecutorImpl struct {
First CommandInterceptor
}
func (CommandExecutorImpl) Exe ¶
func (comm CommandExecutorImpl) Exe(conf Command) (interface{}, error)
type CommandInterceptor ¶
type CommandInterceptor interface { Execute(command Command) (interface{}, error) SetNext(next CommandInterceptor) }
type CommandInvoker ¶
type CommandInvoker struct {
Next CommandInterceptor
}
func (CommandInvoker) Execute ¶
func (commandInvoker CommandInvoker) Execute(command Command) (result interface{}, err error)
func (*CommandInvoker) SetNext ¶
func (commandInvoker *CommandInvoker) SetNext(next CommandInterceptor)
type ContinueProcessOperation ¶
type ContinueProcessOperation struct {
AbstractOperation
}
func (*ContinueProcessOperation) Run ¶
func (cont *ContinueProcessOperation) Run() (err error)
type DefaultActivitiEngineAgenda ¶
func (*DefaultActivitiEngineAgenda) GetNextOperation ¶
func (agenda *DefaultActivitiEngineAgenda) GetNextOperation() engine.Operation
func (*DefaultActivitiEngineAgenda) IsEmpty ¶
func (agenda *DefaultActivitiEngineAgenda) IsEmpty() bool
判断是否为空
func (*DefaultActivitiEngineAgenda) PlanContinueProcessOperation ¶
func (agenda *DefaultActivitiEngineAgenda) PlanContinueProcessOperation(execution engine.ExecutionEntity)
连线继续执行
func (*DefaultActivitiEngineAgenda) PlanEndExecutionOperation ¶
func (agenda *DefaultActivitiEngineAgenda) PlanEndExecutionOperation(execution engine.ExecutionEntity)
任务结束
func (*DefaultActivitiEngineAgenda) PlanOperation ¶
func (agenda *DefaultActivitiEngineAgenda) PlanOperation(operation engine.Operation)
设置后续操作
func (*DefaultActivitiEngineAgenda) PlanTakeOutgoingSequenceFlowsOperation ¶
func (agenda *DefaultActivitiEngineAgenda) PlanTakeOutgoingSequenceFlowsOperation(execution engine.ExecutionEntity, valuateConditions bool)
连线出口设置
func (*DefaultActivitiEngineAgenda) PlanTriggerExecutionOperation ¶
func (agenda *DefaultActivitiEngineAgenda) PlanTriggerExecutionOperation(execution engine.ExecutionEntity)
任务出口执行
type EndExecutionOperation ¶
type EndExecutionOperation struct {
AbstractOperation
}
func (*EndExecutionOperation) Run ¶
func (end *EndExecutionOperation) Run() (err error)
type ExclusiveGatewayActivityBehavior ¶
type ExclusiveGatewayActivityBehavior struct { }
func (ExclusiveGatewayActivityBehavior) Execute ¶
func (exclusive ExclusiveGatewayActivityBehavior) Execute(execution engine.ExecutionEntity) (err error)
排他网关
func (ExclusiveGatewayActivityBehavior) Leave ¶
func (exclusive ExclusiveGatewayActivityBehavior) Leave(execution engine.ExecutionEntity) (err error)
type FlowNodeActivityBehavior ¶
type FlowNodeActivityBehavior interface {
Leave(execution engine.ExecutionEntity) error
}
type InclusiveGatewayActivityBehavior ¶
type InclusiveGatewayActivityBehavior struct { }
func (InclusiveGatewayActivityBehavior) Execute ¶
func (exclusive InclusiveGatewayActivityBehavior) Execute(execution engine.ExecutionEntity) error
包容网关
func (InclusiveGatewayActivityBehavior) Leave ¶
func (exclusive InclusiveGatewayActivityBehavior) Leave(execution engine.ExecutionEntity) error
执行逻辑:获取当前所有执行的节点,判断是否可达当前网关可以停止执行,等待完成
type ProcessEngineConfiguration ¶
type ProcessEngineConfiguration struct { CommandInvoker CommandInterceptor CommandInterceptors []CommandInterceptor EventListeners []ActivitiEventListener Service ServiceImpl CommandExecutor CommandExecutor CommandContextFactory CommandContextFactory VariableTypes VariableTypes EventDispatcher ActivitiEventDispatcher }
func GetProcessEngineConfiguration ¶
func GetProcessEngineConfiguration() *ProcessEngineConfiguration
func (ProcessEngineConfiguration) AddEventListeners ¶
func (processEngineConfiguration ProcessEngineConfiguration) AddEventListeners(eventListeners []ActivitiEventListener)
type ProcessUtils ¶
type ProcessUtils struct {
ProcessId int64
}
func (*ProcessUtils) GetCurrentTask ¶
func (processUtil *ProcessUtils) GetCurrentTask(taskId int) (FlowElement, error)
func (*ProcessUtils) GetFlowElement ¶
func (processUtil *ProcessUtils) GetFlowElement(flowElementId string) (FlowElement, error)
func (*ProcessUtils) LoadProcess ¶
func (processUtil *ProcessUtils) LoadProcess() error
type ServiceImpl ¶
type ServiceImpl struct {
CommandExecutor CommandExecutor
}
func GetServiceImpl ¶
func GetServiceImpl() ServiceImpl
func (*ServiceImpl) SetCommandExecutor ¶
func (serviceImpl *ServiceImpl) SetCommandExecutor(commandExecutor CommandExecutor)
type TakeOutgoingSequenceFlowsOperation ¶
type TakeOutgoingSequenceFlowsOperation struct { AbstractOperation EvaluateConditions bool }
func (TakeOutgoingSequenceFlowsOperation) Run ¶
func (task TakeOutgoingSequenceFlowsOperation) Run() (err error)
type TransactionContextInterceptor ¶
type TransactionContextInterceptor struct {
Next CommandInterceptor
}
func (TransactionContextInterceptor) Execute ¶
func (transactionContextInterceptor TransactionContextInterceptor) Execute(command Command) (value interface{}, err error)
func (*TransactionContextInterceptor) SetNext ¶
func (transactionContextInterceptor *TransactionContextInterceptor) SetNext(next CommandInterceptor)
type TriggerExecutionOperation ¶
type TriggerExecutionOperation struct {
AbstractOperation
}
func (TriggerExecutionOperation) Run ¶
func (trigger TriggerExecutionOperation) Run() (err error)
type TriggerableActivityBehavior ¶
type TriggerableActivityBehavior interface {
Trigger(entity engine.ExecutionEntity)
}
type UserAutoTaskActivityBehavior ¶
func (UserAutoTaskActivityBehavior) Execute ¶
func (user UserAutoTaskActivityBehavior) Execute(execution engine.ExecutionEntity) (err error)
自动通过用户节点处理
func (UserAutoTaskActivityBehavior) Leave ¶
func (user UserAutoTaskActivityBehavior) Leave(execution engine.ExecutionEntity)
func (UserAutoTaskActivityBehavior) Trigger ¶
func (user UserAutoTaskActivityBehavior) Trigger(execution engine.ExecutionEntity)
普通用户节点处理
type UserTaskActivityBehavior ¶
func (UserTaskActivityBehavior) Execute ¶
func (user UserTaskActivityBehavior) Execute(execution engine.ExecutionEntity) (err error)
普通用户节点处理
func (UserTaskActivityBehavior) Leave ¶
func (user UserTaskActivityBehavior) Leave(execution engine.ExecutionEntity)
func (UserTaskActivityBehavior) Trigger ¶
func (user UserTaskActivityBehavior) Trigger(execution engine.ExecutionEntity)
普通用户节点处理
Source Files ¶
- abstractCommandInterceptor.go
- abstractOperation.go
- command.go
- commandContext.go
- commandContextFactory.go
- commandContextInterceptor.go
- commandExecutor.go
- commandExecutorImpl.go
- commandInterceptor.go
- commandInvoker.go
- context.go
- continueProcessOperation.go
- converter.go
- defaultActivitiEngineAgenda.go
- endExecutionOperation.go
- exclusiveGatewayActivityBehavior.go
- flowNodeActivityBehavior.go
- inclusiveGatewayActivityBehavior.go
- processEngineConfiguration.go
- processUtils.go
- serviceImpl.go
- takeOutgoingSequenceFlowsOperation.go
- tiggerableActivityBehavior.go
- transactionContextInterceptor.go
- triggerExecutionOperation.go
- userAutoTaskActivityBehavior.go
- userTaskActivityBehavior.go
Click to show internal directories.
Click to hide internal directories.