workflow

package
v0.0.13 Latest Latest
Warning

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

 Go to latest Published: May 15, 2026 License: AGPL-3.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) 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 

func (s *SWFWorkflowControl) StartJob(ctx context.Context, req workflowctl.StartJob) (swf.JobKey, 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.