workflow_v2

package
v0.55.0 Latest Latest
Warning

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

 Go to latest Published: Jan 6, 2025 License: BSD-3-Clause Imports: 12 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

Functions

func CountAllRuns added in v0.55.0 

func CountAllRuns(ctx context.Context, db gorp.SqlExecutor, filters SearchsRunsFilters) (int64, error)

func CountRunJobsByProjectStatusAndRegions added in v0.55.0 

func CountRunJobsByProjectStatusAndRegions(ctx context.Context, db gorp.SqlExecutor, pkeys []string, statusFilter []sdk.V2WorkflowRunJobStatus, regionsFilter []string) (int64, error)

func CountRuns added in v0.53.1 

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

func DeleteRunByID added in v0.55.0 

func DeleteRunByID(db gorp.SqlExecutor, id string) error

func DeleteWorkflowHooks added in v0.53.1 

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

func DeleteWorkflowVersion added in v0.55.0 

func DeleteWorkflowVersion(ctx context.Context, db gorpmapper.SqlExecutorWithTx, v *sdk.V2WorkflowVersion) 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 InsertWorkflowVersion added in v0.55.0 

func InsertWorkflowVersion(ctx context.Context, db gorpmapper.SqlExecutorWithTx, v *sdk.V2WorkflowVersion) 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 LoadAllVerionsByWorkflow added in v0.55.0 

func LoadAllVerionsByWorkflow(ctx context.Context, db gorp.SqlExecutor, projKey, vcs, repository, wkf string) ([]sdk.V2WorkflowVersion, error)

func LoadAndLockRunByID added in v0.55.0 

func LoadAndLockRunByID(ctx context.Context, db gorp.SqlExecutor, id string, opts ...gorpmapper.GetOptionFunc) (*sdk.V2WorkflowRun, 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 LoadHookHeadRepositoryWebHookByWorkflowAndEvent added in v0.55.0 

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

func LoadHookSchedulerByWorkflow added in v0.55.0 

func LoadHookSchedulerByWorkflow(ctx context.Context, db gorp.SqlExecutor, projKey, vcsName, repoName, workflowName string) ([]sdk.V2WorkflowHook, error)

func LoadHooksByEntityID added in v0.55.0 

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

func LoadHooksByID added in v0.55.0 

func LoadHooksByID(ctx context.Context, db gorp.SqlExecutor, hookID string) (*sdk.V2WorkflowHook, error)

func LoadHooksByModelUpdated added in v0.53.1 

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

func LoadHooksByRepositoryEvent added in v0.53.1 

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

func LoadHooksByWorkflowUpdated added in v0.53.1 

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

func LoadHooksWorkflowRunByWorkflow added in v0.55.0 

func LoadHooksWorkflowRunByWorkflow(ctx context.Context, db gorp.SqlExecutor, 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 LoadRunIDsToDelete added in v0.55.0 

func LoadRunIDsToDelete(ctx context.Context, db gorp.SqlExecutor) ([]string, 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 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 LoadRunJobsByName added in v0.55.0 

func LoadRunJobsByName(ctx context.Context, db gorp.SqlExecutor, wrID string, jobName string, runAttempt int64) ([]sdk.V2WorkflowRunJob, error)

func LoadRunJobsByProjectStatusAndRegions added in v0.55.0 

func LoadRunJobsByProjectStatusAndRegions(ctx context.Context, db gorp.SqlExecutor, pkeys []string, statusFilter []sdk.V2WorkflowRunJobStatus, regionsFilter []string, offset int, limit int) ([]sdk.V2WorkflowRunJob, 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, runAttempt int64) ([]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) ([]sdk.V2WorkflowRunResult, error)

func LoadRunResultsByRunIDAttempt added in v0.55.0 

func LoadRunResultsByRunIDAttempt(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 LoadRunsGitRepositories added in v0.55.0 

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

func LoadRunsTemplates added in v0.55.0 

func LoadRunsTemplates(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 LoadRunsUnsafeWithPagination added in v0.55.0 

func LoadRunsUnsafeWithPagination(ctx context.Context, db gorp.SqlExecutor, offset, limit int) ([]sdk.V2WorkflowRun, error)

func LoadRunsWorkflowNames added in v0.53.1 

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

func LoadRunsWorkflowRefs added in v0.55.0 

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

func LoadRunsWorkflowRepositories added in v0.55.0 

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

func LoadWorkflowVersion added in v0.55.0 

func LoadWorkflowVersion(ctx context.Context, db gorp.SqlExecutor, projKey, vcs, repository, wkf, version string) (*sdk.V2WorkflowVersion, 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 SearchAllRuns added in v0.55.0 

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

func SearchRuns added in v0.53.1 

func SearchRuns(ctx context.Context, db gorp.SqlExecutor, projKey string, filters SearchsRunsFilters, offset, limit uint, sort string, 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 AnnotationsFilter added in v0.55.0 

type AnnotationsFilter struct {
	Key    string         `db:"key"`
	Values pq.StringArray `db:"values"`
}

type AnnotationsFilters added in v0.55.0 

type AnnotationsFilters []AnnotationsFilter

func LoadRunsAnnotations added in v0.55.0 

func LoadRunsAnnotations(ctx context.Context, db gorp.SqlExecutor, projKey string) (AnnotationsFilters, error)

type SearchsRunsFilters added in v0.53.1 

type SearchsRunsFilters struct {
	Workflows            []string
	Actors               []string
	Status               []string
	Refs                 []string
	WorkflowRefs         []string
	Repositories         []string
	WorkflowRepositories []string
	Commits              []string
	Templates            []string
	AnnotationKeys       []string
	AnnotationValues     []string
}

func (SearchsRunsFilters) Lower added in v0.55.0 

func (s SearchsRunsFilters) Lower()

type V2WorkflowVersionWorkflowShort added in v0.55.0 

type V2WorkflowVersionWorkflowShort struct {
	DistinctID         string `db:"id"`
	ProjectKey         string `db:"project_key"`
	WorkflowVCS        string `db:"workflow_vcs"`
	WorkflowRepository string `db:"workflow_repository"`
	WorkflowName       string `db:"workflow_name"`
}

func LoadDistinctWorkflowVersionByWorkflow added in v0.55.0 

func LoadDistinctWorkflowVersionByWorkflow(ctx context.Context, db gorp.SqlExecutor) ([]V2WorkflowVersionWorkflowShort, error)

func (V2WorkflowVersionWorkflowShort) String added in v0.55.0 

func (w V2WorkflowVersionWorkflowShort) String() 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.