Versions in this module Expand all Collapse all v0 v0.55.2 May 7, 2025 v0.55.1 Feb 17, 2025 v0.55.0 Jan 6, 2025 v0.54.1 Mar 29, 2024 v0.54.0 Mar 28, 2024 v0.53.1 Mar 26, 2024 Changes in this version + func LoadAndLockTerminatedNodeJobRun(ctx context.Context, db gorp.SqlExecutor, limit int) ([]sdk.WorkflowNodeJobRun, error) + func LoadCraftingWorkflowRunIDs(db gorp.SqlExecutor) ([]int64, error) type QueueFilter + SkipBooked bool v0.53.0 Sep 4, 2023 Changes in this version + type ArtifactSignature map[string]string type JobRun + Contexts sdk.JobRunContext type NodeRun + Contexts sdk.NodeRunContext v0.52.0 Sep 26, 2022 Changes in this version + func CountRunSecretsByWorkflowRunID(ctx context.Context, db gorp.SqlExecutor, workflowRunID int64) (int64, error) + func DeleteRunSecretsByWorkflowRunID(ctx context.Context, db gorpmapper.SqlExecutorWithTx, workflowRunID int64) error + func FindOldestWorkflowRunsWithResultToSync(ctx context.Context, dbmap *gorp.DbMap) ([]int64, error) + func IsSameCommit(sha1, sha1b string) bool + func LoadRunResultsByRunIDFilterByIDs(ctx context.Context, db gorp.SqlExecutor, runID int64, resultIDs ...string) (sdk.WorkflowRunResults, error) + func LoadRunResultsByRunIDUnique(ctx context.Context, db gorp.SqlExecutor, runID int64) (sdk.WorkflowRunResults, error) + func LoadRunsIDsCreatedBefore(ctx context.Context, db gorp.SqlExecutor, date time.Time, limit int64) ([]int64, error) + func ProcessRunResultPromotionByRunID(ctx context.Context, db gorpmapper.SqlExecutorWithTx, workflowRunID int64, ...) error + func ResyncWorkflowRunResultsRoutine(ctx context.Context, DBFunc func() *gorp.DbMap, delay time.Duration) + func SetRunReadOnlyByID(ctx context.Context, db gorpmapper.SqlExecutorWithTx, workflowRunID int64) error + func SyncRunResultArtifactManagerByRunID(ctx context.Context, db gorpmapper.SqlExecutorWithTx, workflowRunID int64) error + func UpdateRunResult(ctx context.Context, db gorp.SqlExecutor, result *sdk.WorkflowRunResult) error type LoadAllWorkflowsOptionsFilters + AsCode bool v0.50.0 Dec 14, 2021 Changes in this version + const SecretAppContext + const SecretApplicationIntegrationContext + const SecretEnvContext + const SecretProjContext + const SecretProjIntegrationContext + const WorkflowAsCodePattern + var Audits = map[string]sdk.Audit + var KeyResult = cache.Key("run", "result") + func AddResult(ctx context.Context, db *gorp.DbMap, store cache.Store, wr *sdk.WorkflowRun, ...) error + func AddSpawnInfosNodeJobRun(db gorp.SqlExecutor, nodeID, jobID int64, infos []sdk.SpawnInfo) error + func AddWorkflowIntegration(db gorp.SqlExecutor, integ *sdk.WorkflowProjectIntegration) error + func AddWorkflowRunInfo(run *sdk.WorkflowRun, infos ...sdk.SpawnMsg) + func AggregateOnWorkflowTemplateInstance(ctx context.Context, db gorp.SqlExecutor, ...) error + func BookNodeJobRun(ctx context.Context, store cache.Store, id int64, hatchery *sdk.Service) (*sdk.Service, error) + func CanBeRun(workflowRun *sdk.WorkflowRun, workflowNodeRun *sdk.WorkflowNodeRun) bool + func CanUploadRunResult(ctx context.Context, db *gorp.DbMap, store cache.Store, wr sdk.WorkflowRun, ...) (bool, error) + func CheckRegion(ctx context.Context, db gorp.SqlExecutor, proj sdk.Project, wf sdk.Workflow) error + func CheckValidity(_ context.Context, _ gorp.SqlExecutor, w *sdk.Workflow) error + func CompleteWorkflow(ctx context.Context, db gorp.SqlExecutor, w *sdk.Workflow, proj sdk.Project, ...) error + func ComputeLatestDefaultBranchReport(ctx context.Context, db gorpmapper.SqlExecutorWithTx, cache cache.Store, ...) error + func ComputeNewReport(ctx context.Context, db gorpmapper.SqlExecutorWithTx, cache cache.Store, ...) error + func CountNodeJobRunQueue(ctx context.Context, db gorp.SqlExecutor, store cache.Store, ...) (sdk.WorkflowNodeJobRunCount, error) + func CountNodeJobRunQueueByGroupIDs(ctx context.Context, db gorp.SqlExecutor, store cache.Store, ...) (sdk.WorkflowNodeJobRunCount, error) + func CountNotPendingWorkflowRunsByWorkflowID(db gorp.SqlExecutor, workflowID int64) (int64, error) + func CountPipeline(db gorp.SqlExecutor, pipelineID int64) (bool, error) + func CountRepositoryWebHooksByApplication(db gorp.SqlExecutor, appID int64) (int64, error) + func CountWorkflowRunsMarkToDelete(ctx context.Context, db gorp.SqlExecutor, ...) int64 + func CreateBuiltinWorkflowHookModels(db *gorp.DbMap) error + func CreateBuiltinWorkflowOutgoingHookModels(db *gorp.DbMap) error + func CreateRun(db *gorp.DbMap, wf *sdk.Workflow, opts sdk.WorkflowRunPostHandlerOption) (*sdk.WorkflowRun, error) + func DefaultPayload(ctx context.Context, db gorpmapper.SqlExecutorWithTx, store cache.Store, ...) (interface{}, error) + func Delete(ctx context.Context, db gorpmapper.SqlExecutorWithTx, store cache.Store, ...) error + func DeleteIntegrationsFromWorkflow(db gorp.SqlExecutor, workflowID int64) error + func DeleteNodeJobRun(db gorp.SqlExecutor, nodeRunJob int64) error + func DeleteNodeJobRuns(db gorp.SqlExecutor, nodeID int64) error + func DeleteNotifications(db gorp.SqlExecutor, workflowID int64) error + func DeleteWorkflowData(db gorp.SqlExecutor, wf sdk.Workflow) error + func Exists(ctx context.Context, db gorp.SqlExecutor, key string, name string) (bool, error) + func ExistsID(ctx context.Context, db gorp.SqlExecutor, key string, id int64) (bool, error) + func Export(ctx context.Context, db gorp.SqlExecutor, cache cache.Store, proj sdk.Project, ...) (exportentities.Workflow, error) + func FreeNodeJobRun(ctx context.Context, store cache.Store, id int64) error + func GetNodeRunBuildCommits(ctx context.Context, db gorpmapper.SqlExecutorWithTx, store cache.Store, ...) ([]sdk.VCSCommit, sdk.BuildNumberAndHash, error) + func GetRunResultKey(runID int64, t sdk.WorkflowRunResultType, fileName string) string + func GetTagsAndValue(db gorp.SqlExecutor, key, name string) (map[string][]string, error) + func Import(ctx context.Context, db gorpmapper.SqlExecutorWithTx, store cache.Store, ...) error + func Initialize(ctx context.Context, DBFunc func() *gorp.DbMap, store cache.Store, ...) + func Insert(ctx context.Context, db gorpmapper.SqlExecutorWithTx, store cache.Store, ...) error + func InsertArtifact(db gorp.SqlExecutor, a *sdk.WorkflowNodeRunArtifact) error + func InsertAudit(db gorp.SqlExecutor, a *sdk.AuditWorkflow) error + func InsertCoverage(db gorp.SqlExecutor, cov sdk.WorkflowNodeRunCoverage) error + func InsertHookModel(db gorp.SqlExecutor, m *sdk.WorkflowHookModel) error + func InsertNotification(db gorp.SqlExecutor, w *sdk.Workflow, n *sdk.WorkflowNotification) error + func InsertOutgoingHookModel(db gorp.SqlExecutor, m *sdk.WorkflowHookModel) error + func InsertRunNum(db gorp.SqlExecutor, w *sdk.Workflow, num int64) error + func InsertRunSecret(ctx context.Context, db gorpmapper.SqlExecutorWithTx, ...) error + func InsertStaticFiles(db gorp.SqlExecutor, sf *sdk.StaticFiles) error + func InsertVulnerabilityReport(db gorp.SqlExecutor, report *sdk.WorkflowNodeRunVulnerabilityReport) error + func InsertWorkflowData(db gorp.SqlExecutor, w *sdk.Workflow) error + func InsertWorkflowRunTags(db gorp.SqlExecutor, runID int64, runTags []sdk.WorkflowRunTag) error + func IsDeploymentIntegrationUsed(db gorp.SqlExecutor, projectID int64, appID int64, pfName string) (bool, error) + func IsFavorite(db gorp.SqlExecutor, w *sdk.Workflow, uID string) (bool, error) + func LabelWorkflow(db gorp.SqlExecutor, labelID, workflowID int64) error + func Load(ctx context.Context, db gorp.SqlExecutor, _ cache.Store, proj sdk.Project, ...) (*sdk.Workflow, error) + func LoadAll(ctx context.Context, db gorp.SqlExecutor, projectKey string) (sdk.Workflows, error) + func LoadAllByIDs(ctx context.Context, db gorp.SqlExecutor, ids []int64) (sdk.Workflows, error) + func LoadAllHooks(db gorp.SqlExecutor) ([]sdk.NodeHook, error) + func LoadAllNames(db gorp.SqlExecutor, projID int64) (sdk.IDNames, error) + func LoadAllNamesByProjectIDs(_ context.Context, db gorp.SqlExecutor, projectIDs []int64) ([]sdk.WorkflowName, error) + func LoadAndLockNodeJobRunSkipLocked(ctx context.Context, db gorp.SqlExecutor, store cache.Store, id int64) (*sdk.WorkflowNodeJobRun, error) + func LoadAndLockNodeJobRunWait(ctx context.Context, db gorp.SqlExecutor, store cache.Store, id int64) (*sdk.WorkflowNodeJobRun, error) + func LoadAndLockNodeRunByID(ctx context.Context, db gorp.SqlExecutor, id int64) (*sdk.WorkflowNodeRun, error) + func LoadAndLockNodeRunByJobID(ctx context.Context, db gorp.SqlExecutor, jobID int64) (*sdk.WorkflowNodeRun, error) + func LoadAndLockRunByID(ctx context.Context, db gorp.SqlExecutor, id int64, loadOpts LoadRunOptions) (*sdk.WorkflowRun, error) + func LoadAndLockRunByJobID(ctx context.Context, db gorp.SqlExecutor, id int64, loadOpts LoadRunOptions) (*sdk.WorkflowRun, error) + func LoadApplicationSecrets(db gorp.SqlExecutor, id int64) ([]sdk.Variable, error) + func LoadArtifactByIDs(db gorp.SqlExecutor, workflowID, artifactID int64) (*sdk.WorkflowNodeRunArtifact, error) + func LoadAudit(db gorp.SqlExecutor, auditID int64, workflowID int64) (sdk.AuditWorkflow, error) + func LoadAudits(db gorp.SqlExecutor, workflowID int64) ([]sdk.AuditWorkflow, error) + func LoadByApplicationName(ctx context.Context, db gorp.SqlExecutor, projectKey string, appName string) ([]sdk.WorkflowName, error) + func LoadByEnvName(ctx context.Context, db gorp.SqlExecutor, projectKey string, envName string) ([]sdk.WorkflowName, error) + func LoadByID(ctx context.Context, db gorp.SqlExecutor, _ cache.Store, proj sdk.Project, ...) (*sdk.Workflow, error) + func LoadByPipelineName(ctx context.Context, db gorp.SqlExecutor, projectKey string, pipName string) ([]sdk.WorkflowName, error) + func LoadByRepo(ctx context.Context, db gorp.SqlExecutor, proj sdk.Project, repo string, ...) (*sdk.Workflow, error) + func LoadByWorkflowTemplateID(ctx context.Context, db gorp.SqlExecutor, templateID int64) ([]sdk.WorkflowName, error) + func LoadCoverageReport(db gorp.SqlExecutor, workflowNodeRunID int64) (sdk.WorkflowNodeRunCoverage, error) + func LoadCratingWorkflowRunIDs(db gorp.SqlExecutor) ([]int64, error) + func LoadCurrentRunNum(db gorp.SqlExecutor, projectkey, workflowname string) (int64, error) + func LoadDeadNodeJobRun(ctx context.Context, db gorp.SqlExecutor, store cache.Store) ([]sdk.WorkflowNodeJobRun, error) + func LoadDecryptSecrets(ctx context.Context, db gorp.SqlExecutor, wr *sdk.WorkflowRun, ...) ([]sdk.Variable, error) + func LoadEnvironmentSecrets(db gorp.SqlExecutor, id int64) ([]sdk.Variable, error) + func LoadHookByUUID(db gorp.SqlExecutor, uuid string) (sdk.NodeHook, error) + func LoadHookModelByID(db gorp.SqlExecutor, id int64) (*sdk.WorkflowHookModel, error) + func LoadHookModelByName(db gorp.SqlExecutor, name string) (*sdk.WorkflowHookModel, error) + func LoadHookModels(db gorp.SqlExecutor) ([]sdk.WorkflowHookModel, error) + func LoadLabels(db gorp.SqlExecutor, workflowIDs ...int64) ([]sdk.Label, error) + func LoadLastRun(ctx context.Context, db gorp.SqlExecutor, projectkey, workflowname string, ...) (*sdk.WorkflowRun, error) + func LoadLastRuns(ctx context.Context, db gorp.SqlExecutor, workflowIDs []int64, limit int) ([]sdk.WorkflowRun, error) + func LoadNodeJobRun(ctx context.Context, db gorp.SqlExecutor, store cache.Store, id int64) (*sdk.WorkflowNodeJobRun, error) + func LoadNodeJobRunIDByNodeRunID(db gorp.SqlExecutor, runNodeID int64) ([]int64, error) + func LoadNodeJobRunQueue(ctx context.Context, db gorp.SqlExecutor, store cache.Store, ...) ([]sdk.WorkflowNodeJobRun, error) + func LoadNodeJobRunQueueByGroupIDs(ctx context.Context, db gorp.SqlExecutor, store cache.Store, ...) ([]sdk.WorkflowNodeJobRun, error) + func LoadNodeRun(db gorp.SqlExecutor, projectkey, workflowname string, noderunID int64, ...) (*sdk.WorkflowNodeRun, error) + func LoadNodeRunByID(ctx context.Context, db gorp.SqlExecutor, id int64, loadOpts LoadRunOptions) (*sdk.WorkflowNodeRun, error) + func LoadNodeRunByNodeJobID(db gorp.SqlExecutor, nodeJobRunID int64, loadOpts LoadRunOptions) (*sdk.WorkflowNodeRun, error) + func LoadNodeRunDistinctExecutionIDs(db gorp.SqlExecutor) ([]string, error) + func LoadNodeRunJobInfo(ctx context.Context, db gorp.SqlExecutor, nodeRunID int64, jobID int64) ([]sdk.SpawnInfo, error) + func LoadNotificationsByWorkflowIDs(db gorp.SqlExecutor, ids []int64) (map[int64][]sdk.WorkflowNotification, error) + func LoadOutgoingHookModelByID(db gorp.SqlExecutor, id int64) (*sdk.WorkflowHookModel, error) + func LoadOutgoingHookModelByName(db gorp.SqlExecutor, name string) (*sdk.WorkflowHookModel, error) + func LoadOutgoingHookModels(db gorp.SqlExecutor) ([]sdk.WorkflowHookModel, error) + func LoadRun(ctx context.Context, db gorp.SqlExecutor, projectkey, workflowname string, ...) (*sdk.WorkflowRun, error) + func LoadRunByID(ctx context.Context, db gorp.SqlExecutor, id int64, loadOpts LoadRunOptions) (*sdk.WorkflowRun, error) + func LoadRunByIDAndProjectKey(ctx context.Context, db gorp.SqlExecutor, projectkey string, id int64, ...) (*sdk.WorkflowRun, error) + func LoadRunByJobID(ctx context.Context, db gorp.SqlExecutor, id int64, loadOpts LoadRunOptions) (*sdk.WorkflowRun, error) + func LoadRunResultsByNodeRunID(ctx context.Context, db gorp.SqlExecutor, nodeRunID int64) ([]sdk.WorkflowRunResult, error) + func LoadRunResultsByRunID(ctx context.Context, db gorp.SqlExecutor, runID int64) ([]sdk.WorkflowRunResult, error) + func LoadRunResultsByRunIDAndType(ctx context.Context, db gorp.SqlExecutor, runID int64, ...) ([]sdk.WorkflowRunResult, error) + func LoadRunsIDByTag(db gorp.SqlExecutor, projectKey, workflowName, tag, tagValue string) ([]int64, error) + func LoadRunsIDsToDelete(db gorp.SqlExecutor, offset int64, limit int64) ([]int64, int64, int64, int64, error) + func LoadRunsSummaries(ctx context.Context, db gorp.SqlExecutor, projectkey, workflowname string, ...) ([]sdk.WorkflowRunSummary, int, int, int, error) + func LoadWorkflowFromWorkflowRunID(db gorp.SqlExecutor, wrID int64) (sdk.Workflow, error) + func LoadWorkflowIntegrationsByWorkflowID(ctx context.Context, db gorp.SqlExecutor, id int64) ([]sdk.WorkflowProjectIntegration, error) + func LoadWorkfowArtifactByHash(db gorp.SqlExecutor, hash string) (*sdk.WorkflowNodeRunArtifact, error) + func MarkAsDelete(ctx context.Context, db gorpmapper.SqlExecutorWithTx, cache cache.Store, ...) error + func MarkAsDeleteWithDependencies(ctx context.Context, db gorpmapper.SqlExecutorWithTx, cache cache.Store, ...) error + func MarkWorkflowRunsAsDelete(db gorp.SqlExecutor, ids []int64) error + func MaxSubNumber(workflowNodeRuns map[int64][]sdk.WorkflowNodeRun) int64 + func MergeArtifactWithPreviousSubRun(runs []sdk.WorkflowNodeRun) []sdk.WorkflowNodeRunArtifact + func NextRunNumber(db gorp.SqlExecutor, workflowID int64) (int64, error) + func NodeBuildParametersFromRun(wr sdk.WorkflowRun, id int64) ([]sdk.Parameter, error) + func NodeBuildParametersFromWorkflow(proj sdk.Project, wf *sdk.Workflow, refNode *sdk.Node, ancestorsIds []int64) ([]sdk.Parameter, error) + func Parse(ctx context.Context, proj sdk.Project, oldW *sdk.Workflow, ...) (*sdk.Workflow, error) + func ParseAndImport(ctx context.Context, db gorpmapper.SqlExecutorWithTx, store cache.Store, ...) (*sdk.Workflow, []sdk.Message, error) + func PrepareSpawnInfos(infos []sdk.SpawnInfo) []sdk.SpawnInfo + func PreviousNodeRun(db gorp.SqlExecutor, nr sdk.WorkflowNodeRun, nodeName string, workflowID int64) (*sdk.WorkflowNodeRun, error) + func PreviousNodeRunVCSInfos(ctx context.Context, db gorp.SqlExecutor, projectKey string, wf sdk.Workflow, ...) (sdk.BuildNumberAndHash, error) + func Pull(ctx context.Context, db gorp.SqlExecutor, cache cache.Store, proj sdk.Project, ...) (exportentities.WorkflowComponents, error) + func PurgeAllWorkflowRunsByWorkflowID(ctx context.Context, db gorp.SqlExecutor, id int64) (int, error) + func PurgeAudits(ctx context.Context, db gorp.SqlExecutor) error + func PurgeWorkflowRun(ctx context.Context, db gorp.SqlExecutor, wf sdk.Workflow) error + func ReadCDSFiles(files map[string][]byte) (*tar.Reader, error) + func RemoveIntegrationFromWorkflow(db gorp.SqlExecutor, workflowInteg sdk.WorkflowProjectIntegration) error + func RenameNode(ctx context.Context, db gorp.SqlExecutor, w *sdk.Workflow) error + func RestartWorkflowNodeJob(ctx context.Context, db gorp.SqlExecutor, wNodeJob sdk.WorkflowNodeJobRun, ...) error + func Resync(ctx context.Context, db gorp.SqlExecutor, store cache.Store, proj sdk.Project, ...) error + func ResyncCommitStatus(ctx context.Context, db *gorp.DbMap, store cache.Store, proj sdk.Project, ...) error + func ResyncNodeRunsWithCommits(ctx context.Context, db *gorp.DbMap, store cache.Store, proj sdk.Project, ...) + func RunExist(db gorp.SqlExecutor, projectKey string, workflowID int64, hash string) (bool, error) + func SaveVulnerabilityReport(ctx context.Context, db gorpmapper.SqlExecutorWithTx, cache cache.Store, ...) error + func SetMaxRuns(confMaxRuns int64) + func Sort(w *sdk.Workflow) + func SortNode(n *sdk.Node) + func SyncNodeRunRunJob(ctx context.Context, db gorp.SqlExecutor, nodeRun *sdk.WorkflowNodeRun, ...) (bool, error) + func UnLabelWorkflow(db gorp.SqlExecutor, labelID, workflowID int64) error + func Update(ctx context.Context, db gorpmapper.SqlExecutorWithTx, store cache.Store, ...) error + func UpdateCoverage(db gorp.SqlExecutor, cov sdk.WorkflowNodeRunCoverage) error + func UpdateCraftedWorkflowRun(db gorp.SqlExecutor, id int64) error + func UpdateFavorite(db gorp.SqlExecutor, workflowID int64, u string, add bool) error + func UpdateFromRepository(db gorp.SqlExecutor, workflowID int64, fromRepository string) error + func UpdateHookModel(db gorp.SqlExecutor, m *sdk.WorkflowHookModel) error + func UpdateIcon(db gorp.SqlExecutor, workflowID int64, icon string) error + func UpdateMaxRunsByID(db gorp.SqlExecutor, workflowID int64, maxRuns int64) error + func UpdateMetadata(db gorp.SqlExecutor, workflowID int64, metadata sdk.Metadata) error + func UpdateNodeJobRun(ctx context.Context, db gorp.SqlExecutor, j *sdk.WorkflowNodeJobRun) error + func UpdateNodeRun(db gorp.SqlExecutor, n *sdk.WorkflowNodeRun) error + func UpdateNodeRunBuildParameters(db gorp.SqlExecutor, nodeID int64, buildParameters []sdk.Parameter) error + func UpdateNodeRunStatusAndStage(db gorp.SqlExecutor, nodeRun *sdk.WorkflowNodeRun) error + func UpdateOutgoingHookModel(db gorp.SqlExecutor, m *sdk.WorkflowHookModel) error + func UpdateRunNum(db gorp.SqlExecutor, w *sdk.Workflow, num int64) error + func UpdateVulnerabilityReport(db gorp.SqlExecutor, report *sdk.WorkflowNodeRunVulnerabilityReport) error + func UpdateWorkflowRun(ctx context.Context, db gorp.SqlExecutor, wr *sdk.WorkflowRun) error + func UpdateWorkflowRunStatus(db gorp.SqlExecutor, wr *sdk.WorkflowRun) error + func UpdateWorkflowRunTags(db gorp.SqlExecutor, r *sdk.WorkflowRun) error + func UserFavoriteWorkflowIDs(db gorp.SqlExecutor, uID string) ([]int64, error) + type Coverage sdk.WorkflowNodeRunCoverage + func (c *Coverage) PostGet(s gorp.SqlExecutor) error + func (c *Coverage) PostInsert(s gorp.SqlExecutor) error + func (c *Coverage) PostUpdate(s gorp.SqlExecutor) error + type ImportOptions struct + Force bool + FromBranch string + FromRepository string + HookUUID string + IsDefaultBranch bool + RepositoryName string + RepositoryStrategy sdk.RepositoryStrategy + VCSServer string + WorkflowName string + type JobRun struct + BookedBy sdk.BookedBy + ContainsService bool + Done time.Time + ExecGroups sql.NullString + HatcheryName string + Header sql.NullString + ID int64 + IntegrationPlugins sql.NullString + Job sql.NullString + Model string + ModelType sql.NullString + Parameters sql.NullString + ProjectID int64 + Queued time.Time + Region *string + Retry int + Start time.Time + Status string + WorkerName string + WorkflowNodeRunID int64 + func (j *JobRun) ToJobRun(jr *sdk.WorkflowNodeJobRun) (err error) + func (j JobRun) WorkflowNodeRunJob() (sdk.WorkflowNodeJobRun, error) + type LoadAllWorkflowsOptionsFilters struct + ApplicationRepository string + DisableFilterDeletedWorkflow bool + FromRepository string + GroupIDs []int64 + ProjectKey string + VCSServer string + WorkflowIDs []int64 + WorkflowName string + type LoadAllWorkflowsOptionsLoaders struct + WithApplications bool + WithAsCodeUpdateEvents bool + WithAudits bool + WithDeepPipelines bool + WithEnvironments bool + WithFavoritesForUserID string + WithIcon bool + WithIntegrations bool + WithLabels bool + WithPipelines bool + WithRuns int + WithTemplate bool + type LoadOptions struct + DeepPipeline bool + Minimal bool + WithAsCodeUpdateEvent bool + WithFavoritesForUserID string + WithIcon bool + WithIntegrations bool + WithLabels bool + WithTemplate bool + func (loadOpts LoadOptions) GetWorkflowDAO() WorkflowDAO + type LoadRunOptions struct + DisableDetailledNodeRun bool + WithArtifacts bool + WithCoverage bool + WithDeleted bool + WithLightTests bool + WithStaticFiles bool + WithTests bool + WithVulnerabilities bool + type NodeRun struct + ApplicationID sql.NullInt64 + BuildParameters sql.NullString + Callback sql.NullString + Commits sql.NullString + Done time.Time + ExecutionID sql.NullString + Header sql.NullString + HookEvent sql.NullString + HookExecutionTimestamp sql.NullInt64 + ID int64 + LastModified time.Time + Manual sql.NullString + Number int64 + OutgoingHook sql.NullString + Payload sql.NullString + PipelineParameters sql.NullString + SourceNodeRuns sql.NullString + Stages sql.NullString + Start time.Time + Status string + SubNumber int64 + Tests sql.NullString + TriggersRun sql.NullString + UUID sql.NullString + VCSBranch sql.NullString + VCSHash sql.NullString + VCSRepository sql.NullString + VCSServer sql.NullString + VCSTag sql.NullString + WorkflowID sql.NullInt64 + WorkflowNodeID int64 + WorkflowNodeName string + WorkflowRunID int64 + type NodeRunArtifact sdk.WorkflowNodeRunArtifact + type Notification sdk.WorkflowNotification + func (no *Notification) PostGet(db gorp.SqlExecutor) error + func (no *Notification) PostInsert(db gorp.SqlExecutor) error + type ProcessorReport struct + func ResyncWorkflowRunStatus(ctx context.Context, db gorp.SqlExecutor, wr *sdk.WorkflowRun) (*ProcessorReport, error) + func StartWorkflowRun(ctx context.Context, db gorpmapper.SqlExecutorWithTx, store cache.Store, ...) (*ProcessorReport, error) + func StopWorkflowNodeRun(ctx context.Context, dbFunc func() *gorp.DbMap, store cache.Store, ...) (*ProcessorReport, error) + func TakeNodeJobRun(ctx context.Context, db gorpmapper.SqlExecutorWithTx, store cache.Store, ...) (*sdk.WorkflowNodeJobRun, *ProcessorReport, error) + func UpdateNodeJobRunStatus(ctx context.Context, db gorpmapper.SqlExecutorWithTx, store cache.Store, ...) (*ProcessorReport, error) + func UpdateOutgoingHookRunStatus(ctx context.Context, db gorpmapper.SqlExecutorWithTx, store cache.Store, ...) (*ProcessorReport, error) + func UpdateParentWorkflowRun(ctx context.Context, tx gorpmapper.SqlExecutorWithTx, store cache.Store, ...) (*ProcessorReport, error) + func (r *ProcessorReport) Add(ctx context.Context, i ...interface{}) + func (r *ProcessorReport) All() []interface{} + func (r *ProcessorReport) Errors() []error + func (r *ProcessorReport) Jobs() []sdk.WorkflowNodeJobRun + func (r *ProcessorReport) Merge(ctx context.Context, r1 *ProcessorReport) + func (r *ProcessorReport) Nodes() []sdk.WorkflowNodeRun + func (r *ProcessorReport) WorkflowRuns() []sdk.WorkflowRun + func (r *ProcessorReport) Workflows() []sdk.WorkflowRun + type PushOption struct + Branch string + Force bool + FromRepository string + HookUUID string + IsDefaultBranch bool + OldWorkflow sdk.Workflow + RepositoryName string + RepositoryStrategy sdk.RepositoryStrategy + VCSServer string + type PushSecrets struct + ApplicationsSecrets map[int64][]sdk.Variable + EnvironmentdSecrets map[int64][]sdk.Variable + func CreateFromRepository(ctx context.Context, db *gorp.DbMap, store cache.Store, p *sdk.Project, ...) (*PushSecrets, []sdk.Message, error) + func Push(ctx context.Context, db *gorp.DbMap, store cache.Store, proj *sdk.Project, ...) ([]sdk.Message, *sdk.Workflow, *sdk.Workflow, *PushSecrets, error) + func RetrieveSecrets(db gorp.SqlExecutor, wf sdk.Workflow) (*PushSecrets, error) + type QueueFilter struct + Limit *int + ModelType []string + RatioService *int + Regions []string + Rights int + Since *time.Time + Statuses []string + Until *time.Time + func NewQueueFilter() QueueFilter + type Run sdk.WorkflowRun + func (r *Run) PostInsert(db gorp.SqlExecutor) error + func (r *Run) PostUpdate(db gorp.SqlExecutor) error + type RunTag sdk.WorkflowRunTag + type UpdateOptions struct + DisableHookManagement bool + type VCSEventMessenger struct + func (e *VCSEventMessenger) SendVCSEvent(ctx context.Context, db *gorp.DbMap, store cache.Store, proj sdk.Project, ...) error + type Workflow struct + ProjectKey string + func (w *Workflow) Get() sdk.Workflow + func (w *Workflow) PostGet(db gorp.SqlExecutor) error + func (w *Workflow) PostInsert(db gorp.SqlExecutor) error + func (w *Workflow) PostUpdate(db gorp.SqlExecutor) error + func (w *Workflow) PreInsert(db gorp.SqlExecutor) error + func (w *Workflow) PreUpdate(_ gorp.SqlExecutor) error + type WorkflowDAO struct + Ascending bool + Filters LoadAllWorkflowsOptionsFilters + Limit int + Loaders LoadAllWorkflowsOptionsLoaders + Lock bool + Offset int + func (dao WorkflowDAO) GetLoaders() []gorpmapping.GetOptionFunc + func (dao WorkflowDAO) Load(ctx context.Context, db gorp.SqlExecutor) (sdk.Workflow, error) + func (dao WorkflowDAO) LoadAll(ctx context.Context, db gorp.SqlExecutor) (sdk.Workflows, error) + func (dao WorkflowDAO) Query() gorpmapping.Query + type Workflows []Workflow + func (ws Workflows) Get() sdk.Workflows
Go to main page