Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewServiceTask ¶
func NewServiceTask(ctx context.Context, task *schema.ServiceTask) activity.Constructor
Types ¶
type ActiveTrace ¶
type ActiveTrace struct { context.Context Activity activity.Activity Headers map[string]any Properties map[string]any DataObjects map[string]any // contains filtered or unexported fields }
func (*ActiveTrace) Do ¶
func (t *ActiveTrace) Do(dataObjects, result map[string]any, err error, retries *int32)
func (*ActiveTrace) Execute ¶
func (t *ActiveTrace) Execute()
func (*ActiveTrace) TraceInterface ¶
func (t *ActiveTrace) TraceInterface()
type ServiceTask ¶
func (*ServiceTask) Cancel ¶
func (node *ServiceTask) Cancel() <-chan bool
func (*ServiceTask) Element ¶
func (node *ServiceTask) Element() schema.FlowNodeInterface
func (*ServiceTask) NextAction ¶
func (node *ServiceTask) NextAction(flow_interface.T) chan flow_node.IAction
Click to show internal directories.
Click to hide internal directories.