Versions in this module Expand all Collapse all v0 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