send

Documentation

Index

• func NewSendTask(ctx context.Context, task *schema.SendTask) activity.Constructor
• type ActiveTrace
  • func (t *ActiveTrace) Do(options ...DoOption)
  • func (t *ActiveTrace) Execute()
  • func (t *ActiveTrace) GetActivity() activity.Activity
  • func (t *ActiveTrace) TraceInterface()
• type DoOption
  • func WithErr(err error) DoOption
• type SendTask
  • func (node *SendTask) Cancel() <-chan bool
  • func (node *SendTask) Element() schema.FlowNodeInterface
  • func (node *SendTask) NextAction(t flow_interface.T) chan flow_node.IAction

Functions

func NewSendTask

func NewSendTask(ctx context.Context, task *schema.SendTask) activity.Constructor

Types

type ActiveTrace

type ActiveTrace struct {
	context.Context
	Activity   activity.Activity
	Type       string
	Headers    map[string]any
	Properties map[string]any
	// contains filtered or unexported fields
}

func (*ActiveTrace) Do

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

func (*ActiveTrace) Execute

func (t *ActiveTrace) Execute()

func (*ActiveTrace) GetActivity

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

func (*ActiveTrace) TraceInterface

func (t *ActiveTrace) TraceInterface()

type DoOption

type DoOption func(*doResponse)

func WithErr

func WithErr(err error) DoOption

type SendTask

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

func (*SendTask) Cancel

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

func (*SendTask) Element

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

func (*SendTask) NextAction

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