receive

Mar 7, 2024

Changes in this version

+ type Node struct

+ func (node *Node) Cancel() <-chan bool

+ func (node *Node) Element() schema.FlowNodeInterface

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

+ func (node *Node) Type() activity.Type

Dec 15, 2023

Changes in this version

type ReceiveTask

+ func (node *ReceiveTask) Type() activity.Type

+ type TypeKey struct

Dec 11, 2023

Changes in this version

type ActiveTrace

+ func (t *ActiveTrace) GetActivity() activity.Activity

Oct 16, 2023

Changes in this version

+ func NewReceiveTask(ctx context.Context, task *schema.ReceiveTask) activity.Constructor

+ type ActiveTrace struct

+ Activity activity.Activity

+ Headers map[string]any

+ Type string

+ func (t *ActiveTrace) Do(options ...DoOption)

+ func (t *ActiveTrace) Execute()

+ func (t *ActiveTrace) TraceInterface()

+ type DoOption func(*doResponse)

+ func WithErr(err error) DoOption

+ func WithProperties(properties map[string]any) DoOption

+ type ReceiveTask struct

+ func (node *ReceiveTask) Cancel() <-chan bool

+ func (node *ReceiveTask) Element() schema.FlowNodeInterface

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