tasks

Documentation

Index

• func Callback(_ context.Context, task mq.Result) mq.Result
• func NotifyResponse(_ context.Context, result mq.Result) error
• func NotifySubDAGResponse(_ context.Context, result mq.Result) error
• func SchedulerCallback(ctx context.Context, result mq.Result) error
• func SchedulerHandler(ctx context.Context, task *mq.Task) mq.Result
• type Condition
  • func (e *Condition) ProcessTask(ctx context.Context, task *mq.Task) mq.Result
• type EmailDelivery
  • func (e *EmailDelivery) ProcessTask(ctx context.Context, task *mq.Task) mq.Result
• type Final
  • func (e *Final) ProcessTask(ctx context.Context, task *mq.Task) mq.Result
• type GetData
  • func (e *GetData) ProcessTask(ctx context.Context, task *mq.Task) mq.Result
• type InAppNotification
  • func (e *InAppNotification) ProcessTask(ctx context.Context, task *mq.Task) mq.Result
• type Loop
  • func (e *Loop) ProcessTask(ctx context.Context, task *mq.Task) mq.Result
• type Node1
  • func (t *Node1) ProcessTask(_ context.Context, task *mq.Task) mq.Result
• type Node2
  • func (t *Node2) ProcessTask(_ context.Context, task *mq.Task) mq.Result
• type Node3
  • func (t *Node3) ProcessTask(_ context.Context, task *mq.Task) mq.Result
• type Node4
  • func (t *Node4) ProcessTask(_ context.Context, task *mq.Task) mq.Result
• type Node5
  • func (t *Node5) ProcessTask(_ context.Context, task *mq.Task) mq.Result
• type Node6
  • func (t *Node6) ProcessTask(_ context.Context, task *mq.Task) mq.Result
• type Node7
  • func (t *Node7) ProcessTask(_ context.Context, task *mq.Task) mq.Result
• type Node8
  • func (t *Node8) ProcessTask(_ context.Context, task *mq.Task) mq.Result
• type PrepareEmail
  • func (e *PrepareEmail) ProcessTask(ctx context.Context, task *mq.Task) mq.Result
• type SendSms
  • func (e *SendSms) ProcessTask(ctx context.Context, task *mq.Task) mq.Result
• type StoreData
  • func (e *StoreData) ProcessTask(ctx context.Context, task *mq.Task) mq.Result

Functions

func Callback

func Callback(_ context.Context, task mq.Result) mq.Result

func NotifyResponse

func NotifyResponse(_ context.Context, result mq.Result) error

func NotifySubDAGResponse

func NotifySubDAGResponse(_ context.Context, result mq.Result) error

func SchedulerCallback

func SchedulerCallback(ctx context.Context, result mq.Result) error

func SchedulerHandler

func SchedulerHandler(ctx context.Context, task *mq.Task) mq.Result

Types

type Condition

type Condition struct {
	v2.Operation
}

func (*Condition) ProcessTask

func (e *Condition) ProcessTask(ctx context.Context, task *mq.Task) mq.Result

type EmailDelivery

type EmailDelivery struct {
	v2.Operation
}

func (*EmailDelivery) ProcessTask

func (e *EmailDelivery) ProcessTask(ctx context.Context, task *mq.Task) mq.Result

type Final

type Final struct {
	v2.Operation
}

func (*Final) ProcessTask

func (e *Final) ProcessTask(ctx context.Context, task *mq.Task) mq.Result

type GetData

type GetData struct {
	v2.Operation
}

func (*GetData) ProcessTask

func (e *GetData) ProcessTask(ctx context.Context, task *mq.Task) mq.Result

type InAppNotification

type InAppNotification struct {
	v2.Operation
}

func (*InAppNotification) ProcessTask

func (e *InAppNotification) ProcessTask(ctx context.Context, task *mq.Task) mq.Result

type Loop

type Loop struct {
	v2.Operation
}

func (*Loop) ProcessTask

func (e *Loop) ProcessTask(ctx context.Context, task *mq.Task) mq.Result

type Node1

type Node1 struct{ v2.Operation }

func (*Node1) ProcessTask

func (t *Node1) ProcessTask(_ context.Context, task *mq.Task) mq.Result

type Node2

type Node2 struct{ v2.Operation }

func (*Node2) ProcessTask

func (t *Node2) ProcessTask(_ context.Context, task *mq.Task) mq.Result

type Node3

type Node3 struct{ v2.Operation }

func (*Node3) ProcessTask

func (t *Node3) ProcessTask(_ context.Context, task *mq.Task) mq.Result

type Node4

type Node4 struct{ v2.Operation }

func (*Node4) ProcessTask

func (t *Node4) ProcessTask(_ context.Context, task *mq.Task) mq.Result

type Node5

type Node5 struct{ v2.Operation }

func (*Node5) ProcessTask

func (t *Node5) ProcessTask(_ context.Context, task *mq.Task) mq.Result

type Node6

type Node6 struct{ v2.Operation }

func (*Node6) ProcessTask

func (t *Node6) ProcessTask(_ context.Context, task *mq.Task) mq.Result

type Node7

type Node7 struct{ v2.Operation }

func (*Node7) ProcessTask

func (t *Node7) ProcessTask(_ context.Context, task *mq.Task) mq.Result

type Node8

type Node8 struct{ v2.Operation }

func (*Node8) ProcessTask

func (t *Node8) ProcessTask(_ context.Context, task *mq.Task) mq.Result

type PrepareEmail

type PrepareEmail struct {
	v2.Operation
}

func (*PrepareEmail) ProcessTask

func (e *PrepareEmail) ProcessTask(ctx context.Context, task *mq.Task) mq.Result

type SendSms

type SendSms struct {
	v2.Operation
}

func (*SendSms) ProcessTask

func (e *SendSms) ProcessTask(ctx context.Context, task *mq.Task) mq.Result

type StoreData

type StoreData struct {
	v2.Operation
}

func (*StoreData) ProcessTask

func (e *StoreData) ProcessTask(ctx context.Context, task *mq.Task) mq.Result