Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 ¶
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
Click to show internal directories.
Click to hide internal directories.