Documentation
¶
Index ¶
- type RecipeProjectProvider
- type SWFWorkflowControl
- func (s *SWFWorkflowControl) Cancel(ctx context.Context, jobKey jobdb.JobKey) error
- func (s *SWFWorkflowControl) CompleteTask(ctx context.Context, jobKey jobdb.JobKey, taskOrdinal int64, hash string, ...) error
- func (s *SWFWorkflowControl) GetArtifactLazy(ctx context.Context, tenantId string, key jobdb.ArtifactKey) jobdb.Artifact
- func (s *SWFWorkflowControl) GetWaitingTask(ctx context.Context, jobKey jobdb.JobKey) (workflowctl.TaskHandle, error)
- func (s *SWFWorkflowControl) InspectJob(ctx context.Context, key jobdb.JobKey) (workflowctl.JobInspection, error)
- func (s *SWFWorkflowControl) JobResult(ctx context.Context, key jobdb.JobKey) (jobdb.JobData, error)
- func (s *SWFWorkflowControl) ListJobs(ctx context.Context, request jobdb.ListJobsRequest) (jobs []workflowctl.JobItem, nextPage string, err error)
- func (s *SWFWorkflowControl) StartJob(ctx context.Context, req workflowctl.StartJob) (jobdb.JobKey, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RecipeProjectProvider ¶
type SWFWorkflowControl ¶
type SWFWorkflowControl struct {
Engine jobworkflow.Engine
Registry RecipeProjectProvider
PreferRuntimeRecipeResolution bool
}
func (*SWFWorkflowControl) CompleteTask ¶
func (*SWFWorkflowControl) GetArtifactLazy ¶
func (s *SWFWorkflowControl) GetArtifactLazy(ctx context.Context, tenantId string, key jobdb.ArtifactKey) jobdb.Artifact
func (*SWFWorkflowControl) GetWaitingTask ¶
func (s *SWFWorkflowControl) GetWaitingTask(ctx context.Context, jobKey jobdb.JobKey) (workflowctl.TaskHandle, error)
func (*SWFWorkflowControl) InspectJob ¶ added in v0.0.24
func (s *SWFWorkflowControl) InspectJob(ctx context.Context, key jobdb.JobKey) (workflowctl.JobInspection, error)
func (*SWFWorkflowControl) ListJobs ¶
func (s *SWFWorkflowControl) ListJobs(ctx context.Context, request jobdb.ListJobsRequest) (jobs []workflowctl.JobItem, nextPage string, err error)
func (*SWFWorkflowControl) StartJob ¶
func (s *SWFWorkflowControl) StartJob(ctx context.Context, req workflowctl.StartJob) (jobdb.JobKey, error)
Click to show internal directories.
Click to hide internal directories.