workflow

package
v0.0.38 Latest Latest
Warning

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

Go to latest
Published: Jun 21, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type RecipeProjectProvider

type RecipeProjectProvider func(projectId string, recipeRef string) (*recipe.Recipe, error)

type SWFWorkflowControl

type SWFWorkflowControl struct {
	Engine                        swf.SWFEngine
	Registry                      RecipeProjectProvider
	PreferRuntimeRecipeResolution bool
}

func (*SWFWorkflowControl) Cancel

func (s *SWFWorkflowControl) Cancel(ctx context.Context, jobKey swf.JobKey) error

func (*SWFWorkflowControl) CompleteTask

func (s *SWFWorkflowControl) CompleteTask(ctx context.Context, jobKey swf.JobKey, taskOrdinal int64, hash string, outType any) error

func (*SWFWorkflowControl) GetArtifactLazy

func (s *SWFWorkflowControl) GetArtifactLazy(ctx context.Context, tenantId string, key swf.ArtifactKey) swf.Artifact

func (*SWFWorkflowControl) GetWaitingTask

func (s *SWFWorkflowControl) GetWaitingTask(ctx context.Context, jobKey swf.JobKey) (workflowctl.TaskHandle, error)

func (*SWFWorkflowControl) InspectJob added in v0.0.24

func (*SWFWorkflowControl) JobResult

func (s *SWFWorkflowControl) JobResult(ctx context.Context, key swf.JobKey) (swf.JobData, error)

func (*SWFWorkflowControl) ListJobs

func (s *SWFWorkflowControl) ListJobs(ctx context.Context, request swf.ListJobsRequest) (jobs []workflowctl.JobItem, nextPage string, err error)

func (*SWFWorkflowControl) StartJob

Jump to

Keyboard shortcuts

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