workflow

Documentation

Index

• Constants
• func ComposeGreeting(ctx context.Context, name string) (string, error)
• func GreetingWorkflow(ctx workflow.Context, initialWakeUpTime time.Time) (string, error)
• type UpdatableTimer
  • func (u *UpdatableTimer) GetWakeUpTime() time.Time
  • func (u *UpdatableTimer) SleepUntil(ctx workflow.Context, wakeUpTime time.Time, ...) (err error)

Constants

const (
	QueryType  = "GetWakeUpTime"
	SignalType = "UpdateWakeUpTime"
)

const GreetingTaskQueue = "GREETING_TASK_QUEUE"

Functions

func ComposeGreeting

func ComposeGreeting(ctx context.Context, name string) (string, error)

func GreetingWorkflow

func GreetingWorkflow(ctx workflow.Context, initialWakeUpTime time.Time) (string, error)

Types

type UpdatableTimer

type UpdatableTimer struct {
	// contains filtered or unexported fields
}

UpdatableTimer is an example of a timer that can have its wake time updated

func (*UpdatableTimer) GetWakeUpTime

func (u *UpdatableTimer) GetWakeUpTime() time.Time

func (*UpdatableTimer) SleepUntil

func (u *UpdatableTimer) SleepUntil(ctx workflow.Context, wakeUpTime time.Time, updateWakeUpTimeCh workflow.ReceiveChannel) (err error)

SleepUntil sleeps until the provided wake-up time. The wake-up time can be updated at any time by sending a new time over updateWakeUpTimeCh. Supports ctx cancellation. Returns temporal.CanceledError if ctx was canceled.