Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

impl

package

Go to main page

Versions in this module

v3

v3.4.0

Jun 27, 2026

v3.3.0

Mar 23, 2026

Changes in this version

+ type WaitTaskRunner struct

+ Task *model.WaitTask

+ TaskName string

+ func NewWaitTaskRunner(taskName string, task *model.WaitTask) (*WaitTaskRunner, error)

+ func (w *WaitTaskRunner) GetTaskName() string

+ func (w *WaitTaskRunner) Run(input interface{}, taskSupport TaskSupport) (interface{}, error)

v3.2.0

Dec 2, 2025

v3.1.2

Nov 20, 2025

v3.1.1

Oct 20, 2025

v3.1.0

May 2, 2025

Changes in this version

+ func GenerateJSONPointer(workflow *model.Workflow, targetNode interface{}) (string, error)

+ type CallHTTPTaskRunner struct

+ TaskName string

+ func NewCallHttpRunner(taskName string, task *model.CallHTTP) (taskRunner *CallHTTPTaskRunner, err error)

+ func (f *CallHTTPTaskRunner) GetTaskName() string

+ func (f *CallHTTPTaskRunner) Run(input interface{}, taskSupport TaskSupport) (interface{}, error)

+ type DoTaskRunner struct

+ TaskList *model.TaskList

+ func NewDoTaskRunner(taskList *model.TaskList) (*DoTaskRunner, error)

+ func (d *DoTaskRunner) GetTaskName() string

+ func (d *DoTaskRunner) Run(input interface{}, taskSupport TaskSupport) (output interface{}, err error)

+ type ForTaskRunner struct

+ DoRunner *DoTaskRunner

+ Task *model.ForTask

+ TaskName string

+ func NewForTaskRunner(taskName string, task *model.ForTask) (*ForTaskRunner, error)

+ func (f *ForTaskRunner) GetTaskName() string

+ func (f *ForTaskRunner) Run(input interface{}, taskSupport TaskSupport) (interface{}, error)

+ type ForkTaskRunner struct

+ BranchRunners []TaskRunner

+ Task *model.ForkTask

+ TaskName string

+ func NewForkTaskRunner(taskName string, task *model.ForkTask, workflowDef *model.Workflow) (*ForkTaskRunner, error)

+ func (f ForkTaskRunner) GetTaskName() string

+ func (f ForkTaskRunner) Run(input interface{}, parentSupport TaskSupport) (interface{}, error)

+ type RaiseTaskRunner struct

+ Task *model.RaiseTask

+ TaskName string

+ func NewRaiseTaskRunner(taskName string, task *model.RaiseTask, workflowDef *model.Workflow) (*RaiseTaskRunner, error)

+ func (r *RaiseTaskRunner) GetTaskName() string

+ func (r *RaiseTaskRunner) Run(input interface{}, taskSupport TaskSupport) (output interface{}, err error)

+ type SetTaskRunner struct

+ Task *model.SetTask

+ TaskName string

+ func NewSetTaskRunner(taskName string, task *model.SetTask) (*SetTaskRunner, error)

+ func (s *SetTaskRunner) GetTaskName() string

+ func (s *SetTaskRunner) Run(input interface{}, taskSupport TaskSupport) (output interface{}, err error)

+ type TaskRunner interface

+ GetTaskName func() string

+ Run func(input interface{}, taskSupport TaskSupport) (interface{}, error)

+ func NewTaskRunner(taskName string, task model.Task, workflowDef *model.Workflow) (TaskRunner, error)

+ type TaskSupport interface

+ AddLocalExprVars func(vars map[string]interface{})

+ CloneWithContext func(ctx context.Context) TaskSupport

+ GetContext func() context.Context

+ GetTaskReference func() string

+ GetWorkflowDef func() *model.Workflow

+ RemoveLocalExprVars func(keys ...string)

+ SetLocalExprVars func(vars map[string]interface{})

+ SetTaskDef func(task model.Task) error

+ SetTaskName func(name string)

+ SetTaskRawInput func(value interface{})

+ SetTaskRawOutput func(value interface{})

+ SetTaskReferenceFromName func(taskName string) error

+ SetTaskStartedAt func(value time.Time)

+ SetTaskStatus func(task string, status ctx.StatusPhase)

+ SetWorkflowInstanceCtx func(value interface{})

+ type WorkflowRunner interface

+ GetWorkflowCtx func() ctx.WorkflowContext

+ GetWorkflowDef func() *model.Workflow

+ Run func(input interface{}) (output interface{}, err error)

+ func NewDefaultRunner(workflow *model.Workflow) (WorkflowRunner, error)