task

Documentation

Index

• func NewTask(ctx context.Context, task *schema.Task) activity.Constructor
• type ActiveTrace
  • func (t *ActiveTrace) Do(action flow_node.IAction)
  • func (t *ActiveTrace) Execute()
  • func (t *ActiveTrace) TraceInterface()
• type Task
  • func (node *Task) Cancel() <-chan bool
  • func (node *Task) Element() schema.FlowNodeInterface
  • func (node *Task) NextAction(flow_interface.T) chan flow_node.IAction

Functions

func NewTask

func NewTask(ctx context.Context, task *schema.Task) activity.Constructor

Types

type ActiveTrace

type ActiveTrace struct {
	Context  context.Context
	Activity activity.Activity
	// contains filtered or unexported fields
}

func (*ActiveTrace) Do

func (t *ActiveTrace) Do(action flow_node.IAction)

func (*ActiveTrace) Execute

func (t *ActiveTrace) Execute()

func (*ActiveTrace) TraceInterface

func (t *ActiveTrace) TraceInterface()

type Task

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

func (*Task) Cancel

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

func (*Task) Element

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

func (*Task) NextAction

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