tasks

package

Go to main page

Versions in this module

v0

v0.6.9

Jan 23, 2026

v0.6.8

Jan 18, 2026

v0.6.7

Jan 12, 2026

v0.6.6

Jan 11, 2026

v0.6.5

Jan 9, 2026

v0.6.4

Jan 8, 2026

v0.6.3

Jan 7, 2026

v0.6.2

Jan 6, 2026

v0.6.1

Jan 5, 2026

v0.6.0

Jan 2, 2026

v0.5.0

Dec 25, 2025

Changes in this version

+ type CallGRPCActivities struct

+ func (c *CallGRPCActivities) CallGRPCActivity(ctx context.Context, task *model.CallGRPC, input any, state *utils.State) (any, error)

+ type CallGRPCTaskBuilder struct

+ func NewCallGRPCTaskBuilder(temporalWorker worker.Worker, task *model.CallGRPC, taskName string, ...) (*CallGRPCTaskBuilder, error)

+ func (d *CallGRPCTaskBuilder) GetTask() model.Task

+ func (d *CallGRPCTaskBuilder) GetTaskName() string

+ func (d *CallGRPCTaskBuilder) NeverSkipCAN() bool

+ func (d *CallGRPCTaskBuilder) PostLoad() error

+ func (d *CallGRPCTaskBuilder) ShouldRun(state *utils.State) (bool, error)

+ func (d CallGRPCTaskBuilder) ParseMetadata(ctx workflow.Context, state *utils.State) error

+ func (t *CallGRPCTaskBuilder) Build() (TemporalWorkflowFunc, error)

+ type CallHTTPActivities struct

+ func (c *CallHTTPActivities) CallHTTPActivity(ctx context.Context, task *model.CallHTTP, input any, state *utils.State) (any, error)

+ type RunActivities struct

+ func (r *RunActivities) CallScriptActivity(ctx context.Context, task *model.RunTask, input any, state *utils.State) (any, error)

+ func (r *RunActivities) CallShellActivity(ctx context.Context, task *model.RunTask, input any, state *utils.State) (any, error)

v0.4.1

Dec 11, 2025

v0.4.0

Dec 10, 2025

v0.3.0

Dec 7, 2025

Changes in this version

+ type CallActivityTaskBuilder struct

+ func NewCallActivityTaskBuilder(temporalWorker worker.Worker, task *model.CallFunction, taskName string, ...) (*CallActivityTaskBuilder, error)

+ func (d *CallActivityTaskBuilder) GetTask() model.Task

+ func (d *CallActivityTaskBuilder) GetTaskName() string

+ func (d *CallActivityTaskBuilder) NeverSkipCAN() bool

+ func (d *CallActivityTaskBuilder) PostLoad() error

+ func (d *CallActivityTaskBuilder) ShouldRun(state *utils.State) (bool, error)

+ func (d CallActivityTaskBuilder) ParseMetadata(ctx workflow.Context, state *utils.State) error

+ func (t *CallActivityTaskBuilder) Build() (TemporalWorkflowFunc, error)

v0.2.1

Dec 4, 2025

v0.2.0

Dec 3, 2025

Changes in this version

type CallHTTPTaskBuilder

+ func (d *CallHTTPTaskBuilder) NeverSkipCAN() bool

type DoTaskBuilder

+ func (d *DoTaskBuilder) NeverSkipCAN() bool

type DoTaskOpts

+ MaxHistoryLength int

type ForTaskBuilder

+ func (d *ForTaskBuilder) NeverSkipCAN() bool

type ForkTaskBuilder

+ func (d *ForkTaskBuilder) NeverSkipCAN() bool

type ListenTaskBuilder

+ func (d *ListenTaskBuilder) NeverSkipCAN() bool

type RaiseTaskBuilder

+ func (d *RaiseTaskBuilder) NeverSkipCAN() bool

type RunTaskBuilder

+ func (d *RunTaskBuilder) NeverSkipCAN() bool

type SetTaskBuilder

+ func (d *SetTaskBuilder) NeverSkipCAN() bool

type SwitchTaskBuilder

+ func (d *SwitchTaskBuilder) NeverSkipCAN() bool

type TaskBuilder

+ NeverSkipCAN func() bool

type TryTaskBuilder

+ func (d *TryTaskBuilder) NeverSkipCAN() bool

type WaitTaskBuilder

+ func (d *WaitTaskBuilder) NeverSkipCAN() bool

v0.1.0

Nov 24, 2025

Changes in this version

+ func ActivitiesList() []any

+ type CallHTTPTaskBuilder struct

+ func NewCallHTTPTaskBuilder(temporalWorker worker.Worker, task *model.CallHTTP, taskName string, ...) (*CallHTTPTaskBuilder, error)

+ func (d *CallHTTPTaskBuilder) GetTask() model.Task

+ func (d *CallHTTPTaskBuilder) GetTaskName() string

+ func (d *CallHTTPTaskBuilder) PostLoad() error

+ func (d *CallHTTPTaskBuilder) ShouldRun(state *utils.State) (bool, error)

+ func (d CallHTTPTaskBuilder) ParseMetadata(ctx workflow.Context, state *utils.State) error

+ func (t *CallHTTPTaskBuilder) Build() (TemporalWorkflowFunc, error)

+ type DoTaskBuilder struct

+ func NewDoTaskBuilder(temporalWorker worker.Worker, task *model.DoTask, taskName string, ...) (*DoTaskBuilder, error)

+ func (d *DoTaskBuilder) GetTask() model.Task

+ func (d *DoTaskBuilder) GetTaskName() string

+ func (d *DoTaskBuilder) ShouldRun(state *utils.State) (bool, error)

+ func (d DoTaskBuilder) ParseMetadata(ctx workflow.Context, state *utils.State) error

+ func (t *DoTaskBuilder) Build() (TemporalWorkflowFunc, error)

+ func (t *DoTaskBuilder) PostLoad() error

+ type DoTaskOpts struct

+ DisableRegisterWorkflow bool

+ Envvars map[string]any

+ Validator *utils.Validator

+ type ForTaskBuilder struct

+ func NewForTaskBuilder(temporalWorker worker.Worker, task *model.ForTask, taskName string, ...) (*ForTaskBuilder, error)

+ func (d *ForTaskBuilder) GetTask() model.Task

+ func (d *ForTaskBuilder) GetTaskName() string

+ func (d *ForTaskBuilder) ShouldRun(state *utils.State) (bool, error)

+ func (d ForTaskBuilder) ParseMetadata(ctx workflow.Context, state *utils.State) error

+ func (t *ForTaskBuilder) Build() (TemporalWorkflowFunc, error)

+ func (t *ForTaskBuilder) PostLoad() error

+ type ForkTaskBuilder struct

+ func NewForkTaskBuilder(temporalWorker worker.Worker, task *model.ForkTask, taskName string, ...) (*ForkTaskBuilder, error)

+ func (d *ForkTaskBuilder) GetTask() model.Task

+ func (d *ForkTaskBuilder) GetTaskName() string

+ func (d *ForkTaskBuilder) ShouldRun(state *utils.State) (bool, error)

+ func (d ForkTaskBuilder) ParseMetadata(ctx workflow.Context, state *utils.State) error

+ func (t *ForkTaskBuilder) Build() (TemporalWorkflowFunc, error)

+ func (t *ForkTaskBuilder) PostLoad() error

+ type HTTPRequest struct

+ Headers map[string]string

+ Method string

+ URI string

+ type HTTPResponse struct

+ Content any

+ Headers map[string]string

+ Request HTTPRequest

+ StatusCode int

+ type ListenTaskBuilder struct

+ func NewListenTaskBuilder(temporalWorker worker.Worker, task *model.ListenTask, taskName string, ...) (*ListenTaskBuilder, error)

+ func (d *ListenTaskBuilder) GetTask() model.Task

+ func (d *ListenTaskBuilder) GetTaskName() string

+ func (d *ListenTaskBuilder) PostLoad() error

+ func (d *ListenTaskBuilder) ShouldRun(state *utils.State) (bool, error)

+ func (d ListenTaskBuilder) ParseMetadata(ctx workflow.Context, state *utils.State) error

+ func (t *ListenTaskBuilder) Build() (TemporalWorkflowFunc, error)

+ type ListenTaskType string

+ const ListenTaskTypeQuery

+ const ListenTaskTypeSignal

+ const ListenTaskTypeUpdate

+ type RaiseTaskBuilder struct

+ func NewRaiseTaskBuilder(temporalWorker worker.Worker, task *model.RaiseTask, taskName string, ...) (*RaiseTaskBuilder, error)

+ func (d *RaiseTaskBuilder) GetTask() model.Task

+ func (d *RaiseTaskBuilder) GetTaskName() string

+ func (d *RaiseTaskBuilder) PostLoad() error

+ func (d *RaiseTaskBuilder) ShouldRun(state *utils.State) (bool, error)

+ func (d RaiseTaskBuilder) ParseMetadata(ctx workflow.Context, state *utils.State) error

+ func (t *RaiseTaskBuilder) Build() (TemporalWorkflowFunc, error)

+ type RunTaskBuilder struct

+ func NewRunTaskBuilder(temporalWorker worker.Worker, task *model.RunTask, taskName string, ...) (*RunTaskBuilder, error)

+ func (d *RunTaskBuilder) GetTask() model.Task

+ func (d *RunTaskBuilder) GetTaskName() string

+ func (d *RunTaskBuilder) PostLoad() error

+ func (d *RunTaskBuilder) ShouldRun(state *utils.State) (bool, error)

+ func (d RunTaskBuilder) ParseMetadata(ctx workflow.Context, state *utils.State) error

+ func (t *RunTaskBuilder) Build() (TemporalWorkflowFunc, error)

+ type SetTaskBuilder struct

+ func NewSetTaskBuilder(temporalWorker worker.Worker, task *model.SetTask, taskName string, ...) (*SetTaskBuilder, error)

+ func (d *SetTaskBuilder) GetTask() model.Task

+ func (d *SetTaskBuilder) GetTaskName() string

+ func (d *SetTaskBuilder) PostLoad() error

+ func (d *SetTaskBuilder) ShouldRun(state *utils.State) (bool, error)

+ func (d SetTaskBuilder) ParseMetadata(ctx workflow.Context, state *utils.State) error

+ func (t *SetTaskBuilder) Build() (TemporalWorkflowFunc, error)

+ type SwitchTaskBuilder struct

+ func NewSwitchTaskBuilder(temporalWorker worker.Worker, task *model.SwitchTask, taskName string, ...) (*SwitchTaskBuilder, error)

+ func (d *SwitchTaskBuilder) GetTask() model.Task

+ func (d *SwitchTaskBuilder) GetTaskName() string

+ func (d *SwitchTaskBuilder) PostLoad() error

+ func (d *SwitchTaskBuilder) ShouldRun(state *utils.State) (bool, error)

+ func (d SwitchTaskBuilder) ParseMetadata(ctx workflow.Context, state *utils.State) error

+ func (t *SwitchTaskBuilder) Build() (TemporalWorkflowFunc, error)

+ type TaskBuilder interface

+ Build func() (TemporalWorkflowFunc, error)

+ GetTask func() model.Task

+ GetTaskName func() string

+ ParseMetadata func(workflow.Context, *utils.State) error

+ PostLoad func() error

+ ShouldRun func(*utils.State) (bool, error)

+ func NewTaskBuilder(taskName string, task model.Task, temporalWorker worker.Worker, ...) (TaskBuilder, error)

+ type TemporalWorkflowFunc func(ctx workflow.Context, input any, state *utils.State) (output any, err error)

+ type TryTaskBuilder struct

+ func NewTryTaskBuilder(temporalWorker worker.Worker, task *model.TryTask, taskName string, ...) (*TryTaskBuilder, error)

+ func (d *TryTaskBuilder) GetTask() model.Task

+ func (d *TryTaskBuilder) GetTaskName() string

+ func (d *TryTaskBuilder) ShouldRun(state *utils.State) (bool, error)

+ func (d TryTaskBuilder) ParseMetadata(ctx workflow.Context, state *utils.State) error

+ func (t *TryTaskBuilder) Build() (TemporalWorkflowFunc, error)

+ func (t *TryTaskBuilder) PostLoad() error

+ type WaitTaskBuilder struct

+ func NewWaitTaskBuilder(temporalWorker worker.Worker, task *model.WaitTask, taskName string, ...) (*WaitTaskBuilder, error)

+ func (d *WaitTaskBuilder) GetTask() model.Task

+ func (d *WaitTaskBuilder) GetTaskName() string

+ func (d *WaitTaskBuilder) PostLoad() error

+ func (d *WaitTaskBuilder) ShouldRun(state *utils.State) (bool, error)

+ func (d WaitTaskBuilder) ParseMetadata(ctx workflow.Context, state *utils.State) error

+ func (t *WaitTaskBuilder) Build() (TemporalWorkflowFunc, error)

v0.1.0-rc2

Nov 19, 2025

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL