call

Documentation

Index

• func NewCallActivity(ctx context.Context, task *schema.CallActivity) activity.Constructor
• type ActiveTrace
  • func (t *ActiveTrace) Do(options ...DoOption)
  • func (t *ActiveTrace) Execute()
  • func (t *ActiveTrace) TraceInterface()
• type CallActivity
  • func (node *CallActivity) Cancel() <-chan bool
  • func (node *CallActivity) Element() schema.FlowNodeInterface
  • func (node *CallActivity) NextAction(flow_interface.T) chan flow_node.IAction
• type DoOption
  • func WithErr(err error) DoOption
  • func WithErrHandle(err error, ch <-chan flow_node.ErrHandler) DoOption
  • func WithObjects(dataObjects map[string]any) DoOption
  • func WithProperties(properties map[string]any) DoOption

Functions

func NewCallActivity

func NewCallActivity(ctx context.Context, task *schema.CallActivity) activity.Constructor

Types

type ActiveTrace

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

func (*ActiveTrace) Do

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

func (*ActiveTrace) Execute

func (t *ActiveTrace) Execute()

func (*ActiveTrace) TraceInterface

func (t *ActiveTrace) TraceInterface()

type CallActivity

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

func (*CallActivity) Cancel

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

func (*CallActivity) Element

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

func (*CallActivity) NextAction

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

type DoOption

type DoOption func(*doResponse)

func WithErr

func WithErr(err error) DoOption

func WithErrHandle

func WithErrHandle(err error, ch <-chan flow_node.ErrHandler) DoOption

func WithObjects

func WithObjects(dataObjects map[string]any) DoOption

func WithProperties

func WithProperties(properties map[string]any) DoOption