workflow_v2

package

v0.53.0 Latest Latest Go to latest Published: Sep 4, 2023 License: BSD-3-Clause Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/ovh/cds

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func InsertRun(ctx context.Context, db gorpmapper.SqlExecutorWithTx, wr *sdk.V2WorkflowRun) error
func InsertRunInfo(ctx context.Context, db gorpmapper.SqlExecutorWithTx, ...) error
func InsertRunJob(ctx context.Context, db gorpmapper.SqlExecutorWithTx, ...) error
func InsertRunJobInfo(ctx context.Context, db gorpmapper.SqlExecutorWithTx, ...) error
func LoadBuildingRunWithEndedJobs(ctx context.Context, db gorp.SqlExecutor) ([]sdk.V2WorkflowRun, error)
func LoadCratingWorkflowRunIDs(db gorp.SqlExecutor) ([]string, error)
func LoadDeadJobs(ctx context.Context, db gorp.SqlExecutor) ([]sdk.V2WorkflowRunJob, error)
func LoadOldScheduledRunJob(ctx context.Context, db gorp.SqlExecutor, timeout float64) ([]sdk.V2WorkflowRunJob, error)
func LoadQueuedRunJobByModelTypeAndRegion(ctx context.Context, db gorp.SqlExecutor, regionName string, modelType string) ([]sdk.V2WorkflowRunJob, error)
func LoadRunByID(ctx context.Context, db gorp.SqlExecutor, id string) (*sdk.V2WorkflowRun, error)
func LoadRunByRunNumber(ctx context.Context, db gorp.SqlExecutor, ...) (*sdk.V2WorkflowRun, error)
func LoadRunInfosByRunID(ctx context.Context, db gorp.SqlExecutor, runID string) ([]sdk.V2WorkflowRunInfo, error)
func LoadRunJobByID(ctx context.Context, db gorp.SqlExecutor, jobRunID string) (*sdk.V2WorkflowRunJob, error)
func LoadRunJobByName(ctx context.Context, db gorp.SqlExecutor, wrID string, jobName string) (*sdk.V2WorkflowRunJob, error)
func LoadRunJobInfosByRunID(ctx context.Context, db gorp.SqlExecutor, runJobID string) ([]sdk.V2WorkflowRunJobInfo, error)
func LoadRunJobsByRunID(ctx context.Context, db gorp.SqlExecutor, runID string) ([]sdk.V2WorkflowRunJob, error)
func LoadRunJobsByRunIDAndStatus(ctx context.Context, db gorp.SqlExecutor, runID string, status []string) ([]sdk.V2WorkflowRunJob, error)
func LoadRuns(ctx context.Context, db gorp.SqlExecutor, ...) ([]sdk.V2WorkflowRun, error)
func UpdateJobRun(ctx context.Context, db gorpmapper.SqlExecutorWithTx, ...) error
func UpdateRun(ctx context.Context, db gorpmapper.SqlExecutorWithTx, wr *sdk.V2WorkflowRun) error
func WorkflowRunNextNumber(db gorp.SqlExecutor, repoID, workflowName string) (int64, error)

Constants ¶

View Source

const (
	WorkflowEngineKey = "workflow:engine"
)

Variables ¶

This section is empty.

Functions ¶

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 LoadBuildingRunWithEndedJobs ¶

func LoadBuildingRunWithEndedJobs(ctx context.Context, db gorp.SqlExecutor) ([]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 LoadOldScheduledRunJob ¶

func LoadOldScheduledRunJob(ctx context.Context, db gorp.SqlExecutor, timeout float64) ([]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) (*sdk.V2WorkflowRun, error)

func LoadRunByRunNumber ¶

func LoadRunByRunNumber(ctx context.Context, db gorp.SqlExecutor, projectKey, vcsServerID, repositoryID, wfName string, runNumber int64) (*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) (*sdk.V2WorkflowRunJob, error)

func LoadRunJobInfosByRunID ¶

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

func LoadRunJobsByRunID ¶

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

func LoadRunJobsByRunIDAndStatus ¶

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

func LoadRuns ¶

func LoadRuns(ctx context.Context, db gorp.SqlExecutor, projKey, vcsProjectID, repoID, workflowName string) ([]sdk.V2WorkflowRun, 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 WorkflowRunNextNumber ¶

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

Types ¶

This section is empty.

Source Files ¶

View all Source files

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