script

Documentation

Index

• func NewScriptTask(ctx context.Context, task *schema.ScriptTask) activity.Constructor
• type ActiveTrace
  • func (t *ActiveTrace) Execute()
  • func (t *ActiveTrace) ExecuteExt(result map[string]any, err error)
  • func (t *ActiveTrace) TraceInterface()
• type ScriptTask
  • func (node *ScriptTask) Cancel() <-chan bool
  • func (node *ScriptTask) Element() schema.FlowNodeInterface
  • func (node *ScriptTask) NextAction(t flow_interface.T) chan flow_node.IAction

Functions

func NewScriptTask

func NewScriptTask(ctx context.Context, task *schema.ScriptTask) activity.Constructor

Types

type ActiveTrace

type ActiveTrace struct {
	Context     context.Context
	Activity    activity.Activity
	DataObjects map[string]any
	Headers     map[string]any
	Properties  map[string]any
	// contains filtered or unexported fields
}

func (*ActiveTrace) Execute

func (t *ActiveTrace) Execute()

func (*ActiveTrace) ExecuteExt

func (t *ActiveTrace) ExecuteExt(result map[string]any, err error)

func (*ActiveTrace) TraceInterface

func (t *ActiveTrace) TraceInterface()

type ScriptTask

type ScriptTask struct {
	*flow_node.Wiring
	// contains filtered or unexported fields
}

func (*ScriptTask) Cancel

func (node *ScriptTask) Cancel() <-chan bool

func (*ScriptTask) Element

func (node *ScriptTask) Element() schema.FlowNodeInterface

func (*ScriptTask) NextAction

func (node *ScriptTask) NextAction(t flow_interface.T) chan flow_node.IAction