executor

Documentation

Index

• type ElementExecutor
  • func (e *ElementExecutor) Commit(ctx *liflow.FlowCtx) error
  • func (e *ElementExecutor) Execute(ctx *liflow.FlowCtx) error
  • func (e *ElementExecutor) GetExecuteExecutor(ctx *liflow.FlowCtx) liflow.Executor
  • func (e *ElementExecutor) GetRollbackExecutor(ctx *liflow.FlowCtx) (liflow.Executor, error)
  • func (e *ElementExecutor) IsCompleted(ctx *liflow.FlowCtx) bool
  • func (e *ElementExecutor) Rollback(ctx *liflow.FlowCtx) error
  • func (e *ElementExecutor) Validate(eleMap map[string]*schema.FlowElement, ele *schema.FlowElement) error
• type EndEventExecutor
  • func (e *EndEventExecutor) Execute(ctx *liflow.FlowCtx) error
  • func (e *EndEventExecutor) GetExecuteExecutor(ctx *liflow.FlowCtx) liflow.Executor
  • func (e *EndEventExecutor) Rollback(ctx *liflow.FlowCtx) error
  • func (e *EndEventExecutor) Validate(eleMap map[string]*schema.FlowElement, ele *schema.FlowElement) error
• type ExclusiveGatewayExecutor
  • func (e *ExclusiveGatewayExecutor) Execute(ctx *liflow.FlowCtx) error
  • func (e *ExclusiveGatewayExecutor) GetExecuteExecutor(ctx *liflow.FlowCtx) liflow.Executor
• type SequenceFlowExecutor
• type StartEventExecutor
  • func (e *StartEventExecutor) Execute(ctx *liflow.FlowCtx) error
  • func (e *StartEventExecutor) Rollback(ctx *liflow.FlowCtx) error
  • func (e *StartEventExecutor) Validate(eleMap map[string]*schema.FlowElement, ele *schema.FlowElement) error
• type UserTaskExecutor
  • func (e *UserTaskExecutor) Commit(ctx *liflow.FlowCtx) error
  • func (e *UserTaskExecutor) Execute(ctx *liflow.FlowCtx) error
  • func (e *UserTaskExecutor) GetExecuteExecutor(ctx *liflow.FlowCtx) liflow.Executor
  • func (e *UserTaskExecutor) Rollback(ctx *liflow.FlowCtx) error
  • func (e *UserTaskExecutor) Validate(eleMap map[string]*schema.FlowElement, ele *schema.FlowElement) error

Types

type ElementExecutor

type ElementExecutor struct{}

func (*ElementExecutor) Commit

func (e *ElementExecutor) Commit(ctx *liflow.FlowCtx) error

func (*ElementExecutor) Execute

func (e *ElementExecutor) Execute(ctx *liflow.FlowCtx) error

func (*ElementExecutor) GetExecuteExecutor

func (e *ElementExecutor) GetExecuteExecutor(ctx *liflow.FlowCtx) liflow.Executor

func (*ElementExecutor) GetRollbackExecutor

func (e *ElementExecutor) GetRollbackExecutor(ctx *liflow.FlowCtx) (liflow.Executor, error)

func (*ElementExecutor) IsCompleted

func (e *ElementExecutor) IsCompleted(ctx *liflow.FlowCtx) bool

func (*ElementExecutor) Rollback

func (e *ElementExecutor) Rollback(ctx *liflow.FlowCtx) error

func (*ElementExecutor) Validate

func (e *ElementExecutor) Validate(eleMap map[string]*schema.FlowElement, ele *schema.FlowElement) error

type EndEventExecutor

type EndEventExecutor struct {
	ElementExecutor
}

func (*EndEventExecutor) Execute

func (e *EndEventExecutor) Execute(ctx *liflow.FlowCtx) error

func (*EndEventExecutor) GetExecuteExecutor

func (e *EndEventExecutor) GetExecuteExecutor(ctx *liflow.FlowCtx) liflow.Executor

func (*EndEventExecutor) Rollback

func (e *EndEventExecutor) Rollback(ctx *liflow.FlowCtx) error

func (*EndEventExecutor) Validate

func (e *EndEventExecutor) Validate(eleMap map[string]*schema.FlowElement, ele *schema.FlowElement) error

type ExclusiveGatewayExecutor

type ExclusiveGatewayExecutor struct {
	ElementExecutor
}

func (*ExclusiveGatewayExecutor) Execute

func (e *ExclusiveGatewayExecutor) Execute(ctx *liflow.FlowCtx) error

func (*ExclusiveGatewayExecutor) GetExecuteExecutor

func (e *ExclusiveGatewayExecutor) GetExecuteExecutor(ctx *liflow.FlowCtx) liflow.Executor

type SequenceFlowExecutor

type SequenceFlowExecutor struct {
	ElementExecutor
}

type StartEventExecutor

type StartEventExecutor struct {
	ElementExecutor
}

func (*StartEventExecutor) Execute

func (e *StartEventExecutor) Execute(ctx *liflow.FlowCtx) error

func (*StartEventExecutor) Rollback

func (e *StartEventExecutor) Rollback(ctx *liflow.FlowCtx) error

func (*StartEventExecutor) Validate

func (e *StartEventExecutor) Validate(eleMap map[string]*schema.FlowElement, ele *schema.FlowElement) error

type UserTaskExecutor

type UserTaskExecutor struct {
	ElementExecutor
}

func (*UserTaskExecutor) Commit

func (e *UserTaskExecutor) Commit(ctx *liflow.FlowCtx) error

func (*UserTaskExecutor) Execute

func (e *UserTaskExecutor) Execute(ctx *liflow.FlowCtx) error

func (*UserTaskExecutor) GetExecuteExecutor

func (e *UserTaskExecutor) GetExecuteExecutor(ctx *liflow.FlowCtx) liflow.Executor

func (*UserTaskExecutor) Rollback

func (e *UserTaskExecutor) Rollback(ctx *liflow.FlowCtx) error

func (*UserTaskExecutor) Validate

func (e *UserTaskExecutor) Validate(eleMap map[string]*schema.FlowElement, ele *schema.FlowElement) error