workflow_v2

package

Go to main page

Versions in this module

v0

v0.56.0

Sep 4, 2025

Changes in this version

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

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

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

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

type SearchRunsFilters

+ Authors []string

v0.55.2

May 7, 2025

Changes in this version

+ func CountBlockedRunWithProjectConcurrency(ctx context.Context, db gorp.SqlExecutor, proj string, concurrencyName string) (int64, error)

+ func CountBlockedWithWorkflowConcurrency(ctx context.Context, db gorp.SqlExecutor, proj string, vcs string, repo string, ...) (int64, error)

+ func CountRunningWithProjectConcurrency(ctx context.Context, db gorp.SqlExecutor, proj string, concurrencyName string) (int64, error)

+ func CountRunningWithWorkflowConcurrency(ctx context.Context, db gorp.SqlExecutor, proj string, vcs string, repo string, ...) (int64, error)

+ func DeleteWorkflowHookByID(ctx context.Context, db gorpmapper.SqlExecutorWithTx, hookID string) error

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

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

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

+ func LoadHooksWorkflowRunByListeningWorkflow(ctx context.Context, db gorp.SqlExecutor, workflowName string) ([]sdk.V2WorkflowHook, error)

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

+ func LoadProjectConccurencyRunObjects(ctx context.Context, db gorp.SqlExecutor, proj string, concurrencyName string) ([]sdk.ProjectConcurrencyRunObject, error)

+ type ConcurrencyObject struct

+ ID string

+ Type ConcurrencyObjectType

+ func LoadNewestRunJobWithProjectScopedConcurrency(ctx context.Context, db gorp.SqlExecutor, proj string, concurrencyName string, ...) ([]ConcurrencyObject, error)

+ func LoadNewestRunJobWithWorkflowScopedConcurrency(ctx context.Context, db gorp.SqlExecutor, proj string, vcs string, repo string, ...) ([]ConcurrencyObject, error)

+ func LoadOldestRunJobWithProjectScopedConcurrency(ctx context.Context, db gorp.SqlExecutor, proj string, concurrencyName string, ...) ([]ConcurrencyObject, error)

+ func LoadOldestRunJobWithWorkflowScopedConcurrency(ctx context.Context, db gorp.SqlExecutor, proj string, vcs string, repo string, ...) ([]ConcurrencyObject, error)

+ type ConcurrencyObjectType string

+ const ConcurrencyObjectTypeJob

+ const ConcurrencyObjectTypeWorkflow

+ type ConcurrencyRule struct

+ Cancel bool

+ MinPool int64

+ Order string

+ func LoadProjectConcurrencyRules(ctx context.Context, db gorp.SqlExecutor, proj string, concurrencyName string) ([]ConcurrencyRule, error)

+ func LoadWorkflowConcurrencyRules(ctx context.Context, db gorp.SqlExecutor, proj string, vcs string, repo string, ...) ([]ConcurrencyRule, error)

v0.55.1

Feb 17, 2025

Changes in this version

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

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

+ type SearchRunsFilters struct

+ Actors []string

+ AnnotationKeys []string

+ AnnotationValues []string

+ Commits []string

+ Refs []string

+ Repositories []string

+ Status []string

+ Templates []string

+ WorkflowRefs []string

+ WorkflowRepositories []string

+ Workflows []string

+ func (s SearchRunsFilters) Lower()

v0.55.0

Jan 6, 2025

Changes in this version

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

+ func CountRunJobsByProjectStatusAndRegions(ctx context.Context, db gorp.SqlExecutor, pkeys []string, ...) (int64, error)

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

+ func DeleteWorkflowVersion(ctx context.Context, db gorpmapper.SqlExecutorWithTx, v *sdk.V2WorkflowVersion) error

+ func InsertWorkflowVersion(ctx context.Context, db gorpmapper.SqlExecutorWithTx, v *sdk.V2WorkflowVersion) error

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

+ func LoadAndLockRunByID(ctx context.Context, db gorp.SqlExecutor, id string, ...) (*sdk.V2WorkflowRun, error)

+ func LoadHookHeadRepositoryWebHookByWorkflowAndEvent(ctx context.Context, db gorp.SqlExecutor, ...) (*sdk.V2WorkflowHook, error)

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

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

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

+ func LoadHooksWorkflowRunByWorkflow(ctx context.Context, db gorp.SqlExecutor, workflowName string) ([]sdk.V2WorkflowHook, error)

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

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

+ func LoadRunJobsByProjectStatusAndRegions(ctx context.Context, db gorp.SqlExecutor, pkeys []string, ...) ([]sdk.V2WorkflowRunJob, error)

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

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

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

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

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

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

+ func LoadWorkflowVersion(ctx context.Context, db gorp.SqlExecutor, ...) (*sdk.V2WorkflowVersion, error)

+ func SearchAllRuns(ctx context.Context, db gorp.SqlExecutor, filters SearchsRunsFilters, ...) ([]sdk.V2WorkflowRun, error)

+ type AnnotationsFilter struct

+ Key string

+ Values pq.StringArray

+ type AnnotationsFilters []AnnotationsFilter

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

type SearchsRunsFilters

+ AnnotationKeys []string

+ AnnotationValues []string

+ Commits []string

+ Refs []string

+ Templates []string

+ WorkflowRefs []string

+ WorkflowRepositories []string

+ func (s SearchsRunsFilters) Lower()

+ type V2WorkflowVersionWorkflowShort struct

+ DistinctID string

+ ProjectKey string

+ WorkflowName string

+ WorkflowRepository string

+ WorkflowVCS string

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

+ func (w V2WorkflowVersionWorkflowShort) String() string

v0.54.1

Mar 29, 2024

v0.54.0

Mar 28, 2024

v0.53.1

Mar 26, 2024

Changes in this version

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

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

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

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

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

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

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

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

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

+ func LoadHooksByWorkflowUpdated(ctx context.Context, db gorp.SqlExecutor, ...) (*sdk.V2WorkflowHook, error)

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

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

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

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

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

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

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

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

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

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

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

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

+ func SearchRuns(ctx context.Context, db gorp.SqlExecutor, projKey string, ...) ([]sdk.V2WorkflowRun, error)

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

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

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

+ type SearchsRunsFilters struct

+ Actors []string

+ Branches []string

+ Repositories []string

+ Status []string

+ Workflows []string

v0.53.0

Sep 4, 2023

Changes in this version

+ const WorkflowEngineKey

+ 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)

v0.0.1-sgu-test

Mar 12, 2026

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