executor

Documentation

Index

• type IfExecutor
  • func NewIfExecutor() *IfExecutor
  • func (e *IfExecutor) Description() string
  • func (e *IfExecutor) Execute(ctx context.Context, task *types.Task, otherTasks []*types.Task) (interface{}, error)
  • func (e *IfExecutor) ID() string
  • func (e *IfExecutor) InputRules() map[string]interface{}
  • func (e *IfExecutor) Name() string
  • func (e *IfExecutor) New() types.Executor
  • func (e *IfExecutor) OutputRules() map[string]interface{}
  • func (e *IfExecutor) Validate(ctx context.Context, task *types.Task, otherTasks []*types.Task) error
• type Input
• type Output

Types

type IfExecutor

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

func NewIfExecutor

func NewIfExecutor() *IfExecutor

NewIfExecutor creates a new IfExecutor

func (*IfExecutor) Description

func (e *IfExecutor) Description() string

func (*IfExecutor) Execute

func (e *IfExecutor) Execute(ctx context.Context, task *types.Task, otherTasks []*types.Task) (interface{}, error)

func (*IfExecutor) ID

func (e *IfExecutor) ID() string

func (*IfExecutor) InputRules

func (e *IfExecutor) InputRules() map[string]interface{}

func (*IfExecutor) Name

func (e *IfExecutor) Name() string

func (*IfExecutor) New

func (e *IfExecutor) New() types.Executor

func (*IfExecutor) OutputRules

func (e *IfExecutor) OutputRules() map[string]interface{}

func (*IfExecutor) Validate

func (e *IfExecutor) Validate(ctx context.Context, task *types.Task, otherTasks []*types.Task) error

type Input

type Input struct {
	If struct {
		Condition string `json:"condition" validate:"required,javascript"`
		Trigger   string `json:"trigger" validate:"required,alphanum"`
	} `json:"if" validate:"required"`
	Else struct {
		Trigger string `json:"trigger" validate:"required,alphanum"`
	} `json:"else" validate:"required"`
}

type Output

type Output struct {
	Next string `json:"next" validate:"required,alphanum"`
}