activites

package
v0.1.1 Latest Latest
Warning

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

Go to latest
Published: Jul 20, 2023 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source
const CUSTOMIZED_LOOP_PORT_FINISHED = "finished"
View Source
const CUSTOMIZED_LOOP_PORT_OUTPUT = "output"
View Source
const LOOP_PORT_FINISHED = "finished"
View Source
const LOOP_PORT_OUTPUT = "output"

Variables

This section is empty.

Functions

This section is empty.

Types

type ConditionActivity

type ConditionActivity struct {
	Activity runtime.Activity[ConditionConfig]
}

func (*ConditionActivity) Input

func (c *ConditionActivity) Input(inputValue interface{}, ctx context.Context)

type ConditionConfig

type ConditionConfig struct {
	TrueExpression string `json:"trueExpression"`
}

type ConstValueActivity added in v0.1.0

type ConstValueActivity struct {
	Activity runtime.Activity[ConstValueConfig]
}

func (*ConstValueActivity) Input added in v0.1.0

func (d *ConstValueActivity) Input(inputValue any, ctx context.Context)

type ConstValueConfig added in v0.1.0

type ConstValueConfig struct {
	Value any `json:"value"`
}

type ContextReadActivity added in v0.1.0

type ContextReadActivity struct {
	Activity runtime.Activity[ContextReadConfig]
}

func (*ContextReadActivity) Input added in v0.1.0

func (r *ContextReadActivity) Input(inputValue any, ctx context.Context)

type ContextReadConfig added in v0.1.0

type ContextReadConfig struct {
	Name string `json:"name"`
}

type ContextWriteActivity added in v0.1.0

type ContextWriteActivity struct {
	Activity runtime.Activity[ContextWriteConfig]
}

func (*ContextWriteActivity) Input added in v0.1.0

func (w *ContextWriteActivity) Input(inputValue any, ctx context.Context)

type ContextWriteConfig added in v0.1.0

type ContextWriteConfig struct {
	Name string `json:"name"`
}

type CustomizedLoopActivity

type CustomizedLoopActivity struct {
	Activity runtime.Activity[CustomizedLoopConfig]
	// contains filtered or unexported fields
}

func (*CustomizedLoopActivity) Finshed added in v0.1.1

func (l *CustomizedLoopActivity) Finshed(value any, ctx context.Context)

func (*CustomizedLoopActivity) Init added in v0.1.1

func (l *CustomizedLoopActivity) Init()

该方法如果存在,会通过反射被自动调用

func (*CustomizedLoopActivity) Input

func (l *CustomizedLoopActivity) Input(inputValue any, ctx context.Context)

func (*CustomizedLoopActivity) Output

func (l *CustomizedLoopActivity) Output(value any, ctx context.Context)

type CustomizedLoopConfig

type CustomizedLoopConfig struct {
	FromInput bool `json:"fromInput"`
	Times     int  `json:"times"`
}

type DebugActivity

type DebugActivity struct {
	Activity runtime.Activity[DebugConfig]
}

func (*DebugActivity) Input

func (d *DebugActivity) Input(inputValue any, ctx context.Context)

type DebugConfig

type DebugConfig struct {
	Tip    string `json:"tip"`
	Closed bool   `json:"closed"`
}

type DelayActivity added in v0.1.0

type DelayActivity struct {
	Activity runtime.Activity[DelayConfig]
}

func (*DelayActivity) Input added in v0.1.0

func (d *DelayActivity) Input(inputValue any, ctx context.Context)

type DelayConfig added in v0.1.0

type DelayConfig struct {
	//单位是秒
	Time int `json:"time"`
}

type JsCodeActivity added in v0.1.0

type JsCodeActivity struct {
	Activity runtime.Activity[JsCodeConfig]
	// contains filtered or unexported fields
}

func (*JsCodeActivity) DynamicInput added in v0.1.0

func (j *JsCodeActivity) DynamicInput(name string, inputValue any, ctx context.Context)

func (*JsCodeActivity) Init added in v0.1.0

func (j *JsCodeActivity) Init()

type JsCodeConfig added in v0.1.0

type JsCodeConfig struct {
	Expression string `json:"expression"`
}

type LogicFlowConfigParam added in v0.1.0

type LogicFlowConfigParam struct {
	LogicFlowId string `json:"logicFlowId"`
}

type LoopActivity

type LoopActivity struct {
	Activity runtime.Activity[LoopConfig]
}

func (*LoopActivity) Input

func (l *LoopActivity) Input(inputValue any, ctx context.Context)

func (*LoopActivity) Output

func (l *LoopActivity) Output(value any, ctx context.Context)

type LoopConfig

type LoopConfig struct {
	FromInput bool `json:"fromInput"`
	Times     int  `json:"times"`
}

type MergeActivity added in v0.1.0

type MergeActivity struct {
	Activity runtime.Activity[any]
	// contains filtered or unexported fields
}

func (*MergeActivity) DynamicInput added in v0.1.0

func (m *MergeActivity) DynamicInput(name string, inputValue any, ctx context.Context)

func (*MergeActivity) Init added in v0.1.0

func (m *MergeActivity) Init()

type PortFunc added in v0.1.0

type PortFunc = func(inputValue any, ctx context.Context)

type SplitArrayActivity added in v0.1.0

type SplitArrayActivity struct {
	Activity runtime.Activity[any]
}

func (*SplitArrayActivity) Input added in v0.1.0

func (s *SplitArrayActivity) Input(inputValue any, ctx context.Context)

type SplitObjectActivity added in v0.1.0

type SplitObjectActivity struct {
	Activity runtime.Activity[any]
}

func (*SplitObjectActivity) Input added in v0.1.0

func (s *SplitObjectActivity) Input(inputValue any, ctx context.Context)

type SubLogicFlowActivity

type SubLogicFlowActivity struct {
	Activity runtime.Activity[SubLogicFlowConfig]
}

func (*SubLogicFlowActivity) GetFlowMeta

func (s *SubLogicFlowActivity) GetFlowMeta() *dsl.LogicFlowMeta

func (*SubLogicFlowActivity) Init

func (s *SubLogicFlowActivity) Init()

该方法如果存在,会通过反射被自动调用

type SubLogicFlowConfig

type SubLogicFlowConfig struct {
	Param LogicFlowConfigParam `json:"param"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL