tasks

package
v0.6.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 6, 2026 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ActivitiesList 

func ActivitiesList() []any

Types

type CallActivityTaskBuilder added in v0.3.0 

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

func NewCallActivityTaskBuilder added in v0.3.0 

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

func (*CallActivityTaskBuilder) Build added in v0.3.0 

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

func (*CallActivityTaskBuilder) GetTask added in v0.3.0 

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

func (*CallActivityTaskBuilder) GetTaskName added in v0.3.0 

func (d *CallActivityTaskBuilder) GetTaskName() string

func (*CallActivityTaskBuilder) NeverSkipCAN added in v0.3.0 

func (d *CallActivityTaskBuilder) NeverSkipCAN() bool

Some tasks should never be skipped when doing Continue-As-New

func (CallActivityTaskBuilder) ParseMetadata added in v0.3.0 

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

func (*CallActivityTaskBuilder) PostLoad added in v0.3.0 

func (d *CallActivityTaskBuilder) PostLoad() error

func (*CallActivityTaskBuilder) ShouldRun added in v0.3.0 

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

type CallGRPCActivities added in v0.5.0 

type CallGRPCActivities struct{}

func (*CallGRPCActivities) CallGRPCActivity added in v0.5.0 

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

type CallGRPCTaskBuilder added in v0.5.0 

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

func NewCallGRPCTaskBuilder added in v0.5.0 

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

func (*CallGRPCTaskBuilder) Build added in v0.5.0 

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

func (*CallGRPCTaskBuilder) GetTask added in v0.5.0 

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

func (*CallGRPCTaskBuilder) GetTaskName added in v0.5.0 

func (d *CallGRPCTaskBuilder) GetTaskName() string

func (*CallGRPCTaskBuilder) NeverSkipCAN added in v0.5.0 

func (d *CallGRPCTaskBuilder) NeverSkipCAN() bool

Some tasks should never be skipped when doing Continue-As-New

func (CallGRPCTaskBuilder) ParseMetadata added in v0.5.0 

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

func (*CallGRPCTaskBuilder) PostLoad added in v0.5.0 

func (d *CallGRPCTaskBuilder) PostLoad() error

func (*CallGRPCTaskBuilder) ShouldRun added in v0.5.0 

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

type CallHTTPActivities added in v0.5.0 

type CallHTTPActivities struct{}

func (*CallHTTPActivities) CallHTTPActivity added in v0.5.0 

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

type CallHTTPTaskBuilder 

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

func NewCallHTTPTaskBuilder 

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

func (*CallHTTPTaskBuilder) Build 

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

func (*CallHTTPTaskBuilder) GetTask 

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

func (*CallHTTPTaskBuilder) GetTaskName 

func (d *CallHTTPTaskBuilder) GetTaskName() string

func (*CallHTTPTaskBuilder) NeverSkipCAN added in v0.2.0 

func (d *CallHTTPTaskBuilder) NeverSkipCAN() bool

Some tasks should never be skipped when doing Continue-As-New

func (CallHTTPTaskBuilder) ParseMetadata 

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

func (*CallHTTPTaskBuilder) PostLoad 

func (d *CallHTTPTaskBuilder) PostLoad() error

func (*CallHTTPTaskBuilder) ShouldRun 

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

type DoTaskBuilder 

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

func NewDoTaskBuilder 

func NewDoTaskBuilder(
	temporalWorker worker.Worker,
	task *model.DoTask,
	workflowName string,
	doc *model.Workflow,
	opts ...DoTaskOpts,
) (*DoTaskBuilder, error)

func (*DoTaskBuilder) Build 

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

func (*DoTaskBuilder) GetTask 

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

func (*DoTaskBuilder) GetTaskName 

func (d *DoTaskBuilder) GetTaskName() string

func (*DoTaskBuilder) NeverSkipCAN added in v0.2.0 

func (d *DoTaskBuilder) NeverSkipCAN() bool

Some tasks should never be skipped when doing Continue-As-New

func (DoTaskBuilder) ParseMetadata 

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

func (*DoTaskBuilder) PostLoad 

func (t *DoTaskBuilder) PostLoad() error

func (*DoTaskBuilder) ShouldRun 

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

type DoTaskOpts 

type DoTaskOpts struct {
	DisableRegisterWorkflow bool
	Envvars                 map[string]any
	MaxHistoryLength        int
	Validator               *utils.Validator
}

type ForTaskBuilder 

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

func NewForTaskBuilder 

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

func (*ForTaskBuilder) Build 

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

func (*ForTaskBuilder) GetTask 

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

func (*ForTaskBuilder) GetTaskName 

func (d *ForTaskBuilder) GetTaskName() string

func (*ForTaskBuilder) NeverSkipCAN added in v0.2.0 

func (d *ForTaskBuilder) NeverSkipCAN() bool

Some tasks should never be skipped when doing Continue-As-New

func (ForTaskBuilder) ParseMetadata 

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

func (*ForTaskBuilder) PostLoad 

func (t *ForTaskBuilder) PostLoad() error

func (*ForTaskBuilder) ShouldRun 

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

type ForkTaskBuilder 

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

func NewForkTaskBuilder 

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

func (*ForkTaskBuilder) Build 

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

func (*ForkTaskBuilder) GetTask 

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

func (*ForkTaskBuilder) GetTaskName 

func (d *ForkTaskBuilder) GetTaskName() string

func (*ForkTaskBuilder) NeverSkipCAN added in v0.2.0 

func (d *ForkTaskBuilder) NeverSkipCAN() bool

Some tasks should never be skipped when doing Continue-As-New

func (ForkTaskBuilder) ParseMetadata 

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

func (*ForkTaskBuilder) PostLoad 

func (t *ForkTaskBuilder) PostLoad() error

func (*ForkTaskBuilder) ShouldRun 

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

type HTTPRequest 

type HTTPRequest struct {
	Method  string            `json:"method"`
	URI     string            `json:"uri"`
	Headers map[string]string `json:"headers,omitempty"`
}

@link: https://github.com/serverlessworkflow/specification/blob/main/dsl-reference.md#http-request

type HTTPResponse 

type HTTPResponse struct {
	Request    HTTPRequest       `json:"request"`
	StatusCode int               `json:"statusCode"`
	Headers    map[string]string `json:"headers,omitempty"`
	Content    any               `json:"content,omitempty"`
}

@link: https://github.com/serverlessworkflow/specification/blob/main/dsl-reference.md#http-response

type ListenTaskBuilder 

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

func NewListenTaskBuilder 

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

func (*ListenTaskBuilder) Build 

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

func (*ListenTaskBuilder) GetTask 

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

func (*ListenTaskBuilder) GetTaskName 

func (d *ListenTaskBuilder) GetTaskName() string

func (*ListenTaskBuilder) NeverSkipCAN added in v0.2.0 

func (d *ListenTaskBuilder) NeverSkipCAN() bool

Some tasks should never be skipped when doing Continue-As-New

func (ListenTaskBuilder) ParseMetadata 

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

func (*ListenTaskBuilder) PostLoad 

func (d *ListenTaskBuilder) PostLoad() error

func (*ListenTaskBuilder) ShouldRun 

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

type ListenTaskType 

type ListenTaskType string
const (
	ListenTaskTypeQuery  ListenTaskType = "query"
	ListenTaskTypeSignal ListenTaskType = "signal"
	ListenTaskTypeUpdate ListenTaskType = "update"
)

type RaiseTaskBuilder 

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

func NewRaiseTaskBuilder 

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

func (*RaiseTaskBuilder) Build 

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

func (*RaiseTaskBuilder) GetTask 

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

func (*RaiseTaskBuilder) GetTaskName 

func (d *RaiseTaskBuilder) GetTaskName() string

func (*RaiseTaskBuilder) NeverSkipCAN added in v0.2.0 

func (d *RaiseTaskBuilder) NeverSkipCAN() bool

Some tasks should never be skipped when doing Continue-As-New

func (RaiseTaskBuilder) ParseMetadata 

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

func (*RaiseTaskBuilder) PostLoad 

func (d *RaiseTaskBuilder) PostLoad() error

func (*RaiseTaskBuilder) ShouldRun 

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

type RunActivities added in v0.5.0 

type RunActivities struct{}

func (*RunActivities) CallScriptActivity added in v0.5.0 

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

func (*RunActivities) CallShellActivity added in v0.5.0 

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

type RunTaskBuilder 

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

func NewRunTaskBuilder 

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

func (*RunTaskBuilder) Build 

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

func (*RunTaskBuilder) GetTask 

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

func (*RunTaskBuilder) GetTaskName 

func (d *RunTaskBuilder) GetTaskName() string

func (*RunTaskBuilder) NeverSkipCAN added in v0.2.0 

func (d *RunTaskBuilder) NeverSkipCAN() bool

Some tasks should never be skipped when doing Continue-As-New

func (RunTaskBuilder) ParseMetadata 

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

func (*RunTaskBuilder) PostLoad 

func (d *RunTaskBuilder) PostLoad() error

func (*RunTaskBuilder) ShouldRun 

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

type SetTaskBuilder 

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

func NewSetTaskBuilder 

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

func (*SetTaskBuilder) Build 

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

func (*SetTaskBuilder) GetTask 

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

func (*SetTaskBuilder) GetTaskName 

func (d *SetTaskBuilder) GetTaskName() string

func (*SetTaskBuilder) NeverSkipCAN added in v0.2.0 

func (d *SetTaskBuilder) NeverSkipCAN() bool

Some tasks should never be skipped when doing Continue-As-New

func (SetTaskBuilder) ParseMetadata 

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

func (*SetTaskBuilder) PostLoad 

func (d *SetTaskBuilder) PostLoad() error

func (*SetTaskBuilder) ShouldRun 

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

type SwitchTaskBuilder 

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

func NewSwitchTaskBuilder 

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

func (*SwitchTaskBuilder) Build 

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

func (*SwitchTaskBuilder) GetTask 

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

func (*SwitchTaskBuilder) GetTaskName 

func (d *SwitchTaskBuilder) GetTaskName() string

func (*SwitchTaskBuilder) NeverSkipCAN added in v0.2.0 

func (d *SwitchTaskBuilder) NeverSkipCAN() bool

Some tasks should never be skipped when doing Continue-As-New

func (SwitchTaskBuilder) ParseMetadata 

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

func (*SwitchTaskBuilder) PostLoad 

func (d *SwitchTaskBuilder) PostLoad() error

func (*SwitchTaskBuilder) ShouldRun 

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

type TaskBuilder 

type TaskBuilder interface {
	Build() (TemporalWorkflowFunc, error)
	GetTask() model.Task
	GetTaskName() string
	NeverSkipCAN() bool
	ParseMetadata(workflow.Context, *utils.State) error
	PostLoad() error
	ShouldRun(*utils.State) (bool, error)
}

func NewTaskBuilder 

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

Factory to create a TaskBuilder instance, or die trying

type TemporalWorkflowFunc 

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

type TryTaskBuilder 

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

func NewTryTaskBuilder 

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

func (*TryTaskBuilder) Build 

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

func (*TryTaskBuilder) GetTask 

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

func (*TryTaskBuilder) GetTaskName 

func (d *TryTaskBuilder) GetTaskName() string

func (*TryTaskBuilder) NeverSkipCAN added in v0.2.0 

func (d *TryTaskBuilder) NeverSkipCAN() bool

Some tasks should never be skipped when doing Continue-As-New

func (TryTaskBuilder) ParseMetadata 

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

func (*TryTaskBuilder) PostLoad 

func (t *TryTaskBuilder) PostLoad() error

func (*TryTaskBuilder) ShouldRun 

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

type WaitTaskBuilder 

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

func NewWaitTaskBuilder 

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

func (*WaitTaskBuilder) Build 

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

func (*WaitTaskBuilder) GetTask 

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

func (*WaitTaskBuilder) GetTaskName 

func (d *WaitTaskBuilder) GetTaskName() string

func (*WaitTaskBuilder) NeverSkipCAN added in v0.2.0 

func (d *WaitTaskBuilder) NeverSkipCAN() bool

Some tasks should never be skipped when doing Continue-As-New

func (WaitTaskBuilder) ParseMetadata 

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

func (*WaitTaskBuilder) PostLoad 

func (d *WaitTaskBuilder) PostLoad() error

func (*WaitTaskBuilder) ShouldRun 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.