Documentation
¶
Index ¶
- Variables
- func Go(ctx Context, f func(ctx Context))
- func Now(ctx Context) time.Time
- func Replaying(ctx Context) bool
- func Select(ctx Context, cases ...SelectCase)
- func Sleep(ctx Context, d time.Duration) error
- func WithCancel(parent Context) (ctx Context, cancel CancelFunc)
- type Activity
- type ActivityOptions
- type CancelFunc
- type Channel
- type Context
- type Future
- func CreateSubWorkflowInstance(ctx Context, options SubWorkflowOptions, workflow Workflow, ...) Future
- func ExecuteActivity(ctx Context, options ActivityOptions, activity Activity, args ...interface{}) Future
- func ScheduleTimer(ctx Context, delay time.Duration) Future
- func SideEffect(ctx Context, f func(ctx Context) interface{}) Future
- type Instance
- type RetryOptions
- type SelectCase
- type SubWorkflowOptions
- type Workflow
Constants ¶
This section is empty.
Variables ¶
View Source
var Canceled = sync.Canceled
View Source
var DefaultActivityOptions = internal.DefaultActivityOptions
View Source
var DefaultRetryOptions = internal.DefaultRetryOptions
View Source
var DefaultSubWorkflowOptions = internal.DefaultSubWorkflowOptions
Functions ¶
func Select ¶
func Select(ctx Context, cases ...SelectCase)
func WithCancel ¶
func WithCancel(parent Context) (ctx Context, cancel CancelFunc)
WithCancel returns a copy of parent with a new Done channel. The returned context's Done channel is closed when the returned cancel function is called or when the parent context's Done channel is closed, whichever happens first.
Canceling this context releases resources associated with it, so code should call cancel as soon as the operations running in this Context complete.
Types ¶
type ActivityOptions ¶
type ActivityOptions = internal.ActivityOptions
type CancelFunc ¶
type CancelFunc = sync.CancelFunc
type Channel ¶
func NewBufferedChannel ¶
func NewChannel ¶
func NewChannel() Channel
func NewSignalChannel ¶
type Context ¶
func NewDisconnectedContext ¶
type Future ¶
func CreateSubWorkflowInstance ¶
func CreateSubWorkflowInstance(ctx Context, options SubWorkflowOptions, workflow Workflow, args ...interface{}) Future
func ExecuteActivity ¶
func ExecuteActivity(ctx Context, options ActivityOptions, activity Activity, args ...interface{}) Future
ExecuteActivity schedules the given activity to be executed
func SideEffect ¶
type Instance ¶
type Instance = core.WorkflowInstance
type RetryOptions ¶
type RetryOptions = internal.RetryOptions
type SelectCase ¶
type SelectCase = sync.SelectCase
func Default ¶
func Default(handler func(Context)) SelectCase
type SubWorkflowOptions ¶
type SubWorkflowOptions = internal.SubWorkflowOptions
Source Files
Click to show internal directories.
Click to hide internal directories.