workflow_v2

package
v0.54.1 Latest Latest
Warning

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

 Go to latest Published: Mar 29, 2024 License: BSD-3-Clause Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	WorkflowEngineKey = "workflow:engine"
)

Variables

This section is empty.

Functions

func CountRuns added in v0.53.1 

func CountRuns(ctx context.Context, db gorp.SqlExecutor, projKey string, filters SearchsRunsFilters) (int64, error)

func DeleteWorkflowHooks added in v0.53.1 

func DeleteWorkflowHooks(ctx context.Context, db gorpmapper.SqlExecutorWithTx, entityID string) error

func InsertRun 

func InsertRun(ctx context.Context, db gorpmapper.SqlExecutorWithTx, wr *sdk.V2WorkflowRun) error

func InsertRunInfo 

func InsertRunInfo(ctx context.Context, db gorpmapper.SqlExecutorWithTx, info *sdk.V2WorkflowRunInfo) error

func InsertRunJob 

func InsertRunJob(ctx context.Context, db gorpmapper.SqlExecutorWithTx, wrj *sdk.V2WorkflowRunJob) error

func InsertRunJobInfo 

func InsertRunJobInfo(ctx context.Context, db gorpmapper.SqlExecutorWithTx, info *sdk.V2WorkflowRunJobInfo) error

func InsertRunResult added in v0.53.1 

func InsertRunResult(ctx context.Context, db gorp.SqlExecutor, runResult *sdk.V2WorkflowRunResult) error

func InsertWorkflowHook added in v0.53.1 

func InsertWorkflowHook(ctx context.Context, db gorpmapper.SqlExecutorWithTx, h *sdk.V2WorkflowHook) error

func LoadAbandonnedRunResultsID added in v0.53.1 

func LoadAbandonnedRunResultsID(ctx context.Context, db gorp.SqlExecutor) ([]string, error)

func LoadAllHooksUnsafe added in v0.53.1 

func LoadAllHooksUnsafe(ctx context.Context, db gorp.SqlExecutor) ([]sdk.V2WorkflowHook, error)

func LoadAndLockRunResultByID added in v0.53.1 

func LoadAndLockRunResultByID(ctx context.Context, db gorp.SqlExecutor, id string) (*sdk.V2WorkflowRunResult, error)

func LoadBuildingRunWithEndedJobs 

func LoadBuildingRunWithEndedJobs(ctx context.Context, db gorp.SqlExecutor, opts ...gorpmapper.GetOptionFunc) ([]sdk.V2WorkflowRun, error)

func LoadCratingWorkflowRunIDs 

func LoadCratingWorkflowRunIDs(db gorp.SqlExecutor) ([]string, error)

func LoadDeadJobs 

func LoadDeadJobs(ctx context.Context, db gorp.SqlExecutor) ([]sdk.V2WorkflowRunJob, error)

func LoadHooksByModelUpdated added in v0.53.1 

func LoadHooksByModelUpdated(ctx context.Context, db gorp.SqlExecutor, models []string) ([]sdk.V2WorkflowHook, error)

func LoadHooksByRepositoryEvent added in v0.53.1 

func LoadHooksByRepositoryEvent(ctx context.Context, db gorp.SqlExecutor, vcsName, repoName, eventName string) ([]sdk.V2WorkflowHook, error)

func LoadHooksByWorkflowUpdated added in v0.53.1 

func LoadHooksByWorkflowUpdated(ctx context.Context, db gorp.SqlExecutor, projKey, vcsName, repoName, workflowName string) (*sdk.V2WorkflowHook, error)

func LoadOldScheduledRunJob 

func LoadOldScheduledRunJob(ctx context.Context, db gorp.SqlExecutor, timeout int64) ([]sdk.V2WorkflowRunJob, error)

func LoadQueuedRunJobByModelTypeAndRegion 

func LoadQueuedRunJobByModelTypeAndRegion(ctx context.Context, db gorp.SqlExecutor, regionName string, modelType string) ([]sdk.V2WorkflowRunJob, error)

func LoadRunByID 

func LoadRunByID(ctx context.Context, db gorp.SqlExecutor, id string, opts ...gorpmapper.GetOptionFunc) (*sdk.V2WorkflowRun, error)

func LoadRunByProjectKeyAndID added in v0.53.1 

func LoadRunByProjectKeyAndID(ctx context.Context, db gorp.SqlExecutor, projectKey, id string, opts ...gorpmapper.GetOptionFunc) (*sdk.V2WorkflowRun, error)

func LoadRunByRunNumber 

func LoadRunByRunNumber(ctx context.Context, db gorp.SqlExecutor, projectKey, vcsServerID, repositoryID, wfName string, runNumber int64, opts ...gorpmapper.GetOptionFunc) (*sdk.V2WorkflowRun, error)

func LoadRunInfosByRunID 

func LoadRunInfosByRunID(ctx context.Context, db gorp.SqlExecutor, runID string) ([]sdk.V2WorkflowRunInfo, error)

func LoadRunJobByID 

func LoadRunJobByID(ctx context.Context, db gorp.SqlExecutor, jobRunID string) (*sdk.V2WorkflowRunJob, error)

func LoadRunJobByName 

func LoadRunJobByName(ctx context.Context, db gorp.SqlExecutor, wrID string, jobName string, runAttempt int64) (*sdk.V2WorkflowRunJob, error)

func LoadRunJobByRunIDAndID added in v0.53.1 

func LoadRunJobByRunIDAndID(ctx context.Context, db gorp.SqlExecutor, wrID, jobRunID string) (*sdk.V2WorkflowRunJob, error)

func LoadRunJobInfosByRunJobID added in v0.53.1 

func LoadRunJobInfosByRunJobID(ctx context.Context, db gorp.SqlExecutor, runJobID string) ([]sdk.V2WorkflowRunJobInfo, error)

func LoadRunJobsByRunID 

func LoadRunJobsByRunID(ctx context.Context, db gorp.SqlExecutor, runID string, runAttempt int64) ([]sdk.V2WorkflowRunJob, error)

func LoadRunJobsByRunIDAndStatus 

func LoadRunJobsByRunIDAndStatus(ctx context.Context, db gorp.SqlExecutor, runID string, status []string) ([]sdk.V2WorkflowRunJob, error)

func LoadRunResult added in v0.53.1 

func LoadRunResult(ctx context.Context, db gorp.SqlExecutor, runID string, id string) (*sdk.V2WorkflowRunResult, error)

func LoadRunResultsByRunID added in v0.53.1 

func LoadRunResultsByRunID(ctx context.Context, db gorp.SqlExecutor, runID string, runAttempt int64) ([]sdk.V2WorkflowRunResult, error)

func LoadRunResultsByRunJobID added in v0.53.1 

func LoadRunResultsByRunJobID(ctx context.Context, db gorp.SqlExecutor, runJobID string) ([]sdk.V2WorkflowRunResult, error)

func LoadRuns 

func LoadRuns(ctx context.Context, db gorp.SqlExecutor, projKey, vcsProjectID, repoID, workflowName string, opts ...gorpmapper.GetOptionFunc) ([]sdk.V2WorkflowRun, error)

func LoadRunsActors added in v0.53.1 

func LoadRunsActors(ctx context.Context, db gorp.SqlExecutor, projKey string) ([]string, error)

func LoadRunsGitRefs added in v0.53.1 

func LoadRunsGitRefs(ctx context.Context, db gorp.SqlExecutor, projKey string) ([]string, error)

func LoadRunsRepositories added in v0.53.1 

func LoadRunsRepositories(ctx context.Context, db gorp.SqlExecutor, projKey string) ([]string, error)

func LoadRunsUnsafe added in v0.53.1 

func LoadRunsUnsafe(ctx context.Context, db gorp.SqlExecutor) ([]sdk.V2WorkflowRun, error)

func LoadRunsWorkflowNames added in v0.53.1 

func LoadRunsWorkflowNames(ctx context.Context, db gorp.SqlExecutor, projKey string) ([]string, error)

func RetrieveJobToKeep added in v0.53.1 

func RetrieveJobToKeep(_ context.Context, w sdk.V2Workflow, runJobsMap map[string]sdk.V2WorkflowRunJob, runJobToRestart map[string]sdk.V2WorkflowRunJob) map[string]sdk.V2WorkflowRunJob

func SearchRuns added in v0.53.1 

func SearchRuns(ctx context.Context, db gorp.SqlExecutor, projKey string, filters SearchsRunsFilters, offset, limit uint, opts ...gorpmapper.GetOptionFunc) ([]sdk.V2WorkflowRun, error)

func UnsafeLoadAllRunJobs added in v0.53.1 

func UnsafeLoadAllRunJobs(ctx context.Context, db gorp.SqlExecutor) ([]sdk.V2WorkflowRunJob, error)

func UpdateJobRun 

func UpdateJobRun(ctx context.Context, db gorpmapper.SqlExecutorWithTx, wrj *sdk.V2WorkflowRunJob) error

func UpdateRun 

func UpdateRun(ctx context.Context, db gorpmapper.SqlExecutorWithTx, wr *sdk.V2WorkflowRun) error

func UpdateRunResult added in v0.53.1 

func UpdateRunResult(ctx context.Context, db gorp.SqlExecutor, runResult *sdk.V2WorkflowRunResult) error

func UpdateWorkflowHook added in v0.53.1 

func UpdateWorkflowHook(ctx context.Context, db gorpmapper.SqlExecutorWithTx, h *sdk.V2WorkflowHook) error

func WorkflowRunNextNumber 

func WorkflowRunNextNumber(db gorp.SqlExecutor, repoID, workflowName string) (int64, error)

Types

type SearchsRunsFilters added in v0.53.1 

type SearchsRunsFilters struct {
	Workflows    []string
	Actors       []string
	Status       []string
	Branches     []string
	Repositories []string
}

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.