workflow

package
v0.19.771 Latest Latest
Warning

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

Go to latest
Published: Feb 7, 2026 License: AGPL-3.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type GenerateWorkflowStepsRequest

type GenerateWorkflowStepsRequest struct {
	WorkflowID string              `json:"workflow_id" validate:"required"`
	Steps      []*app.WorkflowStep `json:"steps" validate:"required"`
}

type Params

type Params struct {
	fx.In

	V             *validator.Validate
	EVClient      teventloop.Client
	MetricsWriter metrics.Writer
}

type WaitForApprovalResponseRequest

type WaitForApprovalResponseRequest struct {
	WorkflowID string `json:"workflow_id" validate:"required"`
	StepID     string `json:"step_id" validate:"required"`
	MaxTS      *time.Time
}

type Workflows

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

func New

func New(params Params) (*Workflows, error)

func (*Workflows) GenerateWorkflowSteps

func (w *Workflows) GenerateWorkflowSteps(ctx workflow.Context, req *GenerateWorkflowStepsRequest) ([]*app.WorkflowStep, error)

@temporal-gen workflow @execution-timeout 1h @task-timeout 1m @id-template {{.CallerID}}-generate-steps

func (*Workflows) WaitForApprovalResponse

@temporal-gen workflow @execution-timeout 720h @task-timeout 1m @id-template {{.CallerID}}-{{.Req.StepID}}-wait-for-approval-response

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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