workflow

Documentation

Index

• Constants
• func DoSomething(ctx workflow.Context, input DoSomethingInput) error
• func GetActivity1ChanName(paymentID string) string
• func GetActivity2ChanName(paymentID string) string
• func GetActivity3ChanName(paymentID string) string
• func GetActivity4ChanName(paymentID string) string
• func GetActivity5ChanName(paymentID string) string
• func GetDoSomethingWorkflowName(paymentID string) string
• type Activity1
  • func NewActivity1(temporalClient client.Client, updateProcessingPayment interface{}) *Activity1
  • func (a *Activity1) Activity1(ctx context.Context, request interface{}) error
• type Activity1Response
• type Activity2
  • func NewActivity2(temporalClient client.Client, updateProcessingPayment interface{}) *Activity2
  • func (a *Activity2) Activity2(ctx context.Context, request interface{}) error
• type Activity2Response
• type Activity3
  • func NewActivity3(temporalClient client.Client, updateProcessingPayment interface{}) *Activity3
  • func (a *Activity3) Activity3(ctx context.Context, request interface{}) error
• type Activity3Response
• type Activity4
  • func NewActivity4(temporalClient client.Client, updateProcessingPayment interface{}) *Activity4
  • func (a *Activity4) Activity4(ctx context.Context, request interface{}) error
• type Activity4Response
• type Activity5
  • func NewActivity5(temporalClient client.Client, updateProcessingPayment interface{}) *Activity5
  • func (a *Activity5) Activity5(ctx context.Context, request interface{}) error
• type Activity5Response
• type DoSomethingInput

Constants

const (
	DO_SOMETHING_WORKFLOW_NAME = "DO_SOMETHING"
	X_REQUEST_ID               = "uuid"
)

const ACTIVITY1_NAME = "ACTIVITY_1"

const ACTIVITY2_NAME = "ACTIVITY_2"

const ACTIVITY3_NAME = "ACTIVITY_3"

const ACTIVITY4_NAME = "ACTIVITY_4"

const ACTIVITY5_NAME = "ACTIVITY_5"

Functions

func DoSomething

func DoSomething(ctx workflow.Context, input DoSomethingInput) error

func GetActivity1ChanName

func GetActivity1ChanName(paymentID string) string

func GetActivity2ChanName

func GetActivity2ChanName(paymentID string) string

func GetActivity3ChanName

func GetActivity3ChanName(paymentID string) string

func GetActivity4ChanName

func GetActivity4ChanName(paymentID string) string

func GetActivity5ChanName

func GetActivity5ChanName(paymentID string) string

func GetDoSomethingWorkflowName

func GetDoSomethingWorkflowName(paymentID string) string

Types

type Activity1

type Activity1 struct {
	TemporalClient    client.Client
	Activity1Response *Activity1Response
}

func NewActivity1

func NewActivity1(temporalClient client.Client, updateProcessingPayment interface{}) *Activity1

func (*Activity1) Activity1

func (a *Activity1) Activity1(ctx context.Context, request interface{}) error

type Activity1Response

type Activity1Response struct {
	Message string
	TS      time.Time
}

type Activity2

type Activity2 struct {
	TemporalClient    client.Client
	Activity2Response *Activity2Response
}

func NewActivity2

func NewActivity2(temporalClient client.Client, updateProcessingPayment interface{}) *Activity2

func (*Activity2) Activity2

func (a *Activity2) Activity2(ctx context.Context, request interface{}) error

type Activity2Response

type Activity2Response struct {
	Message string
	TS      time.Time
}

type Activity3

type Activity3 struct {
	TemporalClient    client.Client
	Activity3Response *Activity3Response
}

func NewActivity3

func NewActivity3(temporalClient client.Client, updateProcessingPayment interface{}) *Activity3

func (*Activity3) Activity3

func (a *Activity3) Activity3(ctx context.Context, request interface{}) error

type Activity3Response

type Activity3Response struct {
	Message string
	TS      time.Time
}

type Activity4

type Activity4 struct {
	TemporalClient    client.Client
	Activity4Response *Activity4Response
}

func NewActivity4

func NewActivity4(temporalClient client.Client, updateProcessingPayment interface{}) *Activity4

func (*Activity4) Activity4

func (a *Activity4) Activity4(ctx context.Context, request interface{}) error

type Activity4Response

type Activity4Response struct {
	Message string
	TS      time.Time
}

type Activity5

type Activity5 struct {
	TemporalClient    client.Client
	Activity5Response *Activity5Response
}

func NewActivity5

func NewActivity5(temporalClient client.Client, updateProcessingPayment interface{}) *Activity5

func (*Activity5) Activity5

func (a *Activity5) Activity5(ctx context.Context, request interface{}) error

type Activity5Response

type Activity5Response struct {
	Message string
	TS      time.Time
}

type DoSomethingInput

type DoSomethingInput struct {
	PaymentID string
}