pipelineConfig

Sep 11, 2025

Changes in this version

type CdWorkflowRepository

+ GetLatestTriggersOfPipelinesStuckInNonTerminalStatuses func(getPipelineDeployedWithinHours int, deploymentAppType string) ([]*CdWorkflowRunner, error)

type CdWorkflowRepositoryImpl

+ func (impl *CdWorkflowRepositoryImpl) GetLatestTriggersOfPipelinesStuckInNonTerminalStatuses(getPipelineDeployedWithinHours int, deploymentAppType string) ([]*CdWorkflowRunner, error)

+ type CdWorkflowStatusLatest struct

+ AppId int

+ EnvironmentId int

+ Id int

+ PipelineId int

+ WorkflowRunnerId int

+ WorkflowType string

type CiWorkflowRepository

+ FindCiPipelineIdsByAppId func(appId int) ([]int, error)

+ FindWorkflowsByCiWorkflowIds func(ciWorkflowIds []int) (ciWorkflow []*CiWorkflow, err error)

type CiWorkflowRepositoryImpl

+ func (impl *CiWorkflowRepositoryImpl) FindCiPipelineIdsByAppId(appId int) ([]int, error)

+ func (impl *CiWorkflowRepositoryImpl) FindWorkflowsByCiWorkflowIds(ciWorkflowIds []int) (ciWorkflow []*CiWorkflow, err error)

+ type CiWorkflowStatusLatest struct

+ AppId int

+ CiWorkflowId int

+ Id int

+ PipelineId int

+ type WorkflowStatusLatestRepository interface

+ GetCdWorkflowStatusLatestByPipelineIdAndWorkflowType func(tx *pg.Tx, pipelineId int, workflowType string) (*CdWorkflowStatusLatest, error)

+ GetCdWorkflowStatusLatestByPipelineIds func(pipelineIds []int) ([]*CdWorkflowStatusLatest, error)

+ GetCiWorkflowStatusLatestByPipelineId func(pipelineId int) (*CiWorkflowStatusLatest, error)

+ GetCiWorkflowStatusLatestByPipelineIds func(pipelineIds []int) ([]*CiWorkflowStatusLatest, error)

+ SaveCdWorkflowStatusLatest func(tx *pg.Tx, model *CdWorkflowStatusLatest) error

+ SaveCiWorkflowStatusLatest func(tx *pg.Tx, model *CiWorkflowStatusLatest) error

+ UpdateCdWorkflowStatusLatest func(tx *pg.Tx, model *CdWorkflowStatusLatest) error

+ UpdateCiWorkflowStatusLatest func(tx *pg.Tx, model *CiWorkflowStatusLatest) error

+ type WorkflowStatusLatestRepositoryImpl struct

+ func NewWorkflowStatusLatestRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *WorkflowStatusLatestRepositoryImpl

+ func (impl *WorkflowStatusLatestRepositoryImpl) GetCdWorkflowStatusLatestByPipelineIdAndWorkflowType(tx *pg.Tx, pipelineId int, workflowType string) (*CdWorkflowStatusLatest, error)

+ func (impl *WorkflowStatusLatestRepositoryImpl) GetCdWorkflowStatusLatestByPipelineIds(pipelineIds []int) ([]*CdWorkflowStatusLatest, error)

+ func (impl *WorkflowStatusLatestRepositoryImpl) GetCiWorkflowStatusLatestByPipelineId(pipelineId int) (*CiWorkflowStatusLatest, error)

+ func (impl *WorkflowStatusLatestRepositoryImpl) GetCiWorkflowStatusLatestByPipelineIds(pipelineIds []int) ([]*CiWorkflowStatusLatest, error)

+ func (impl *WorkflowStatusLatestRepositoryImpl) SaveCdWorkflowStatusLatest(tx *pg.Tx, model *CdWorkflowStatusLatest) error

+ func (impl *WorkflowStatusLatestRepositoryImpl) SaveCiWorkflowStatusLatest(tx *pg.Tx, model *CiWorkflowStatusLatest) error

+ func (impl *WorkflowStatusLatestRepositoryImpl) UpdateCdWorkflowStatusLatest(tx *pg.Tx, model *CdWorkflowStatusLatest) error

+ func (impl *WorkflowStatusLatestRepositoryImpl) UpdateCiWorkflowStatusLatest(tx *pg.Tx, model *CiWorkflowStatusLatest) error

Jun 16, 2025

Changes in this version

type CiTemplateOverrideRepository

+ FindIfTemplateOverrideExistsByCiPipelineIdsAndGitMaterialId func(ciPipelineIds []int, gitMaterialId int) (bool, error)

type CiTemplateOverrideRepositoryImpl

+ func (repo *CiTemplateOverrideRepositoryImpl) FindIfTemplateOverrideExistsByCiPipelineIdsAndGitMaterialId(ciPipelineIds []int, gitMaterialId int) (bool, error)

type PipelineRepository

+ FindAllPipelinesWithoutOverriddenCharts func(appId int) (pipelineIds []int, err error)

+ FindEnvIdsByIdsInIncludingDeleted func(ids []int) ([]int, error)

+ GetPipelineCountByDeploymentType func(deploymentType string) (int, error)

type PipelineRepositoryImpl

+ func (impl *PipelineRepositoryImpl) FindAllPipelinesWithoutOverriddenCharts(appId int) (pipelineIds []int, err error)

+ func (impl *PipelineRepositoryImpl) FindEnvIdsByIdsInIncludingDeleted(ids []int) ([]int, error)

+ func (impl *PipelineRepositoryImpl) GetPipelineCountByDeploymentType(deploymentType string) (int, error)

May 8, 2025

Changes in this version

type CdWorkflowRepository

+ FindPreOrPostCdWorkflowRunnerById func(wfrId int) (*CdWorkflowRunner, error)

type CdWorkflowRepositoryImpl

+ func (impl *CdWorkflowRepositoryImpl) FindPreOrPostCdWorkflowRunnerById(wfrId int) (*CdWorkflowRunner, error)

type CdWorkflowRunner

+ ImageState constants.ImageStateWhileDeployment

type CiPipeline

+ func (p *CiPipeline) GetWorkflowCacheConfig() common.WorkflowCacheConfigType

Mar 24, 2025

Changes in this version

+ type PipelineDeploymentConfigObj struct

+ AppId int

+ ClusterId int

+ DeploymentAppName string

+ EnvironmentId int

+ Namespace string

type PipelineRepository

+ FindOneByAppIdAndEnvId func(appId int, envId int) (*Pipeline, error)

+ GetAllAppsByClusterAndDeploymentAppType func(clusterIds []int, deploymentAppName string) ([]*PipelineDeploymentConfigObj, error)

+ GetAllArgoAppInfoByDeploymentAppNames func(deploymentAppNames []string) ([]*PipelineDeploymentConfigObj, error)

type PipelineRepositoryImpl

+ func (impl *PipelineRepositoryImpl) FindOneByAppIdAndEnvId(appId int, envId int) (*Pipeline, error)

+ func (impl *PipelineRepositoryImpl) GetAllAppsByClusterAndDeploymentAppType(clusterIds []int, deploymentAppName string) ([]*PipelineDeploymentConfigObj, error)

+ func (impl *PipelineRepositoryImpl) GetAllArgoAppInfoByDeploymentAppNames(deploymentAppNames []string) ([]*PipelineDeploymentConfigObj, error)

Feb 21, 2025

Changes in this version

type CdWorkflowRepository

+ SaveWorkFlowRunnerWithTx func(wfr *CdWorkflowRunner, tx *pg.Tx) (*CdWorkflowRunner, error)

+ UpdateWorkFlowRunnerWithTx func(wfr *CdWorkflowRunner, tx *pg.Tx) error

type CdWorkflowRepositoryImpl

+ func (impl *CdWorkflowRepositoryImpl) SaveWorkFlowRunnerWithTx(wfr *CdWorkflowRunner, tx *pg.Tx) (*CdWorkflowRunner, error)

+ func (impl *CdWorkflowRepositoryImpl) UpdateWorkFlowRunnerWithTx(wfr *CdWorkflowRunner, tx *pg.Tx) error

type CiWorkflowRepository

+ SaveWorkFlowWithTx func(wf *CiWorkflow, tx *pg.Tx) error

+ UpdateWorkFlowWithTx func(wf *CiWorkflow, tx *pg.Tx) error

type CiWorkflowRepositoryImpl

+ func (impl *CiWorkflowRepositoryImpl) SaveWorkFlowWithTx(wf *CiWorkflow, tx *pg.Tx) error

+ func (impl *CiWorkflowRepositoryImpl) UpdateWorkFlowWithTx(wf *CiWorkflow, tx *pg.Tx) error

type TriggerType

+ func (t TriggerType) IsAuto() bool

+ func (t TriggerType) IsManual() bool

Feb 5, 2025

Changes in this version

type WorkflowWithArtifact

+ TargetPlatforms string

Feb 4, 2025

Changes in this version

type CdWorkflowRepository

+ FindLatestCdWorkflowRunnerArtifactMetadataForAppAndEnvIds func(appVsEnvIdMap map[int][]int, runnerType apiBean.WorkflowType) ([]*cdWorkflow.CdWorkflowRunnerArtifactMetadata, error)

type CdWorkflowRepositoryImpl

+ func (impl *CdWorkflowRepositoryImpl) FindLatestCdWorkflowRunnerArtifactMetadataForAppAndEnvIds(appVsEnvIdMap map[int][]int, runnerType apiBean.WorkflowType) ([]*cdWorkflow.CdWorkflowRunnerArtifactMetadata, error)

Dec 20, 2024

Changes in this version

type CdWorkflowRepository

+ FindDeployedCdWorkflowRunnersByPipelineId func(pipelineId int) ([]*CdWorkflowRunner, error)

type CdWorkflowRepositoryImpl

+ func (impl *CdWorkflowRepositoryImpl) FindDeployedCdWorkflowRunnersByPipelineId(pipelineId int) ([]*CdWorkflowRunner, error)

type CiPipelineRepository

+ FindOneWithMinData func(id int) (pipeline *CiPipeline, err error)

+ GetChildrenCiCount func(parentCiPipelineId int) (int, error)

type CiPipelineRepositoryImpl

+ func (impl *CiPipelineRepositoryImpl) FindOneWithMinData(id int) (pipeline *CiPipeline, err error)

+ func (impl *CiPipelineRepositoryImpl) GetChildrenCiCount(parentCiPipelineId int) (int, error)

Nov 11, 2024

Changes in this version

type CdWorkflowRepository

+ MigrateCdArtifactLocation func(wfrId int, cdArtifactLocation string)

+ MigrateIsArtifactUploaded func(wfrId int, isArtifactUploaded bool)

+ UpdateIsArtifactUploaded func(wfrId int, isArtifactUploaded workflow.ArtifactUploadedType) error

type CdWorkflowRepositoryImpl

+ func (impl *CdWorkflowRepositoryImpl) MigrateCdArtifactLocation(wfrId int, cdArtifactLocation string)

+ func (impl *CdWorkflowRepositoryImpl) MigrateIsArtifactUploaded(wfrId int, isArtifactUploaded bool)

+ func (impl *CdWorkflowRepositoryImpl) UpdateIsArtifactUploaded(wfrId int, isArtifactUploaded workflow.ArtifactUploadedType) error

type CdWorkflowRunner

+ CdArtifactLocation string

+ IsArtifactUploaded workflow.ArtifactUploadedType

+ func (c *CdWorkflowRunner) GetIsArtifactUploaded() (isArtifactUploaded bool, isMigrationRequired bool)

+ func (c *CdWorkflowRunner) WithIsArtifactUploaded(isArtifactUploaded bool) *CdWorkflowRunner

type CiWorkflow

+ IsArtifactUploaded workflow.ArtifactUploadedType

+ func (ciWorkflow *CiWorkflow) GetIsArtifactUploaded() (isArtifactUploaded bool, isMigrationRequired bool)

+ func (ciWorkflow *CiWorkflow) WithIsArtifactUploaded(isArtifactUploaded bool) *CiWorkflow

type CiWorkflowRepository

+ MigrateCiArtifactLocation func(wfId int, artifactLocation string)

+ MigrateIsArtifactUploaded func(wfId int, isArtifactUploaded bool)

+ UpdateArtifactUploaded func(id int, isUploaded workflow.ArtifactUploadedType) error

type CiWorkflowRepositoryImpl

+ func (impl *CiWorkflowRepositoryImpl) MigrateCiArtifactLocation(wfId int, artifactLocation string)

+ func (impl *CiWorkflowRepositoryImpl) MigrateIsArtifactUploaded(wfId int, isArtifactUploaded bool)

+ func (impl *CiWorkflowRepositoryImpl) UpdateArtifactUploaded(id int, isUploaded workflow.ArtifactUploadedType) error

type WorkflowWithArtifact

+ IsArtifactUploadedV2 workflow.ArtifactUploadedType

+ func (w *WorkflowWithArtifact) GetIsArtifactUploaded() (isArtifactUploaded bool, isMigrationRequired bool)

Aug 26, 2024

Changes in this version

type CdWorkflowRepository

+ FetchEnvAllCdStagesLatestEntityStatus func(wfrIds []int, envID int) ([]*CdWorkflowRunner, error)

type CdWorkflowRepositoryImpl

+ func (impl *CdWorkflowRepositoryImpl) FetchEnvAllCdStagesLatestEntityStatus(wfrIds []int, envID int) ([]*CdWorkflowRunner, error)

type CiPipelineRepository

+ FindByLinkedCiCount func(parentCiPipelineId int) (int, error)

type CiPipelineRepositoryImpl

+ func (impl *CiPipelineRepositoryImpl) FindByLinkedCiCount(parentCiPipelineId int) (int, error)

type PipelineRepository

+ FindActivePipelineAppIdsByEnvId func(envId int) ([]int, error)

+ FindActivePipelineAppIdsByInFilter func(envId int, appIdIncludes []int) ([]int, error)

+ FindByAppIdToEnvIdsMapping func(appIdToEnvIds map[int][]int) ([]*Pipeline, error)

+ FindDeploymentAppTypeByAppIdAndEnvId func(appId, envId int) (string, error)

+ FindDeploymentAppTypeByIds func(ids []int) (pipelines []*Pipeline, err error)

+ UpdateCiPipelineId func(tx *pg.Tx, pipelineIds []int, ciPipelineId int) error

type PipelineRepositoryImpl

+ func (impl PipelineRepositoryImpl) FindActivePipelineAppIdsByEnvId(envId int) ([]int, error)

+ func (impl PipelineRepositoryImpl) FindActivePipelineAppIdsByInFilter(envId int, appIdIncludes []int) ([]int, error)

+ func (impl PipelineRepositoryImpl) FindByAppIdToEnvIdsMapping(appIdToEnvIds map[int][]int) ([]*Pipeline, error)

+ func (impl PipelineRepositoryImpl) FindDeploymentAppTypeByAppIdAndEnvId(appId, envId int) (string, error)

+ func (impl PipelineRepositoryImpl) FindDeploymentAppTypeByIds(ids []int) (pipelines []*Pipeline, err error)

+ func (impl PipelineRepositoryImpl) UpdateCiPipelineId(tx *pg.Tx, pipelineIds []int, ciPipelineId int) error

Jul 11, 2024 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jul 10, 2024 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

+ const PIPELINE_DELETED

+ var ErrorDeploymentSuperseded = errors.New(NEW_DEPLOYMENT_INITIATED)

type CdWorkflowRepository

+ FindBasicWorkflowRunnerById func(wfrId int) (*CdWorkflowRunner, error)

+ FindLastUnFailedProcessedRunner func(appId int, environmentId int) (*CdWorkflowRunner, error)

+ FindLatestByPipelineIdAndRunnerType func(pipelineId int, runnerType apiBean.WorkflowType) (CdWorkflowRunner, error)

+ GetPreviousQueuedRunners func(cdWfrId, pipelineId int) ([]*CdWorkflowRunner, error)

+ UpdateRunnerStatusToFailedForIds func(errMsg string, triggeredBy int32, cdWfrIds ...int) error

type CdWorkflowRepositoryImpl

+ func (impl *CdWorkflowRepositoryImpl) FindBasicWorkflowRunnerById(wfrId int) (*CdWorkflowRunner, error)

+ func (impl *CdWorkflowRepositoryImpl) FindLastUnFailedProcessedRunner(appId int, environmentId int) (*CdWorkflowRunner, error)

+ func (impl *CdWorkflowRepositoryImpl) FindLatestByPipelineIdAndRunnerType(pipelineId int, runnerType apiBean.WorkflowType) (CdWorkflowRunner, error)

+ func (impl *CdWorkflowRepositoryImpl) GetPreviousQueuedRunners(cdWfrId, pipelineId int) ([]*CdWorkflowRunner, error)

+ func (impl *CdWorkflowRepositoryImpl) UpdateRunnerStatusToFailedForIds(errMsg string, triggeredBy int32, cdWfrIds ...int) error

type PipelineRepository

+ FindActiveByAppIdAndEnvId func(appId int, envId int) (*Pipeline, error)

+ MarkPartiallyDeleted func(id int, userId int32, tx *pg.Tx) error

type PipelineRepositoryImpl

+ func (impl PipelineRepositoryImpl) FindActiveByAppIdAndEnvId(appId int, envId int) (*Pipeline, error)

+ func (impl PipelineRepositoryImpl) MarkPartiallyDeleted(id int, userId int32, tx *pg.Tx) error

type PipelineStatusTimelineRepository

+ CheckIfTimelineStatusPresentByInstalledAppVersionHistoryId func(installedAppVersionHistoryId int, status timelineStatus.TimelineStatus) (bool, error)

+ CheckIfTimelineStatusPresentByWfrId func(wfrId int, status timelineStatus.TimelineStatus) (bool, error)

+ FetchTimelinesForWfrIdExcludingStatuses func(wfrId int, statuses ...timelineStatus.TimelineStatus) ([]*PipelineStatusTimeline, error)

+ GetLastStatusPublishedTimeForWfrId func(wfrId int) (time.Time, error)

type PipelineStatusTimelineRepositoryImpl

+ func (impl *PipelineStatusTimelineRepositoryImpl) CheckIfTimelineStatusPresentByInstalledAppVersionHistoryId(installedAppVersionHistoryId int, status timelineStatus.TimelineStatus) (bool, error)

+ func (impl *PipelineStatusTimelineRepositoryImpl) CheckIfTimelineStatusPresentByWfrId(wfrId int, status timelineStatus.TimelineStatus) (bool, error)

+ func (impl *PipelineStatusTimelineRepositoryImpl) FetchTimelinesForWfrIdExcludingStatuses(wfrId int, statuses ...timelineStatus.TimelineStatus) ([]*PipelineStatusTimeline, error)

+ func (impl *PipelineStatusTimelineRepositoryImpl) GetLastStatusPublishedTimeForWfrId(wfrId int) (time.Time, error)

type TriggerType

+ func (t TriggerType) ToString() string

Jun 7, 2024 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type CdWorkflowRepository

+ FindAllTriggeredWorkflowCountInLast24Hour func() (cdWorkflowCount int, err error)

+ FindLatestRunnerByPipelineIdsAndRunnerType func(ctx context.Context, pipelineIds []int, runnerType bean.WorkflowType) ([]CdWorkflowRunner, error)

type CdWorkflowRepositoryImpl

+ func (impl *CdWorkflowRepositoryImpl) FindAllTriggeredWorkflowCountInLast24Hour() (cdWorkflowCount int, err error)

+ func (impl *CdWorkflowRepositoryImpl) FindLatestRunnerByPipelineIdsAndRunnerType(ctx context.Context, pipelineIds []int, runnerType bean.WorkflowType) ([]CdWorkflowRunner, error)

type CiPipelineRepository

+ FindAllDeletedPipelineCountInLast24Hour func() (pipelineCount int, err error)

+ FindAllPipelineCreatedCountInLast24Hour func() (pipelineCount int, err error)

+ GetDownStreamInfo func(ctx context.Context, sourceCiPipelineId int, appNameMatch, envNameMatch string, ...) ([]bean.LinkedCIDetails, int, error)

+ GetLinkedCiPipelines func(ctx context.Context, ciPipelineId int) ([]*CiPipeline, error)

type CiPipelineRepositoryImpl

+ func (impl *CiPipelineRepositoryImpl) FindAllDeletedPipelineCountInLast24Hour() (pipelineCount int, err error)

+ func (impl *CiPipelineRepositoryImpl) FindAllPipelineCreatedCountInLast24Hour() (pipelineCount int, err error)

+ func (impl *CiPipelineRepositoryImpl) GetDownStreamInfo(ctx context.Context, sourceCiPipelineId int, appNameMatch, envNameMatch string, ...) ([]bean.LinkedCIDetails, int, error)

+ func (impl *CiPipelineRepositoryImpl) GetLinkedCiPipelines(ctx context.Context, ciPipelineId int) ([]*CiPipeline, error)

type CiWorkflowRepository

+ FindAllTriggeredWorkflowCountInLast24Hour func() (ciWorkflowCount int, err error)

type CiWorkflowRepositoryImpl

+ func (impl *CiWorkflowRepositoryImpl) FindAllTriggeredWorkflowCountInLast24Hour() (ciWorkflowCount int, err error)

type PipelineRepository

+ FindAllDeletedPipelineCountInLast24Hour func() (pipelineCount int, err error)

+ FindAllPipelineCreatedCountInLast24Hour func() (pipelineCount int, err error)

+ FindByIdEvenIfInactive func(id int) (pipeline *Pipeline, err error)

+ FindWithEnvironmentByCiIds func(ctx context.Context, cIPipelineIds []int) ([]*Pipeline, error)

type PipelineRepositoryImpl

+ func (impl PipelineRepositoryImpl) FindAllDeletedPipelineCountInLast24Hour() (pipelineCount int, err error)

+ func (impl PipelineRepositoryImpl) FindAllPipelineCreatedCountInLast24Hour() (pipelineCount int, err error)

+ func (impl PipelineRepositoryImpl) FindByIdEvenIfInactive(id int) (pipeline *Pipeline, err error)

+ func (impl PipelineRepositoryImpl) FindWithEnvironmentByCiIds(ctx context.Context, cIPipelineIds []int) ([]*Pipeline, error)

Apr 13, 2024 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

+ const GITOPS_REPO_NOT_CONFIGURED

+ func GetTriggerMetricsFromRunnerObj(runner *CdWorkflowRunner) util4.CDMetrics

type CiPipelineRepository

+ FindOneWithAppData func(id int) (pipeline *CiPipeline, err error)

type CiPipelineRepositoryImpl

+ func (impl CiPipelineRepositoryImpl) FindOneWithAppData(id int) (pipeline *CiPipeline, err error)

Mar 13, 2024 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type CdWorkflowRepository

+ CheckWorkflowRunnerByReferenceId func(referenceId string) (bool, error)

type CdWorkflowRepositoryImpl

+ func (impl *CdWorkflowRepositoryImpl) CheckWorkflowRunnerByReferenceId(referenceId string) (bool, error)

type CdWorkflowRunner

+ ReferenceId *string

type PipelineStatusTimelineRepository

+ GetConnection func() *pg.DB

type PipelineStatusTimelineRepositoryImpl

+ func (impl *PipelineStatusTimelineRepositoryImpl) GetConnection() *pg.DB

type TimelineStatus

+ const TIMELINE_STATUS_ARGOCD_SYNC_COMPLETED

+ const TIMELINE_STATUS_ARGOCD_SYNC_INITIATED

Jan 30, 2024 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Dec 15, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Dec 14, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

+ const FOUND_VULNERABILITY

+ const NEW_DEPLOYMENT_INITIATED

+ const WorkflowInQueue

+ const WorkflowInitiated

+ var WfrTerminalStatusList = []string

type CdWorkflowRepository

+ IsLatestCDWfr func(pipelineId, wfrId int) (bool, error)

+ UpdatePreviousQueuedRunnerStatus func(cdWfrId, pipelineId int, triggeredBy int32) ([]*CdWorkflowRunner, error)

type CdWorkflowRepositoryImpl

+ func (impl *CdWorkflowRepositoryImpl) FetchArtifactsByCdPipelineIdV2(listingFilterOptions bean.ArtifactsListFilterOptions) ([]CdWorkflowRunner, int, error)

+ func (impl *CdWorkflowRepositoryImpl) IsLatestCDWfr(pipelineId, wfrId int) (bool, error)

+ func (impl *CdWorkflowRepositoryImpl) UpdatePreviousQueuedRunnerStatus(cdWfrId, pipelineId int, triggeredBy int32) ([]*CdWorkflowRunner, error)

type CdWorkflowRunner

+ ImagePathReservationIds []int

+ type CdWorkflowRunnerWithExtraFields struct

+ TotalCount int

type CiPipelineRepository

+ CheckIfPipelineExistsByNameAndAppId func(pipelineName string, appId int) (bool, error)

+ FindByIdIncludingInActive func(id int) (pipeline *CiPipeline, err error)

+ FindByParentIdAndType func(parentCiPipelineId int, pipelineType string) ([]*CiPipeline, error)

+ FindLinkedCiCount func(ciPipelineId int) (int, error)

type CiPipelineRepositoryImpl

+ func (impl CiPipelineRepositoryImpl) CheckIfPipelineExistsByNameAndAppId(pipelineName string, appId int) (bool, error)

+ func (impl CiPipelineRepositoryImpl) FindByIdIncludingInActive(id int) (pipeline *CiPipeline, err error)

+ func (impl CiPipelineRepositoryImpl) FindByParentIdAndType(parentCiPipelineId int, pipelineType string) ([]*CiPipeline, error)

+ func (impl CiPipelineRepositoryImpl) FindLinkedCiCount(ciPipelineId int) (int, error)

type CiWorkflow

+ ExecutorType WorkflowExecutorType

+ ImagePathReservationIds []int

+ func (ciWorkflow *CiWorkflow) InProgress() bool

type CiWorkflowRepository

+ FindCiWorkflowGitTriggersByIds func(ids []int) ([]*CiWorkflow, error)

+ FindLastTriggeredWorkflowGitTriggersByArtifactIds func(ciArtifactIds []int) ([]*WorkflowWithArtifact, error)

type CiWorkflowRepositoryImpl

+ func (impl *CiWorkflowRepositoryImpl) FindCiWorkflowGitTriggersByIds(ids []int) ([]*CiWorkflow, error)

+ func (impl *CiWorkflowRepositoryImpl) FindLastTriggeredWorkflowGitTriggersByArtifactIds(ciArtifactIds []int) ([]*WorkflowWithArtifact, error)

+ type DeploymentObject struct

+ DeploymentType models.DeploymentType

+ PipelineId int

+ Status string

type PipelineRepository

+ FindActivePipelineByEnvId func(envId int) (pipelines []*Pipeline, err error)

+ FindDeploymentTypeByPipelineIds func(cdPipelineIds []int) (map[int]DeploymentObject, error)

+ UpdateOldCiPipelineIdToNewCiPipelineId func(tx *pg.Tx, oldCiPipelineId, newCiPipelineId int) error

type PipelineRepositoryImpl

+ func (impl PipelineRepositoryImpl) FindActivePipelineByEnvId(envId int) (pipelines []*Pipeline, err error)

+ func (impl PipelineRepositoryImpl) FindDeploymentTypeByPipelineIds(cdPipelineIds []int) (map[int]DeploymentObject, error)

+ func (impl PipelineRepositoryImpl) UpdateOldCiPipelineIdToNewCiPipelineId(tx *pg.Tx, oldCiPipelineId, newCiPipelineId int) error

type WorkflowWithArtifact

+ ExecutorType WorkflowExecutorType

+ ImagePathReservationIds []int

Dec 7, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

+ const WorkflowTypeDeploy

+ const WorkflowTypePost

+ const WorkflowTypePre

type CdWorkflowRunner

+ func (c *CdWorkflowRunner) IsExternalRun() bool

type CiWorkflow

+ ImagePathReservationId int

+ func (r *CiWorkflow) IsExternalRunInJobType() bool

type CiWorkflowStatus

+ CiWorkflowId int

type WorkflowWithArtifact

+ ImagePathReservationId int

Oct 30, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Oct 29, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type CdWorkflowRepository

+ FindRetriedWorkflowCountByReferenceId func(wfrId int) (int, error)

type CdWorkflowRepositoryImpl

+ func (impl *CdWorkflowRepositoryImpl) FindRetriedWorkflowCountByReferenceId(wfrId int) (int, error)

type CdWorkflowRunner

+ RefCdWorkflowRunnerId int

type CdWorkflowWithArtifact

+ RefCdWorkflowRunnerId int

type CiPipeline

+ PipelineType string

type CiPipelineMaterialRepository

+ GetByIdsIncludeDeleted func(ids []int) ([]*CiPipelineMaterial, error)

type CiPipelineMaterialRepositoryImpl

+ func (impl CiPipelineMaterialRepositoryImpl) GetByIdsIncludeDeleted(ids []int) ([]*CiPipelineMaterial, error)

type CiPipelineRepository

+ FindCiPipelineByAppIdAndEnvIds func(appId int, envIds []int) ([]*CiPipeline, error)

type CiPipelineRepositoryImpl

+ func (impl CiPipelineRepositoryImpl) FindCiPipelineByAppIdAndEnvIds(appId int, envIds []int) ([]*CiPipeline, error)

type CiWorkflow

+ ParentCiWorkFlowId int

+ ReferenceCiWorkflowId int

type CiWorkflowRepository

+ FindRetriedWorkflowCountByReferenceId func(id int) (int, error)

type CiWorkflowRepositoryImpl

+ func (impl *CiWorkflowRepositoryImpl) FindRetriedWorkflowCountByReferenceId(id int) (int, error)

type WorkflowWithArtifact

+ ParentCiWorkflowId int

+ RefCiWorkflowId int

Oct 20, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type MaterialRepository

+ FindByAppIdAndGitMaterialId func(appId, id int) (*GitMaterial, error)

type MaterialRepositoryImpl

+ func (repo MaterialRepositoryImpl) FindByAppIdAndGitMaterialId(appId, id int) (*GitMaterial, error)

Sep 15, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Sep 14, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Aug 23, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

+ type CiEnvMapping struct

+ CiPipeline CiPipeline

+ CiPipelineId int

+ Deleted bool

+ Environment repository.Environment

+ EnvironmentId int

+ Id int

type CiPipelineRepository

+ FindCiEnvMappingByCiPipelineId func(ciPipelineId int) (*CiEnvMapping, error)

+ SaveCiEnvMapping func(cienvmapping *CiEnvMapping, tx *pg.Tx) error

+ UpdateCiEnvMapping func(cienvmapping *CiEnvMapping, tx *pg.Tx) error

type CiPipelineRepositoryImpl

+ func (impl CiPipelineRepositoryImpl) FindCiEnvMappingByCiPipelineId(ciPipelineId int) (*CiEnvMapping, error)

+ func (impl CiPipelineRepositoryImpl) SaveCiEnvMapping(cienvmapping *CiEnvMapping, tx *pg.Tx) error

+ func (impl CiPipelineRepositoryImpl) UpdateCiEnvMapping(cienvmapping *CiEnvMapping, tx *pg.Tx) error

type CiWorkflow

+ EnvironmentId int

type WorkflowWithArtifact

+ EnvironmentId int

+ EnvironmentName string

Aug 13, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jul 17, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type CdWorkflowWithArtifact

+ ImageComment *repository2.ImageComment

+ ImageReleaseTags []*repository2.ImageTag

type CiPipelineRepository

+ GetCiPipelineByArtifactId func(artifactId int) (*CiPipeline, error)

+ GetExternalCiPipelineByArtifactId func(artifactId int) (*ExternalCiPipeline, error)

type CiPipelineRepositoryImpl

+ func (impl CiPipelineRepositoryImpl) GetCiPipelineByArtifactId(artifactId int) (*CiPipeline, error)

+ func (impl CiPipelineRepositoryImpl) GetExternalCiPipelineByArtifactId(artifactId int) (*ExternalCiPipeline, error)

Jul 3, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type CdWorkflowWithArtifact

+ CiMaterials []CiPipelineMaterialResponse

+ GitTriggers map[int]GitCommit

+ type CiPipelineMaterialResponse struct

+ Active bool

+ BranchErrorMsg string

+ GitMaterialId int

+ GitMaterialName string

+ GitMaterialUrl string

+ History []*gitSensor.GitCommit

+ Id int

+ IsBranchError bool

+ IsRepoError bool

+ LastFetchTime time.Time

+ Regex string

+ RepoErrorMsg string

+ Type string

+ Url string

+ Value string

type CiWorkflowRepository

+ FindAllLastTriggeredWorkflowByArtifactId func(ciArtifactId []int) (ciWorkflow []*CiWorkflow, err error)

type CiWorkflowRepositoryImpl

+ func (impl *CiWorkflowRepositoryImpl) FindAllLastTriggeredWorkflowByArtifactId(ciArtifactIds []int) (ciWorkflows []*CiWorkflow, err error)

Jun 28, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jun 27, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jun 14, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jun 9, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jun 1, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jun 1, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

+ const TIMELINE_DESCRIPTION_DEPLOYMENT_INITIATED

+ const TIMELINE_DESCRIPTION_MANIFEST_GENERATED

+ const TIMELINE_DESCRIPTION_VULNERABLE_IMAGE

+ var TimelineStatusDescription string

type CiBuildConfig

+ UseRootContext *bool

type CiPipelineMaterialRepository

+ GetByPipelineIdAndGitMaterialId func(id int, gitMaterialId int) ([]*CiPipelineMaterial, error)

+ GetCheckoutPath func(gitMaterialId int) (string, error)

+ UpdateNotNull func(tx *pg.Tx, material ...*CiPipelineMaterial) error

type CiPipelineMaterialRepositoryImpl

+ func (impl CiPipelineMaterialRepositoryImpl) GetByPipelineIdAndGitMaterialId(id int, gitMaterialId int) ([]*CiPipelineMaterial, error)

+ func (impl CiPipelineMaterialRepositoryImpl) GetCheckoutPath(gitMaterialId int) (string, error)

+ func (impl CiPipelineMaterialRepositoryImpl) UpdateNotNull(tx *pg.Tx, materials ...*CiPipelineMaterial) error

type CiPipelineRepository

+ FindAppIdsForCiPipelineIds func(pipelineIds []int) (map[int]int, error)

+ FindParentCiPipelineMapByAppId func(appId int) ([]*CiPipeline, []int, error)

+ FindWithMinDataByCiPipelineId func(id int) (pipeline *CiPipeline, err error)

type CiPipelineRepositoryImpl

+ func (impl CiPipelineRepositoryImpl) FindAppIdsForCiPipelineIds(pipelineIds []int) (map[int]int, error)

+ func (impl CiPipelineRepositoryImpl) FindParentCiPipelineMapByAppId(appId int) ([]*CiPipeline, []int, error)

+ func (impl CiPipelineRepositoryImpl) FindWithMinDataByCiPipelineId(id int) (pipeline *CiPipeline, err error)

type CiTemplate

+ BuildContextGitMaterialId int

type CiTemplateOverride

+ BuildContextGitMaterialId int

type CiWorkflowRepository

+ FIndCiWorkflowStatusesByAppId func(appId int) ([]*CiWorkflowStatus, error)

+ FindCiWorkflowGitTriggersById func(id int) (workflow *CiWorkflow, err error)

+ FindLastTriggeredWorkflowGitTriggersByArtifactId func(ciArtifactId int) (ciWorkflow *CiWorkflow, err error)

type CiWorkflowRepositoryImpl

+ func (impl *CiWorkflowRepositoryImpl) FIndCiWorkflowStatusesByAppId(appId int) ([]*CiWorkflowStatus, error)

+ func (impl *CiWorkflowRepositoryImpl) FindCiWorkflowGitTriggersById(id int) (ciWorkflow *CiWorkflow, err error)

+ func (impl *CiWorkflowRepositoryImpl) FindLastTriggeredWorkflowGitTriggersByArtifactId(ciArtifactId int) (ciWorkflow *CiWorkflow, err error)

type GitMaterial

+ FilterPattern []string

type PipelineRepository

+ FilterDeploymentDeleteRequestedPipelineIds func(cdPipelineIds []int) (map[int]bool, error)

+ FindActiveByEnvIds func(envId []int) (pipelines []*Pipeline, err error)

+ FindAppAndEnvDetailsByPipelineId func(id int) (pipeline *Pipeline, err error)

+ GetPostStageConfigById func(id int) (pipeline *Pipeline, err error)

+ SetDeploymentAppCreatedInPipeline func(deploymentAppCreated bool, pipelineId int, userId int32) error

+ UpdateCdPipelineAfterDeployment func(deploymentAppType string, cdPipelineIdIncludes []int, userId int32, ...) error

type PipelineRepositoryImpl

+ func (impl PipelineRepositoryImpl) FilterDeploymentDeleteRequestedPipelineIds(cdPipelineIds []int) (map[int]bool, error)

+ func (impl PipelineRepositoryImpl) FindActiveByEnvIds(envIds []int) (pipelines []*Pipeline, err error)

+ func (impl PipelineRepositoryImpl) FindAppAndEnvDetailsByPipelineId(id int) (pipeline *Pipeline, err error)

+ func (impl PipelineRepositoryImpl) GetPostStageConfigById(id int) (pipeline *Pipeline, err error)

+ func (impl PipelineRepositoryImpl) SetDeploymentAppCreatedInPipeline(deploymentAppCreated bool, pipelineId int, userId int32) error

+ func (impl PipelineRepositoryImpl) UpdateCdPipelineAfterDeployment(deploymentAppType string, cdPipelineIdIncludes []int, userId int32, ...) error

type PipelineStatusSyncDetailRepository

+ GetByInstalledAppVersionHistoryId func(installedAppVersionHistoryId int) (*PipelineStatusSyncDetail, error)

+ GetOfLatestInstalledAppVersionHistoryByInstalledAppVersionId func(installedAppVersionId int) (*PipelineStatusSyncDetail, error)

type PipelineStatusSyncDetailRepositoryImpl

+ func (impl *PipelineStatusSyncDetailRepositoryImpl) GetByInstalledAppVersionHistoryId(installedAppVersionHistoryId int) (*PipelineStatusSyncDetail, error)

+ func (impl *PipelineStatusSyncDetailRepositoryImpl) GetOfLatestInstalledAppVersionHistoryByInstalledAppVersionId(installedAppVersionId int) (*PipelineStatusSyncDetail, error)

type PipelineStatusTimelineRepository

+ CheckIfTerminalStatusTimelinePresentByInstalledAppVersionHistoryId func(installedAppVersionHistoryId int) (bool, error)

+ FetchLatestTimelinesByInstalledAppVersionHistoryId func(installedAppVersionHistoryId int) (*PipelineStatusTimeline, error)

+ FetchTimelineByInstalledAppVersionHistoryIdAndPipelineStatuses func(installedAppVersionHistoryId int, statuses []TimelineStatus) ([]*PipelineStatusTimeline, error)

+ FetchTimelineByInstalledAppVersionHistoryIdAndStatus func(installedAppVersionHistoryId int, status TimelineStatus) (*PipelineStatusTimeline, error)

+ FetchTimelinesByInstalledAppVersionHistoryId func(installedAppVersionHistoryId int) ([]*PipelineStatusTimeline, error)

type PipelineStatusTimelineRepositoryImpl

+ func (impl *PipelineStatusTimelineRepositoryImpl) CheckIfTerminalStatusTimelinePresentByInstalledAppVersionHistoryId(installedAppVersionHistoryId int) (bool, error)

+ func (impl *PipelineStatusTimelineRepositoryImpl) FetchLatestTimelinesByInstalledAppVersionHistoryId(installedAppVersionHistoryId int) (*PipelineStatusTimeline, error)

+ func (impl *PipelineStatusTimelineRepositoryImpl) FetchTimelineByInstalledAppVersionHistoryIdAndPipelineStatuses(installedAppVersionHistoryId int, statuses []TimelineStatus) ([]*PipelineStatusTimeline, error)

+ func (impl *PipelineStatusTimelineRepositoryImpl) FetchTimelineByInstalledAppVersionHistoryIdAndStatus(installedAppVersionHistoryId int, status TimelineStatus) (*PipelineStatusTimeline, error)

+ func (impl *PipelineStatusTimelineRepositoryImpl) FetchTimelinesByInstalledAppVersionHistoryId(installedAppVersionHistoryId int) ([]*PipelineStatusTimeline, error)

type PipelineStatusTimelineResourcesRepository

+ GetByCdWfrIds func(cdWfrIds []int) ([]*PipelineStatusTimelineResources, error)

+ GetByInstalledAppVersionHistoryIdAndTimelineStage func(installedAppVersionHistoryId int) ([]*PipelineStatusTimelineResources, error)

type PipelineStatusTimelineResourcesRepositoryImpl

+ func (impl *PipelineStatusTimelineResourcesRepositoryImpl) GetByCdWfrIds(cdWfrIds []int) ([]*PipelineStatusTimelineResources, error)

+ func (impl *PipelineStatusTimelineResourcesRepositoryImpl) GetByInstalledAppVersionHistoryIdAndTimelineStage(installedAppVersionHistoryId int) ([]*PipelineStatusTimelineResources, error)

type TimelineStatus

+ const TIMELINE_STATUS_MANIFEST_GENERATED

May 25, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

May 23, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type CiPipelineRepository

+ FindByParentCiPipelineIds func(parentCiPipelineIds []int) ([]*CiPipeline, error)

+ FindCiPipelineConfigsByIds func(ids []int) ([]*CiPipeline, error)

+ FindCiScriptsByCiPipelineIds func(ciPipelineId []int) ([]*CiPipelineScript, error)

type CiPipelineRepositoryImpl

+ func (impl CiPipelineRepositoryImpl) FindByParentCiPipelineIds(parentCiPipelineIds []int) ([]*CiPipeline, error)

+ func (impl CiPipelineRepositoryImpl) FindCiPipelineConfigsByIds(ids []int) ([]*CiPipeline, error)

+ func (impl CiPipelineRepositoryImpl) FindCiScriptsByCiPipelineIds(ciPipelineIds []int) ([]*CiPipelineScript, error)

type CiTemplateOverrideRepository

+ FindByCiPipelineIds func(ciPipelineIds []int) ([]*CiTemplateOverride, error)

type CiTemplateOverrideRepositoryImpl

+ func (repo *CiTemplateOverrideRepositoryImpl) FindByCiPipelineIds(ciPipelineIds []int) ([]*CiTemplateOverride, error)

type CiTemplateRepository

+ FindByAppIds func(appIds []int) ([]*CiTemplate, error)

type CiTemplateRepositoryImpl

+ func (impl CiTemplateRepositoryImpl) FindByAppIds(appIds []int) ([]*CiTemplate, error)

type MaterialRepository

+ FindByAppIds func(appIds []int) ([]*GitMaterial, error)

type MaterialRepositoryImpl

+ func (repo MaterialRepositoryImpl) FindByAppIds(appId []int) ([]*GitMaterial, error)

Apr 11, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type CiPipelineRepository

+ FindAppAndProjectByCiPipelineIds func(ciPipelineIds []int) ([]*CiPipeline, error)

type CiPipelineRepositoryImpl

+ func (impl CiPipelineRepositoryImpl) FindAppAndProjectByCiPipelineIds(ciPipelineIds []int) ([]*CiPipeline, error)

type PipelineRepository

+ FindAppAndEnvironmentAndProjectByPipelineIds func(pipelineIds []int) (pipelines []*Pipeline, err error)

type PipelineRepositoryImpl

+ func (impl PipelineRepositoryImpl) FindAppAndEnvironmentAndProjectByPipelineIds(pipelineIds []int) (pipelines []*Pipeline, err error)

type WorkflowWithArtifact

+ IsArtifactUploaded bool

Mar 28, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type CiPipelineMaterialRepository

+ GetByPipelineIdForRegexAndFixed func(id int) ([]*CiPipelineMaterial, error)

type CiPipelineMaterialRepositoryImpl

+ func (impl CiPipelineMaterialRepositoryImpl) GetByPipelineIdForRegexAndFixed(id int) ([]*CiPipelineMaterial, error)

Feb 28, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

+ type AppDeploymentStatus struct

+ AppId int

+ DeployStatus string

+ PipelineId int

+ WfrId int

type AppLabel

+ Propagate bool

type CdWorkflowStatus

+ DeploymentAppDeleteRequest bool

type CiPipelineRepository

+ FindByAppIds func(appIds []int) (pipelines []*CiPipeline, err error)

+ FindExternalCiByAppIds func(appIds []int) ([]*ExternalCiPipeline, error)

type CiPipelineRepositoryImpl

+ func (impl CiPipelineRepositoryImpl) FindByAppIds(appIds []int) (pipelines []*CiPipeline, err error)

+ func (impl CiPipelineRepositoryImpl) FindExternalCiByAppIds(appIds []int) ([]*ExternalCiPipeline, error)

type Pipeline

+ DeploymentAppDeleteRequest bool

type PipelineRepository

+ FindActiveByAppIds func(appIds []int) (pipelines []*Pipeline, err error)

+ FindActiveByEnvIdAndDeploymentType func(environmentId int, deploymentAppType string, exclusionList []int, ...) ([]*Pipeline, error)

+ GetPartiallyDeletedPipelineByStatus func(appId int, envId int) (Pipeline, error)

+ UpdateCdPipelineDeploymentAppInFilter func(deploymentAppType string, cdPipelineIdIncludes []int, userId int32) error

type PipelineRepositoryImpl

+ func (impl PipelineRepositoryImpl) FindActiveByAppIds(appIds []int) (pipelines []*Pipeline, err error)

+ func (impl PipelineRepositoryImpl) FindActiveByEnvIdAndDeploymentType(environmentId int, deploymentAppType string, exclusionList []int, ...) ([]*Pipeline, error)

+ func (impl PipelineRepositoryImpl) GetPartiallyDeletedPipelineByStatus(appId int, envId int) (Pipeline, error)

+ func (impl PipelineRepositoryImpl) UpdateCdPipelineDeploymentAppInFilter(deploymentAppType string, cdPipelineIdIncludes []int, userId int32) error

Feb 27, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type CdWorkflowRepository

+ GetLatestTriggersOfHelmPipelinesStuckInNonTerminalStatuses func() ([]*CdWorkflowRunner, error)

type CdWorkflowRepositoryImpl

+ func (impl *CdWorkflowRepositoryImpl) GetLatestTriggersOfHelmPipelinesStuckInNonTerminalStatuses() ([]*CdWorkflowRunner, error)

Jan 31, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

+ const WorkflowAborted

+ const WorkflowFailed

+ const WorkflowInProgress

+ const WorkflowStarting

+ const WorkflowSucceeded

+ const WorkflowTimedOut

+ const WorkflowUnableToFetchState

type CdWorkflowRepository

+ FindLatestCdWorkflowRunnerByEnvironmentIdAndRunnerType func(appId int, environmentId int, runnerType bean.WorkflowType) (CdWorkflowRunner, error)

type CdWorkflowRepositoryImpl

+ func (impl *CdWorkflowRepositoryImpl) FindLatestCdWorkflowRunnerByEnvironmentIdAndRunnerType(appId int, environmentId int, runnerType bean.WorkflowType) (CdWorkflowRunner, error)

type Pipeline

+ DeploymentAppName string

type PipelineRepository

+ GetArgoPipelineByArgoAppName func(argoAppName string) (Pipeline, error)

+ GetArgoPipelinesHavingLatestTriggerStuckInNonTerminalStatuses func(deployedBeforeMinutes int) ([]*Pipeline, error)

+ GetArgoPipelinesHavingTriggersStuckInLastPossibleNonTerminalTimelines func(pendingSinceSeconds int, timeForDegradation int) ([]*Pipeline, error)

type PipelineRepositoryImpl

+ func (impl PipelineRepositoryImpl) GetArgoPipelineByArgoAppName(argoAppName string) (Pipeline, error)

+ func (impl PipelineRepositoryImpl) GetArgoPipelinesHavingLatestTriggerStuckInNonTerminalStatuses(deployedBeforeMinutes int) ([]*Pipeline, error)

+ func (impl PipelineRepositoryImpl) GetArgoPipelinesHavingTriggersStuckInLastPossibleNonTerminalTimelines(pendingSinceSeconds int, timeForDegradation int) ([]*Pipeline, error)

+ type PipelineStatusSyncDetail struct

+ CdWorkflowRunnerId int

+ Id int

+ InstalledAppVersionHistoryId int

+ LastSyncedAt time.Time

+ SyncCount int

+ type PipelineStatusSyncDetailRepository interface

+ GetByCdWfrId func(cdWfrId int) (*PipelineStatusSyncDetail, error)

+ GetOfLatestCdWfrByCdPipelineId func(pipelineId int) (*PipelineStatusSyncDetail, error)

+ Save func(model *PipelineStatusSyncDetail) error

+ Update func(model *PipelineStatusSyncDetail) error

+ type PipelineStatusSyncDetailRepositoryImpl struct

+ func NewPipelineStatusSyncDetailRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *PipelineStatusSyncDetailRepositoryImpl

+ func (impl *PipelineStatusSyncDetailRepositoryImpl) GetByCdWfrId(cdWfrId int) (*PipelineStatusSyncDetail, error)

+ func (impl *PipelineStatusSyncDetailRepositoryImpl) GetOfLatestCdWfrByCdPipelineId(pipelineId int) (*PipelineStatusSyncDetail, error)

+ func (impl *PipelineStatusSyncDetailRepositoryImpl) Save(model *PipelineStatusSyncDetail) error

+ func (impl *PipelineStatusSyncDetailRepositoryImpl) Update(model *PipelineStatusSyncDetail) error

type PipelineStatusTimelineRepository

+ DeleteByCdWfrIdAndTimelineStatuses func(cdWfrId int, status []TimelineStatus) error

+ DeleteByCdWfrIdAndTimelineStatusesWithTxn func(cdWfrId int, status []TimelineStatus, tx *pg.Tx) error

+ FetchLatestTimelineByWfrId func(wfrId int) (*PipelineStatusTimeline, error)

+ FetchTimelineByWfrIdAndStatuses func(wfrId int, statuses []TimelineStatus) ([]*PipelineStatusTimeline, error)

+ SaveTimelines func(timelines []*PipelineStatusTimeline) error

+ UpdateTimelines func(timelines []*PipelineStatusTimeline) error

+ UpdateTimelinesWithTxn func(timelines []*PipelineStatusTimeline, tx *pg.Tx) error

type PipelineStatusTimelineRepositoryImpl

+ func (impl *PipelineStatusTimelineRepositoryImpl) DeleteByCdWfrIdAndTimelineStatuses(cdWfrId int, status []TimelineStatus) error

+ func (impl *PipelineStatusTimelineRepositoryImpl) DeleteByCdWfrIdAndTimelineStatusesWithTxn(cdWfrId int, status []TimelineStatus, tx *pg.Tx) error

+ func (impl *PipelineStatusTimelineRepositoryImpl) FetchLatestTimelineByWfrId(wfrId int) (*PipelineStatusTimeline, error)

+ func (impl *PipelineStatusTimelineRepositoryImpl) FetchTimelineByWfrIdAndStatuses(wfrId int, statuses []TimelineStatus) ([]*PipelineStatusTimeline, error)

+ func (impl *PipelineStatusTimelineRepositoryImpl) SaveTimelines(timelines []*PipelineStatusTimeline) error

+ func (impl *PipelineStatusTimelineRepositoryImpl) UpdateTimelines(timelines []*PipelineStatusTimeline) error

+ func (impl *PipelineStatusTimelineRepositoryImpl) UpdateTimelinesWithTxn(timelines []*PipelineStatusTimeline, tx *pg.Tx) error

+ type PipelineStatusTimelineResources struct

+ CdWorkflowRunnerId int

+ Id int

+ InstalledAppVersionHistoryId int

+ ResourceGroup string

+ ResourceKind string

+ ResourceName string

+ ResourcePhase string

+ ResourceStatus string

+ StatusMessage string

+ TimelineStage ResourceTimelineStage

+ type PipelineStatusTimelineResourcesRepository interface

+ GetByCdWfrIdAndTimelineStage func(cdWfrId int) ([]*PipelineStatusTimelineResources, error)

+ SaveTimelineResources func(timelineResources []*PipelineStatusTimelineResources) error

+ SaveTimelineResourcesWithTxn func(timelineResources []*PipelineStatusTimelineResources, tx *pg.Tx) error

+ UpdateTimelineResources func(timelineResources []*PipelineStatusTimelineResources) error

+ UpdateTimelineResourcesWithTxn func(timelineResources []*PipelineStatusTimelineResources, tx *pg.Tx) error

+ type PipelineStatusTimelineResourcesRepositoryImpl struct

+ func NewPipelineStatusTimelineResourcesRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *PipelineStatusTimelineResourcesRepositoryImpl

+ func (impl *PipelineStatusTimelineResourcesRepositoryImpl) GetByCdWfrIdAndTimelineStage(cdWfrId int) ([]*PipelineStatusTimelineResources, error)

+ func (impl *PipelineStatusTimelineResourcesRepositoryImpl) SaveTimelineResources(timelineResources []*PipelineStatusTimelineResources) error

+ func (impl *PipelineStatusTimelineResourcesRepositoryImpl) SaveTimelineResourcesWithTxn(timelineResources []*PipelineStatusTimelineResources, tx *pg.Tx) error

+ func (impl *PipelineStatusTimelineResourcesRepositoryImpl) UpdateTimelineResources(timelineResources []*PipelineStatusTimelineResources) error

+ func (impl *PipelineStatusTimelineResourcesRepositoryImpl) UpdateTimelineResourcesWithTxn(timelineResources []*PipelineStatusTimelineResources, tx *pg.Tx) error

+ type ResourceTimelineStage string

+ const TIMELINE_RESOURCE_STAGE_KUBECTL_APPLY

type TimelineStatus

+ const TIMELINE_STATUS_DEPLOYMENT_SUPERSEDED

+ const TIMELINE_STATUS_FETCH_TIMED_OUT

+ const TIMELINE_STATUS_UNABLE_TO_FETCH_STATUS

Jan 17, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jan 9, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jan 3, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Dec 21, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Dec 14, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type CiPipelineRepository

+ FindExternalCiByAppId func(appId int) ([]*ExternalCiPipeline, error)

+ FindExternalCiById func(id int) (*ExternalCiPipeline, error)

type CiPipelineRepositoryImpl

+ func (impl CiPipelineRepositoryImpl) FindExternalCiByAppId(appId int) ([]*ExternalCiPipeline, error)

+ func (impl CiPipelineRepositoryImpl) FindExternalCiById(id int) (*ExternalCiPipeline, error)

type ExternalCiPipeline

+ AppId int

Dec 9, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Dec 2, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Dec 2, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Nov 25, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Nov 23, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Nov 16, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Nov 10, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

+ type BuildTypeCount struct

+ Count int

+ Status string

+ Type string

+ type CiBuildConfig struct

+ BuildMetadata string

+ CiTemplateId int

+ CiTemplateOverrideId int

+ Id int

+ Type string

+ type CiBuildConfigRepository interface

+ Delete func(ciBuildConfigId int) error

+ GetCountByBuildType func() (map[string]int, error)

+ Save func(ciBuildConfig *CiBuildConfig) error

+ Update func(ciBuildConfig *CiBuildConfig) error

+ type CiBuildConfigRepositoryImpl struct

+ func NewCiBuildConfigRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *CiBuildConfigRepositoryImpl

+ func (impl CiBuildConfigRepositoryImpl) Delete(ciBuildConfigId int) error

+ func (impl CiBuildConfigRepositoryImpl) GetCountByBuildType() (map[string]int, error)

+ func (impl CiBuildConfigRepositoryImpl) Save(ciBuildConfig *CiBuildConfig) error

+ func (impl CiBuildConfigRepositoryImpl) Update(ciBuildConfig *CiBuildConfig) error

type CiTemplate

+ CiBuildConfig *CiBuildConfig

+ CiBuildConfigId int

type CiTemplateOverride

+ CiBuildConfig *CiBuildConfig

+ CiBuildConfigId int

type CiWorkflow

+ CiBuildType string

type CiWorkflowRepository

+ FindBuildTypeAndStatusDataOfLast1Day func() []*BuildTypeCount

type CiWorkflowRepositoryImpl

+ func (impl *CiWorkflowRepositoryImpl) FindBuildTypeAndStatusDataOfLast1Day() []*BuildTypeCount

type WorkflowWithArtifact

+ CiBuildType string

Nov 3, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Nov 1, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type PipelineRepository

+ FindIdsByAppIdsAndEnvironmentIds func(appIds, environmentIds []int) (ids []int, err error)

+ FindIdsByProjectIdsAndEnvironmentIds func(projectIds, environmentIds []int) ([]int, error)

+ GetPipelineIdsHavingStatusTimelinesPendingAfterKubectlApplyStatus func(pendingSinceSeconds int) ([]int, error)

type PipelineRepositoryImpl

+ func (impl PipelineRepositoryImpl) FindIdsByAppIdsAndEnvironmentIds(appIds, environmentIds []int) ([]int, error)

+ func (impl PipelineRepositoryImpl) FindIdsByProjectIdsAndEnvironmentIds(projectIds, environmentIds []int) ([]int, error)

+ func (impl PipelineRepositoryImpl) GetPipelineIdsHavingStatusTimelinesPendingAfterKubectlApplyStatus(pendingSinceSeconds int) ([]int, error)

type PipelineStatusTimelineRepository

+ FetchLatestTimelineByAppIdAndEnvId func(appId, envId int) (*PipelineStatusTimeline, error)

type PipelineStatusTimelineRepositoryImpl

+ func (impl *PipelineStatusTimelineRepositoryImpl) FetchLatestTimelineByAppIdAndEnvId(appId, envId int) (*PipelineStatusTimeline, error)

Oct 18, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Oct 13, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type CdWorkflowRepository

+ FetchArtifactsByCdPipelineId func(pipelineId int, runnerType bean.WorkflowType, offset, limit int) ([]CdWorkflowRunner, error)

type CdWorkflowRepositoryImpl

+ func (impl *CdWorkflowRepositoryImpl) FetchArtifactsByCdPipelineId(pipelineId int, runnerType bean.WorkflowType, offset, limit int) ([]CdWorkflowRunner, error)

Oct 8, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type CdWorkflowRunner

+ PodName string

type CiTemplate

+ DockerBuildOptions string

type CiWorkflow

+ PodName string

type PipelineRepository

+ FindActiveByInFilter func(envId int, appIdIncludes []int) (pipelines []*Pipeline, err error)

+ FindActiveByNotFilter func(envId int, appIdExcludes []int) (pipelines []*Pipeline, err error)

type PipelineRepositoryImpl

+ func (impl PipelineRepositoryImpl) FindActiveByInFilter(envId int, appIdIncludes []int) (pipelines []*Pipeline, err error)

+ func (impl PipelineRepositoryImpl) FindActiveByNotFilter(envId int, appIdExcludes []int) (pipelines []*Pipeline, err error)

type WorkflowWithArtifact

+ PodName string

Sep 24, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type CdWorkflowRunner

+ BlobStorageEnabled bool

type CdWorkflowWithArtifact

+ BlobStorageEnabled bool

type CiPipeline

+ IsDockerConfigOverridden bool

+ type CiTemplateOverride struct

+ Active bool

+ CiPipelineId int

+ DockerRegistry *repository.DockerArtifactStore

+ DockerRegistryId string

+ DockerRepository string

+ DockerfilePath string

+ GitMaterial *GitMaterial

+ GitMaterialId int

+ Id int

+ type CiTemplateOverrideRepository interface

+ FindByAppId func(appId int) ([]*CiTemplateOverride, error)

+ FindByCiPipelineId func(ciPipelineId int) (*CiTemplateOverride, error)

+ Save func(templateOverrideConfig *CiTemplateOverride) (*CiTemplateOverride, error)

+ Update func(templateOverrideConfig *CiTemplateOverride) (*CiTemplateOverride, error)

+ type CiTemplateOverrideRepositoryImpl struct

+ func NewCiTemplateOverrideRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *CiTemplateOverrideRepositoryImpl

+ func (repo *CiTemplateOverrideRepositoryImpl) FindByAppId(appId int) ([]*CiTemplateOverride, error)

+ func (repo *CiTemplateOverrideRepositoryImpl) FindByCiPipelineId(ciPipelineId int) (*CiTemplateOverride, error)

+ func (repo *CiTemplateOverrideRepositoryImpl) Save(templateOverrideConfig *CiTemplateOverride) (*CiTemplateOverride, error)

+ func (repo *CiTemplateOverrideRepositoryImpl) Update(templateOverrideConfig *CiTemplateOverride) (*CiTemplateOverride, error)

type CiWorkflow

+ BlobStorageEnabled bool

type CiWorkflowStatus

+ StorageConfigured bool

type WorkflowWithArtifact

+ BlobStorageEnabled bool

Sep 13, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Sep 1, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Sep 1, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type CdWorkflowRepository

+ FindCdWorkflowRunnerByEnvironmentIdAndRunnerType func(appId int, environmentId int, runnerType bean.WorkflowType) (CdWorkflowRunner, error)

+ FindLatestWfrByAppIdAndEnvironmentId func(appId int, environmentId int) (CdWorkflowRunner, error)

+ GetConnection func() *pg.DB

+ UpdateWorkFlowRunnersWithTxn func(wfrs []CdWorkflowRunner, tx *pg.Tx) error

type CdWorkflowRepositoryImpl

+ func (impl *CdWorkflowRepositoryImpl) FindCdWorkflowRunnerByEnvironmentIdAndRunnerType(appId int, environmentId int, runnerType bean.WorkflowType) (CdWorkflowRunner, error)

+ func (impl *CdWorkflowRepositoryImpl) FindLatestWfrByAppIdAndEnvironmentId(appId int, environmentId int) (CdWorkflowRunner, error)

+ func (impl *CdWorkflowRepositoryImpl) GetConnection() *pg.DB

+ func (impl *CdWorkflowRepositoryImpl) UpdateWorkFlowRunnersWithTxn(wfrs []CdWorkflowRunner, tx *pg.Tx) error

type PipelineStatusTimelineRepository

+ CheckIfTerminalStatusTimelinePresentByWfrId func(wfrId int) (bool, error)

+ FetchTimelineByWfrIdAndStatus func(wfrId int, status TimelineStatus) (*PipelineStatusTimeline, error)

+ SaveTimelinesWithTxn func(timelines []PipelineStatusTimeline, tx *pg.Tx) error

type PipelineStatusTimelineRepositoryImpl

+ func (impl *PipelineStatusTimelineRepositoryImpl) CheckIfTerminalStatusTimelinePresentByWfrId(wfrId int) (bool, error)

+ func (impl *PipelineStatusTimelineRepositoryImpl) FetchTimelineByWfrIdAndStatus(wfrId int, status TimelineStatus) (*PipelineStatusTimeline, error)

+ func (impl *PipelineStatusTimelineRepositoryImpl) SaveTimelinesWithTxn(timelines []PipelineStatusTimeline, tx *pg.Tx) error

type TimelineStatus

+ const TIMELINE_STATUS_DEPLOYMENT_FAILED

+ const TIMELINE_STATUS_DEPLOYMENT_INITIATED

+ const TIMELINE_STATUS_GIT_COMMIT_FAILED

Aug 30, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Aug 25, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type CiPipelineMaterial

+ Regex string

type CiPipelineMaterialRepository

+ CheckRegexExistsForMaterial func(id int) bool

+ GetRegexByPipelineId func(id int) ([]*CiPipelineMaterial, error)

type CiPipelineMaterialRepositoryImpl

+ func (impl CiPipelineMaterialRepositoryImpl) CheckRegexExistsForMaterial(id int) bool

+ func (impl CiPipelineMaterialRepositoryImpl) GetRegexByPipelineId(id int) ([]*CiPipelineMaterial, error)

+ type PipelineStatusTimeline struct

+ CdWorkflowRunnerId int

+ Id int

+ InstalledAppVersionHistoryId int

+ Status TimelineStatus

+ StatusDetail string

+ StatusTime time.Time

+ type PipelineStatusTimelineRepository interface

+ CheckTimelineExistsOfLatestWfByCdWorkflowIdAndStatus func(cdWorkflowId int, status TimelineStatus) (bool, error)

+ FetchTimelineOfLatestWfByCdWorkflowIdAndStatus func(pipelineId int, status TimelineStatus) (*PipelineStatusTimeline, error)

+ FetchTimelinesByPipelineId func(pipelineId int) ([]*PipelineStatusTimeline, error)

+ FetchTimelinesByWfrId func(wfrId int) ([]*PipelineStatusTimeline, error)

+ SaveTimeline func(timeline *PipelineStatusTimeline) error

+ UpdateTimeline func(timeline *PipelineStatusTimeline) error

+ type PipelineStatusTimelineRepositoryImpl struct

+ func NewPipelineStatusTimelineRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *PipelineStatusTimelineRepositoryImpl

+ func (impl *PipelineStatusTimelineRepositoryImpl) CheckTimelineExistsOfLatestWfByCdWorkflowIdAndStatus(cdWorkflowId int, status TimelineStatus) (bool, error)

+ func (impl *PipelineStatusTimelineRepositoryImpl) FetchTimelineOfLatestWfByCdWorkflowIdAndStatus(cdWorkflowId int, status TimelineStatus) (*PipelineStatusTimeline, error)

+ func (impl *PipelineStatusTimelineRepositoryImpl) FetchTimelinesByPipelineId(pipelineId int) ([]*PipelineStatusTimeline, error)

+ func (impl *PipelineStatusTimelineRepositoryImpl) FetchTimelinesByWfrId(wfrId int) ([]*PipelineStatusTimeline, error)

+ func (impl *PipelineStatusTimelineRepositoryImpl) SaveTimeline(timeline *PipelineStatusTimeline) error

+ func (impl *PipelineStatusTimelineRepositoryImpl) UpdateTimeline(timeline *PipelineStatusTimeline) error

+ type TimelineStatus string

+ const TIMELINE_STATUS_APP_DEGRADED

+ const TIMELINE_STATUS_APP_HEALTHY

+ const TIMELINE_STATUS_GIT_COMMIT

+ const TIMELINE_STATUS_KUBECTL_APPLY_STARTED

+ const TIMELINE_STATUS_KUBECTL_APPLY_SYNCED

Jul 22, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type CiTemplate

+ TargetPlatform string

Jul 21, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jul 19, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jul 19, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jul 8, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jul 5, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jul 1, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jun 29, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jun 27, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jun 23, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jun 22, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jun 21, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jun 17, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type PipelineRepository

+ GetAppAndEnvDetailsForDeploymentAppTypePipeline func(deploymentAppType string, clusterIds []int) ([]*Pipeline, error)

type PipelineRepositoryImpl

+ func (impl PipelineRepositoryImpl) GetAppAndEnvDetailsForDeploymentAppTypePipeline(deploymentAppType string, clusterIds []int) ([]*Pipeline, error)

Jun 14, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type CiPipelineRepository

+ FindNumberOfAppsWithCiPipeline func(appIds []int) (count int, err error)

type CiPipelineRepositoryImpl

+ func (impl CiPipelineRepositoryImpl) FindNumberOfAppsWithCiPipeline(appIds []int) (count int, err error)

type CiTemplateRepository

+ FindNumberOfAppsWithDockerConfigured func(appIds []int) (int, error)

type CiTemplateRepositoryImpl

+ func (impl CiTemplateRepositoryImpl) FindNumberOfAppsWithDockerConfigured(appIds []int) (int, error)

type MaterialRepository

+ FindNumberOfAppsWithGitRepo func(appIds []int) (int, error)

type MaterialRepositoryImpl

+ func (repo MaterialRepositoryImpl) FindNumberOfAppsWithGitRepo(appIds []int) (int, error)

type Pipeline

+ DeploymentAppType string

type PipelineRepository

+ FindNumberOfAppsWithCdPipeline func(appIds []int) (count int, err error)

type PipelineRepositoryImpl

+ func (impl PipelineRepositoryImpl) FindNumberOfAppsWithCdPipeline(appIds []int) (count int, err error)

Jun 13, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jun 9, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jun 8, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jun 6, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

May 31, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

May 30, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type PipelineRepository

+ FindActiveByAppIdAndPipelineId func(appId int, pipelineId int) ([]*Pipeline, error)

type PipelineRepositoryImpl

+ func (impl PipelineRepositoryImpl) FindActiveByAppIdAndPipelineId(appId int, pipelineId int) ([]*Pipeline, error)

May 30, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

May 27, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

May 25, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type Pipeline

+ DeploymentAppCreated bool

type PipelineRepository

+ UpdateCdPipeline func(pipeline *Pipeline) error

type PipelineRepositoryImpl

+ func (impl PipelineRepositoryImpl) UpdateCdPipeline(pipeline *Pipeline) error

May 20, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

May 18, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type CdWorkflowRepository

+ ExistsByStatus func(status string) (bool, error)

type CdWorkflowRepositoryImpl

+ func (impl *CdWorkflowRepositoryImpl) ExistsByStatus(status string) (bool, error)

type CiPipelineRepository

+ Exists func() (exist bool, err error)

type CiPipelineRepositoryImpl

+ func (impl CiPipelineRepositoryImpl) Exists() (exist bool, err error)

type CiWorkflowRepository

+ ExistsByStatus func(status string) (bool, error)

type CiWorkflowRepositoryImpl

+ func (impl *CiWorkflowRepositoryImpl) ExistsByStatus(status string) (bool, error)

type PipelineRepository

+ Exists func() (exist bool, err error)

type PipelineRepositoryImpl

+ func (impl PipelineRepositoryImpl) Exists() (exist bool, err error)

May 17, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type CiPipelineRepository

+ MarkCiPipelineScriptsInactiveByCiPipelineId func(ciPipelineId int, tx *pg.Tx) error

type CiPipelineRepositoryImpl

+ func (impl CiPipelineRepositoryImpl) MarkCiPipelineScriptsInactiveByCiPipelineId(ciPipelineId int, tx *pg.Tx) error

May 10, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

May 2, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Apr 21, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Apr 17, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Apr 13, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Apr 7, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Apr 1, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Mar 29, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Mar 25, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type PipelineRepository

+ FindAllPipelinesByChartsOverrideAndAppIdAndChartId func(chartOverridden bool, appId int, chartId int) (pipelines []*Pipeline, err error)

+ GetByEnvOverrideIdAndEnvId func(envOverrideId, envId int) (Pipeline, error)

type PipelineRepositoryImpl

+ func (impl PipelineRepositoryImpl) FindAllPipelinesByChartsOverrideAndAppIdAndChartId(hasConfigOverridden bool, appId int, chartId int) (pipelines []*Pipeline, err error)

+ func (impl PipelineRepositoryImpl) GetByEnvOverrideIdAndEnvId(envOverrideId, envId int) (Pipeline, error)

Mar 21, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Mar 14, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Mar 10, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Mar 4, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Feb 25, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Feb 14, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type CiTemplateRepository

+ FindByDockerRegistryId func(dockerRegistryId string) (ciTemplates []*CiTemplate, err error)

type CiTemplateRepositoryImpl

+ func (impl CiTemplateRepositoryImpl) FindByDockerRegistryId(dockerRegistryId string) (ciTemplates []*CiTemplate, err error)

type MaterialRepository

+ FindByGitProviderId func(gitProviderId int) (materials []*GitMaterial, err error)

+ MarkMaterialDeleted func(material *GitMaterial) error

type MaterialRepositoryImpl

+ func (repo MaterialRepositoryImpl) FindByGitProviderId(gitProviderId int) (materials []*GitMaterial, err error)

+ func (repo MaterialRepositoryImpl) MarkMaterialDeleted(material *GitMaterial) error

type PipelineRepository

+ FindActiveByEnvId func(envId int) (pipelines []*Pipeline, err error)

type PipelineRepositoryImpl

+ func (impl PipelineRepositoryImpl) FindActiveByEnvId(envId int) (pipelines []*Pipeline, err error)

Feb 7, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jan 8, 2022 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Dec 29, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type PipelineRepository

+ FindByParentCiPipelineId func(ciPipelineId int) (pipelines []*Pipeline, err error)

type PipelineRepositoryImpl

+ func (impl PipelineRepositoryImpl) FindByParentCiPipelineId(ciPipelineId int) (pipelines []*Pipeline, err error)

Dec 23, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Dec 17, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Dec 16, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Dec 13, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Dec 9, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Dec 2, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type MaterialRepository

+ FindByAppIdAndCheckoutPath func(appId int, checkoutPath string) (*GitMaterial, error)

type MaterialRepositoryImpl

+ func (repo MaterialRepositoryImpl) FindByAppIdAndCheckoutPath(appId int, checkoutPath string) (*GitMaterial, error)

Nov 29, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Nov 27, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Nov 27, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Nov 26, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Nov 23, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Nov 20, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Nov 18, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Nov 11, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type GitCommit

+ CiConfigureSourceType SourceType

+ CiConfigureSourceValue string

+ GitRepoName string

+ GitRepoUrl string

Nov 3, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Oct 29, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Oct 21, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Oct 10, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type GitMaterial

+ FetchSubmodules bool

Sep 28, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Sep 27, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Sep 23, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Sep 9, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Sep 2, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Aug 27, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Aug 26, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Aug 24, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

+ type AppLabel struct

+ App App

+ AppId int

+ Id int

+ Key string

+ Value string

+ type AppLabelRepository interface

+ Create func(model *AppLabel, tx *pg.Tx) (*AppLabel, error)

+ Delete func(model *AppLabel, tx *pg.Tx) error

+ FindAll func() ([]*AppLabel, error)

+ FindAllByAppId func(appId int) ([]*AppLabel, error)

+ FindAllByIds func(ids []int) ([]*AppLabel, error)

+ FindByAppIdAndKeyAndValue func(appId int, key string, value string) (*AppLabel, error)

+ FindById func(id int) (*AppLabel, error)

+ FindByLabelKey func(key string) ([]*AppLabel, error)

+ FindByLabelValue func(label string) ([]*AppLabel, error)

+ Update func(model *AppLabel) (*AppLabel, error)

+ type AppLabelRepositoryImpl struct

+ func NewAppLabelRepositoryImpl(dbConnection *pg.DB) *AppLabelRepositoryImpl

+ func (impl AppLabelRepositoryImpl) Create(model *AppLabel, tx *pg.Tx) (*AppLabel, error)

+ func (impl AppLabelRepositoryImpl) Delete(model *AppLabel, tx *pg.Tx) error

+ func (impl AppLabelRepositoryImpl) FindAll() ([]*AppLabel, error)

+ func (impl AppLabelRepositoryImpl) FindAllByAppId(appId int) ([]*AppLabel, error)

+ func (impl AppLabelRepositoryImpl) FindAllByIds(ids []int) ([]*AppLabel, error)

+ func (impl AppLabelRepositoryImpl) FindByAppIdAndKeyAndValue(appId int, key string, value string) (*AppLabel, error)

+ func (impl AppLabelRepositoryImpl) FindById(id int) (*AppLabel, error)

+ func (impl AppLabelRepositoryImpl) FindByLabelKey(key string) ([]*AppLabel, error)

+ func (impl AppLabelRepositoryImpl) FindByLabelValue(label string) ([]*AppLabel, error)

+ func (impl AppLabelRepositoryImpl) Update(model *AppLabel) (*AppLabel, error)

type AppRepository

+ GetConnection func() *pg.DB

+ UpdateWithTxn func(app *App, tx *pg.Tx) error

type AppRepositoryImpl

+ func (repo AppRepositoryImpl) GetConnection() *pg.DB

+ func (repo AppRepositoryImpl) UpdateWithTxn(app *App, tx *pg.Tx) error

Aug 20, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type GitCommit

+ WebhookData WebhookData

type SourceType

+ const SOURCE_TYPE_WEBHOOK

+ type WebhookData struct

+ Data map[string]string

+ EventActionType string

+ Id int

Aug 13, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type AppRepository

+ FindAppAndProjectByAppId func(appId int) (*App, error)

type AppRepositoryImpl

+ func (repo AppRepositoryImpl) FindAppAndProjectByAppId(appId int) (*App, error)

Aug 10, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jul 28, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jul 20, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jul 16, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jul 9, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jul 2, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jun 28, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type CiPipelineRepository

+ FindAllPipelineInLast24Hour func() (pipelines []*CiPipeline, err error)

type CiPipelineRepositoryImpl

+ func (impl CiPipelineRepositoryImpl) FindAllPipelineInLast24Hour() (pipelines []*CiPipeline, err error)

type PipelineRepository

+ FindAllPipelineInLast24Hour func() (pipelines []*Pipeline, err error)

type PipelineRepositoryImpl

+ func (impl PipelineRepositoryImpl) FindAllPipelineInLast24Hour() (pipelines []*Pipeline, err error)

Jun 17, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jun 1, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

May 24, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

May 23, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

May 5, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Apr 23, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

type AppRepository

+ FindActiveListByName func(appName string) ([]*App, error)

type AppRepositoryImpl

+ func (repo AppRepositoryImpl) FindActiveListByName(appName string) ([]*App, error)

Mar 15, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Mar 15, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Mar 15, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Mar 15, 2021 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

+ const WORKFLOW_EXECUTOR_TYPE_AWF

+ const WORKFLOW_EXECUTOR_TYPE_SYSTEM

+ type App struct

+ Active bool

+ AppName string

+ AppStore bool

+ Id int

+ Team team.Team

+ TeamId int

+ type AppRepository interface

+ AppExists func(appName string) (bool, error)

+ CheckAppExists func(appNames []string) ([]*App, error)

+ FetchAppsByFilter func(appNameIncludes string, appNameExcludes string) ([]*App, error)

+ FetchAppsByFilterV2 func(appNameIncludes string, appNameExcludes string, environmentId int) ([]*App, error)

+ FindActiveByName func(appName string) (pipelineGroup *App, err error)

+ FindAll func() ([]App, error)

+ FindAllActiveAppsWithTeam func() ([]*App, error)

+ FindAppsByEnvironmentId func(environmentId int) ([]App, error)

+ FindAppsByTeamId func(teamId int) ([]App, error)

+ FindAppsByTeamIds func(teamId []int) ([]App, error)

+ FindAppsByTeamName func(teamName string) ([]App, error)

+ FindById func(id int) (pipelineGroup *App, err error)

+ FindByIds func(ids []*int) ([]*App, error)

+ Save func(pipelineGroup *App) error

+ SaveWithTxn func(pipelineGroup *App, tx *pg.Tx) error

+ Update func(app *App) error

+ type AppRepositoryImpl struct

+ func NewAppRepositoryImpl(dbConnection *pg.DB) *AppRepositoryImpl

+ func (repo AppRepositoryImpl) AppExists(appName string) (bool, error)

+ func (repo AppRepositoryImpl) CheckAppExists(appNames []string) ([]*App, error)

+ func (repo AppRepositoryImpl) FetchAppsByFilter(appNameIncludes string, appNameExcludes string) ([]*App, error)

+ func (repo AppRepositoryImpl) FetchAppsByFilterV2(appNameIncludes string, appNameExcludes string, environmentId int) ([]*App, error)

+ func (repo AppRepositoryImpl) FindActiveByName(appName string) (*App, error)

+ func (repo AppRepositoryImpl) FindAll() ([]App, error)

+ func (repo AppRepositoryImpl) FindAllActiveAppsWithTeam() ([]*App, error)

+ func (repo AppRepositoryImpl) FindAppsByEnvironmentId(environmentId int) ([]App, error)

+ func (repo AppRepositoryImpl) FindAppsByTeamId(teamId int) ([]App, error)

+ func (repo AppRepositoryImpl) FindAppsByTeamIds(teamId []int) ([]App, error)

+ func (repo AppRepositoryImpl) FindAppsByTeamName(teamName string) ([]App, error)

+ func (repo AppRepositoryImpl) FindById(id int) (*App, error)

+ func (repo AppRepositoryImpl) FindByIds(ids []*int) ([]*App, error)

+ func (repo AppRepositoryImpl) Save(pipelineGroup *App) error

+ func (repo AppRepositoryImpl) SaveWithTxn(pipelineGroup *App, tx *pg.Tx) error

+ func (repo AppRepositoryImpl) Update(app *App) error

+ type CdWorkflow struct

+ CdWorkflowRunner []CdWorkflowRunner

+ CiArtifact *repository.CiArtifact

+ CiArtifactId int

+ Id int

+ Pipeline *Pipeline

+ PipelineId int

+ WorkflowStatus WorkflowStatus

+ type CdWorkflowConfig struct

+ CdArtifactLocationFormat string

+ CdCacheBucket string

+ CdCacheRegion string

+ CdImage string

+ CdPipelineId int

+ CdTimeout int64

+ Id int

+ LogsBucket string

+ MaxCpu string

+ MaxEphStorage string

+ MaxMem string

+ MaxStorage string

+ MinCpu string

+ MinEphStorage string

+ MinMem string

+ MinStorage string

+ Namespace string

+ type CdWorkflowRepository interface

+ FetchAllCdStagesLatestEntity func(pipelineIds []int) ([]*CdWorkflowStatus, error)

+ FetchAllCdStagesLatestEntityStatus func(wfrIds []int) ([]*CdWorkflowRunner, error)

+ FindArtifactByPipelineIdAndRunnerType func(pipelineId int, runnerType bean.CdWorkflowType, limit int) ([]CdWorkflowRunner, error)

+ FindById func(wfId int) (*CdWorkflow, error)

+ FindByWorkflowIdAndRunnerType func(wfId int, runnerType bean.CdWorkflowType) (CdWorkflowRunner, error)

+ FindCdWorkflowMetaByEnvironmentId func(appId int, environmentId int, offset int, size int) ([]CdWorkflowRunner, error)

+ FindCdWorkflowMetaByPipelineId func(pipelineId int, offset int, size int) ([]CdWorkflowRunner, error)

+ FindConfigByPipelineId func(pipelineId int) (*CdWorkflowConfig, error)

+ FindLastPreOrPostTriggeredByEnvironmentId func(appId int, environmentId int) (CdWorkflowRunner, error)

+ FindLastPreOrPostTriggeredByPipelineId func(pipelineId int) (CdWorkflowRunner, error)

+ FindLastStatusByPipelineIdAndRunnerType func(pipelineId int, runnerType bean.CdWorkflowType) (CdWorkflowRunner, error)

+ FindLatestCdWorkflowByPipelineId func(pipelineIds []int) (*CdWorkflow, error)

+ FindLatestCdWorkflowByPipelineIdV2 func(pipelineIds []int) ([]*CdWorkflow, error)

+ FindPreviousCdWfRunnerByStatus func(pipelineId int, currentWFRunnerId int, status []string) ([]*CdWorkflowRunner, error)

+ FindWorkflowRunnerByCdWorkflowId func(wfIds []int) ([]*CdWorkflowRunner, error)

+ FindWorkflowRunnerById func(wfrId int) (*CdWorkflowRunner, error)

+ IsLatestWf func(pipelineId int, wfId int) (bool, error)

+ SaveWorkFlow func(wf *CdWorkflow) error

+ SaveWorkFlowRunner func(wfr *CdWorkflowRunner) error

+ SaveWorkFlows func(wfs ...*CdWorkflow) error

+ UpdateWorkFlow func(wf *CdWorkflow) error

+ UpdateWorkFlowRunner func(wfr *CdWorkflowRunner) error

+ UpdateWorkFlowRunners func(wfr []*CdWorkflowRunner) error

+ type CdWorkflowRepositoryImpl struct

+ func NewCdWorkflowRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *CdWorkflowRepositoryImpl

+ func (impl *CdWorkflowRepositoryImpl) FetchAllCdStagesLatestEntity(pipelineIds []int) ([]*CdWorkflowStatus, error)

+ func (impl *CdWorkflowRepositoryImpl) FetchAllCdStagesLatestEntityStatus(wfrIds []int) ([]*CdWorkflowRunner, error)

+ func (impl *CdWorkflowRepositoryImpl) FindArtifactByPipelineIdAndRunnerType(pipelineId int, runnerType bean.CdWorkflowType, limit int) ([]CdWorkflowRunner, error)

+ func (impl *CdWorkflowRepositoryImpl) FindById(wfId int) (*CdWorkflow, error)

+ func (impl *CdWorkflowRepositoryImpl) FindByWorkflowIdAndRunnerType(wfId int, runnerType bean.CdWorkflowType) (CdWorkflowRunner, error)

+ func (impl *CdWorkflowRepositoryImpl) FindCdWorkflowMetaByEnvironmentId(appId int, environmentId int, offset int, limit int) ([]CdWorkflowRunner, error)

+ func (impl *CdWorkflowRepositoryImpl) FindCdWorkflowMetaByPipelineId(pipelineId int, offset int, limit int) ([]CdWorkflowRunner, error)

+ func (impl *CdWorkflowRepositoryImpl) FindConfigByPipelineId(pipelineId int) (*CdWorkflowConfig, error)

+ func (impl *CdWorkflowRepositoryImpl) FindLastPreOrPostTriggeredByEnvironmentId(appId int, environmentId int) (CdWorkflowRunner, error)

+ func (impl *CdWorkflowRepositoryImpl) FindLastPreOrPostTriggeredByPipelineId(pipelineId int) (CdWorkflowRunner, error)

+ func (impl *CdWorkflowRepositoryImpl) FindLastStatusByPipelineIdAndRunnerType(pipelineId int, runnerType bean.CdWorkflowType) (CdWorkflowRunner, error)

+ func (impl *CdWorkflowRepositoryImpl) FindLatestCdWorkflowByPipelineId(pipelineIds []int) (*CdWorkflow, error)

+ func (impl *CdWorkflowRepositoryImpl) FindLatestCdWorkflowByPipelineIdV2(pipelineIds []int) ([]*CdWorkflow, error)

+ func (impl *CdWorkflowRepositoryImpl) FindPreviousCdWfRunnerByStatus(pipelineId int, currentWFRunnerId int, status []string) ([]*CdWorkflowRunner, error)

+ func (impl *CdWorkflowRepositoryImpl) FindWorkflowRunnerByCdWorkflowId(wfIds []int) ([]*CdWorkflowRunner, error)

+ func (impl *CdWorkflowRepositoryImpl) FindWorkflowRunnerById(wfrId int) (*CdWorkflowRunner, error)

+ func (impl *CdWorkflowRepositoryImpl) IsLatestWf(pipelineId int, wfId int) (bool, error)

+ func (impl *CdWorkflowRepositoryImpl) SaveWorkFlow(wf *CdWorkflow) error

+ func (impl *CdWorkflowRepositoryImpl) SaveWorkFlowRunner(wfr *CdWorkflowRunner) error

+ func (impl *CdWorkflowRepositoryImpl) SaveWorkFlows(wfs ...*CdWorkflow) error

+ func (impl *CdWorkflowRepositoryImpl) UpdateWorkFlow(wf *CdWorkflow) error

+ func (impl *CdWorkflowRepositoryImpl) UpdateWorkFlowRunner(wfr *CdWorkflowRunner) error

+ func (impl *CdWorkflowRepositoryImpl) UpdateWorkFlowRunners(wfr []*CdWorkflowRunner) error

+ type CdWorkflowRunner struct

+ CdWorkflow *CdWorkflow

+ CdWorkflowId int

+ ExecutorType WorkflowExecutorType

+ FinishedOn time.Time

+ Id int

+ LogLocation string

+ Message string

+ Name string

+ Namespace string

+ PodStatus string

+ StartedOn time.Time

+ Status string

+ TriggeredBy int32

+ WorkflowType bean.CdWorkflowType

+ type CdWorkflowStatus struct

+ CiPipelineId int

+ DeployStatus string

+ PipelineId int

+ PipelineName string

+ PostStatus string

+ PreStatus string

+ WfrId int

+ WorkflowType string

+ type CdWorkflowWithArtifact struct

+ CdWorkflowId int

+ CiArtifactId int

+ DataSource string

+ EmailId string

+ ExecutorType string

+ FinishedOn time.Time

+ Id int

+ Image string

+ LogFilePath string

+ MaterialInfo string

+ Message string

+ Name string

+ Namespace string

+ PipelineId int

+ PodStatus string

+ StartedOn time.Time

+ Status string

+ TriggeredBy int32

+ WorkflowType string

+ type CiArtifactDTO struct

+ DataSource string

+ Id int

+ Image string

+ ImageDigest string

+ MaterialInfo string

+ PipelineId int

+ WorkflowId *int

+ type CiPipeline struct

+ Active bool

+ App *App

+ AppId int

+ CiPipelineMaterials []*CiPipelineMaterial

+ CiTemplate *CiTemplate

+ CiTemplateId int

+ Deleted bool

+ DockerArgs string

+ ExternalCiPipeline *ExternalCiPipeline

+ Id int

+ IsExternal bool

+ IsManual bool

+ Name string

+ ParentCiPipeline int

+ ScanEnabled bool

+ Version string

+ type CiPipelineMaterial struct

+ Active bool

+ CheckoutPath string

+ CiPipeline *CiPipeline

+ CiPipelineId int

+ GitMaterial *GitMaterial

+ GitMaterialId int

+ GitTag string

+ Id int

+ Path string

+ ScmId string

+ ScmName string

+ ScmVersion string

+ Type SourceType

+ Value string

+ type CiPipelineMaterialRepository interface

+ FindByCiPipelineIdsIn func(ids []int) ([]*CiPipelineMaterial, error)

+ GetByGitMaterialUrlAndType func(url string, ciPipelineMaterialType string) ([]*CiPipelineMaterial, error)

+ GetById func(id int) (*CiPipelineMaterial, error)

+ GetByPipelineId func(id int) ([]*CiPipelineMaterial, error)

+ Save func(tx *pg.Tx, pipeline ...*CiPipelineMaterial) error

+ Update func(tx *pg.Tx, material ...*CiPipelineMaterial) error

+ type CiPipelineMaterialRepositoryImpl struct

+ func NewCiPipelineMaterialRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *CiPipelineMaterialRepositoryImpl

+ func (impl CiPipelineMaterialRepositoryImpl) FindByCiPipelineIdsIn(ids []int) ([]*CiPipelineMaterial, error)

+ func (impl CiPipelineMaterialRepositoryImpl) GetByGitMaterialUrlAndType(url string, ciPipelineMaterialType string) ([]*CiPipelineMaterial, error)

+ func (impl CiPipelineMaterialRepositoryImpl) GetById(id int) (*CiPipelineMaterial, error)

+ func (impl CiPipelineMaterialRepositoryImpl) GetByPipelineId(id int) ([]*CiPipelineMaterial, error)

+ func (impl CiPipelineMaterialRepositoryImpl) Save(tx *pg.Tx, material ...*CiPipelineMaterial) error

+ func (impl CiPipelineMaterialRepositoryImpl) Update(tx *pg.Tx, materials ...*CiPipelineMaterial) error

+ type CiPipelineRepository interface

+ FetchCiPipelinesForDG func(parentId int, childCiPipelineIds []int) (*CiPipeline, int, error)

+ FetchParentCiPipelinesForDG func() ([]*CiPipelinesMap, error)

+ FinDByParentCiPipelineAndAppId func(parentCiPipeline int, appIds []int) ([]*CiPipeline, error)

+ FindByAppId func(appId int) (pipelines []*CiPipeline, err error)

+ FindByCiAndAppDetailsById func(pipelineId int) (pipeline *CiPipeline, err error)

+ FindById func(id int) (pipeline *CiPipeline, err error)

+ FindByIdsIn func(ids []int) ([]*CiPipeline, error)

+ FindByName func(pipelineName string) (pipeline *CiPipeline, err error)

+ FindByParentCiPipelineId func(parentCiPipelineId int) ([]*CiPipeline, error)

+ FindCiScriptsByCiPipelineId func(ciPipelineId int) ([]*CiPipelineScript, error)

+ FindExternalCiByCiPipelineId func(ciPipelineId int) (*ExternalCiPipeline, error)

+ PipelineExistsByName func(names []string) (found []string, err error)

+ Save func(pipeline *CiPipeline, tx *pg.Tx) error

+ SaveCiPipelineScript func(ciPipelineScript *CiPipelineScript, tx *pg.Tx) error

+ SaveExternalCi func(pipeline *ExternalCiPipeline, tx *pg.Tx) (*ExternalCiPipeline, error)

+ Update func(pipeline *CiPipeline, tx *pg.Tx) error

+ UpdateCiPipelineScript func(script *CiPipelineScript, tx *pg.Tx) error

+ UpdateExternalCi func(pipeline *ExternalCiPipeline, tx *pg.Tx) (*ExternalCiPipeline, int, error)

+ type CiPipelineRepositoryImpl struct

+ func NewCiPipelineRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *CiPipelineRepositoryImpl

+ func (impl *CiPipelineRepositoryImpl) FinDByParentCiPipelineAndAppId(parentCiPipeline int, appIds []int) ([]*CiPipeline, error)

+ func (impl CiPipelineRepositoryImpl) FetchCiPipelinesForDG(parentId int, childCiPipelineIds []int) (*CiPipeline, int, error)

+ func (impl CiPipelineRepositoryImpl) FetchParentCiPipelinesForDG() ([]*CiPipelinesMap, error)

+ func (impl CiPipelineRepositoryImpl) FindByAppId(appId int) (pipelines []*CiPipeline, err error)

+ func (impl CiPipelineRepositoryImpl) FindByCiAndAppDetailsById(pipelineId int) (pipeline *CiPipeline, err error)

+ func (impl CiPipelineRepositoryImpl) FindById(id int) (pipeline *CiPipeline, err error)

+ func (impl CiPipelineRepositoryImpl) FindByIdsIn(ids []int) ([]*CiPipeline, error)

+ func (impl CiPipelineRepositoryImpl) FindByName(pipelineName string) (pipeline *CiPipeline, err error)

+ func (impl CiPipelineRepositoryImpl) FindByParentCiPipelineId(parentCiPipelineId int) ([]*CiPipeline, error)

+ func (impl CiPipelineRepositoryImpl) FindCiScriptsByCiPipelineId(ciPipelineId int) ([]*CiPipelineScript, error)

+ func (impl CiPipelineRepositoryImpl) FindExternalCiByCiPipelineId(ciPipelineId int) (*ExternalCiPipeline, error)

+ func (impl CiPipelineRepositoryImpl) PipelineExistsByName(names []string) (found []string, err error)

+ func (impl CiPipelineRepositoryImpl) Save(pipeline *CiPipeline, tx *pg.Tx) error

+ func (impl CiPipelineRepositoryImpl) SaveCiPipelineScript(ciPipelineScript *CiPipelineScript, tx *pg.Tx) error

+ func (impl CiPipelineRepositoryImpl) SaveExternalCi(pipeline *ExternalCiPipeline, tx *pg.Tx) (*ExternalCiPipeline, error)

+ func (impl CiPipelineRepositoryImpl) Update(pipeline *CiPipeline, tx *pg.Tx) error

+ func (impl CiPipelineRepositoryImpl) UpdateCiPipelineScript(script *CiPipelineScript, tx *pg.Tx) error

+ func (impl CiPipelineRepositoryImpl) UpdateExternalCi(pipeline *ExternalCiPipeline, tx *pg.Tx) (*ExternalCiPipeline, int, error)

+ type CiPipelineScript struct

+ Active bool

+ CiPipelineId int

+ Id int

+ Index int

+ Name string

+ OutputLocation string

+ Script string

+ Stage string

+ type CiPipelinesMap struct

+ Id int

+ ParentCiPipeline int

+ type CiTemplate struct

+ Active bool

+ AfterDockerBuild string

+ App *App

+ AppId int

+ Args string

+ BeforeDockerBuild string

+ DockerRegistry *repository.DockerArtifactStore

+ DockerRegistryId string

+ DockerRepository string

+ DockerfilePath string

+ GitMaterial *GitMaterial

+ GitMaterialId int

+ Id int

+ TemplateName string

+ Version string

+ type CiTemplateRepository interface

+ FindByAppId func(appId int) (ciTemplate *CiTemplate, err error)

+ Save func(material *CiTemplate) error

+ Update func(material *CiTemplate) error

+ type CiTemplateRepositoryImpl struct

+ func NewCiTemplateRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *CiTemplateRepositoryImpl

+ func (impl CiTemplateRepositoryImpl) FindByAppId(appId int) (ciTemplate *CiTemplate, err error)

+ func (impl CiTemplateRepositoryImpl) Save(material *CiTemplate) error

+ func (impl CiTemplateRepositoryImpl) Update(material *CiTemplate) error

+ type CiWorkflow struct

+ CiArtifactLocation string

+ CiPipeline *CiPipeline

+ CiPipelineId int

+ FinishedOn time.Time

+ GitTriggers map[int]GitCommit

+ Id int

+ LogLocation string

+ Message string

+ Name string

+ Namespace string

+ PodStatus string

+ StartedOn time.Time

+ Status string

+ TriggeredBy int32

+ type CiWorkflowConfig struct

+ CiArtifactLocationFormat string

+ CiCacheBucket string

+ CiCacheRegion string

+ CiImage string

+ CiPipelineId int

+ CiTimeout int64

+ Id int

+ LogsBucket string

+ MaxCpu string

+ MaxEphStorage string

+ MaxMem string

+ MaxStorage string

+ MinCpu string

+ MinEphStorage string

+ MinMem string

+ MinStorage string

+ Namespace string

+ type CiWorkflowRepository interface

+ FindById func(id int) (*CiWorkflow, error)

+ FindByName func(name string) (*CiWorkflow, error)

+ FindByPipelineId func(pipelineId int, offset int, size int) ([]WorkflowWithArtifact, error)

+ FindByStatusesIn func(activeStatuses []string) ([]*CiWorkflow, error)

+ FindConfigByPipelineId func(pipelineId int) (*CiWorkflowConfig, error)

+ FindLastTriggeredWorkflow func(pipelineId int) (*CiWorkflow, error)

+ FindLastTriggeredWorkflowByArtifactId func(ciArtifactId int) (ciWorkflow *CiWorkflow, err error)

+ FindLastTriggeredWorkflowByCiIds func(pipelineId []int) (ciWorkflow []*CiWorkflow, err error)

+ SaveWorkFlow func(wf *CiWorkflow) error

+ SaveWorkFlowConfig func(config *CiWorkflowConfig) error

+ UpdateWorkFlow func(wf *CiWorkflow) error

+ type CiWorkflowRepositoryImpl struct

+ func NewCiWorkflowRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *CiWorkflowRepositoryImpl

+ func (impl *CiWorkflowRepositoryImpl) FindById(id int) (*CiWorkflow, error)

+ func (impl *CiWorkflowRepositoryImpl) FindByName(name string) (*CiWorkflow, error)

+ func (impl *CiWorkflowRepositoryImpl) FindByPipelineId(pipelineId int, offset int, limit int) ([]WorkflowWithArtifact, error)

+ func (impl *CiWorkflowRepositoryImpl) FindByStatusesIn(activeStatuses []string) ([]*CiWorkflow, error)

+ func (impl *CiWorkflowRepositoryImpl) FindConfigByPipelineId(pipelineId int) (*CiWorkflowConfig, error)

+ func (impl *CiWorkflowRepositoryImpl) FindLastTriggeredWorkflow(pipelineId int) (ciWorkflow *CiWorkflow, err error)

+ func (impl *CiWorkflowRepositoryImpl) FindLastTriggeredWorkflowByArtifactId(ciArtifactId int) (ciWorkflow *CiWorkflow, err error)

+ func (impl *CiWorkflowRepositoryImpl) FindLastTriggeredWorkflowByCiIds(pipelineId []int) (ciWorkflow []*CiWorkflow, err error)

+ func (impl *CiWorkflowRepositoryImpl) SaveWorkFlow(wf *CiWorkflow) error

+ func (impl *CiWorkflowRepositoryImpl) SaveWorkFlowConfig(config *CiWorkflowConfig) error

+ func (impl *CiWorkflowRepositoryImpl) UpdateWorkFlow(wf *CiWorkflow) error

+ type CiWorkflowStatus struct

+ CiPipelineId int

+ CiPipelineName string

+ CiStatus string

+ type ConnectedPipelinesMap struct

+ Count int

+ Id int

+ type DbMigrationConfig struct

+ Active bool

+ DbConfig *repository.DbConfig

+ DbConfigId int

+ GitMaterial *GitMaterial

+ GitMaterialId int

+ Id int

+ MigrationTool MigrationTool

+ PipelineId int

+ ScriptSource string

+ type DbMigrationConfigRepository interface

+ FindByPipelineId func(pipelineId int) (config *DbMigrationConfig, err error)

+ Save func(config *DbMigrationConfig) error

+ Update func(config *DbMigrationConfig) error

+ type DbMigrationConfigRepositoryImpl struct

+ func NewDbMigrationConfigRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *DbMigrationConfigRepositoryImpl

+ func (impl DbMigrationConfigRepositoryImpl) FindByPipelineId(pipelineId int) (config *DbMigrationConfig, err error)

+ func (impl DbMigrationConfigRepositoryImpl) Save(config *DbMigrationConfig) error

+ func (impl DbMigrationConfigRepositoryImpl) Update(config *DbMigrationConfig) error

+ type DeploymentTemplate string

+ const DEPLOYMENT_TEMPLATE_BLUE_GREEN

+ const DEPLOYMENT_TEMPLATE_CANARY

+ const DEPLOYMENT_TEMPLATE_RECREATE

+ const DEPLOYMENT_TEMPLATE_ROLLING

+ type ExternalCiPipeline struct

+ AccessToken string

+ Active bool

+ CiPipeline *CiPipeline

+ CiPipelineId int

+ Id int

+ type GitCommit struct

+ Author string

+ Changes []string

+ Commit string

+ Date time.Time

+ Message string

+ type GitMaterial struct

+ Active bool

+ App *App

+ AppId int

+ CheckoutPath string

+ GitProvider *repository.GitProvider

+ GitProviderId int

+ Id int

+ Name string

+ Url string

+ type MaterialRepository interface

+ FindByAppId func(appId int) ([]*GitMaterial, error)

+ FindById func(Id int) (*GitMaterial, error)

+ MaterialExists func(url string) (bool, error)

+ SaveMaterial func(material *GitMaterial) error

+ Update func(materials []*GitMaterial) error

+ UpdateMaterial func(material *GitMaterial) error

+ UpdateMaterialScmId func(material *GitMaterial) error

+ type MaterialRepositoryImpl struct

+ func NewMaterialRepositoryImpl(dbConnection *pg.DB) *MaterialRepositoryImpl

+ func (impl MaterialRepositoryImpl) Update(materials []*GitMaterial) error

+ func (repo MaterialRepositoryImpl) FindByAppId(appId int) ([]*GitMaterial, error)

+ func (repo MaterialRepositoryImpl) FindById(Id int) (*GitMaterial, error)

+ func (repo MaterialRepositoryImpl) MaterialExists(url string) (bool, error)

+ func (repo MaterialRepositoryImpl) SaveMaterial(material *GitMaterial) error

+ func (repo MaterialRepositoryImpl) UpdateMaterial(material *GitMaterial) error

+ func (repo MaterialRepositoryImpl) UpdateMaterialScmId(material *GitMaterial) error

+ type MigrationTool string

+ const MIGRATION_TOOL_MIGRATE

+ func (t MigrationTool) IsValid() bool

+ type Pipeline struct

+ App App

+ AppId int

+ CiPipelineId int

+ Deleted bool

+ Environment cluster.Environment

+ EnvironmentId int

+ Id int

+ Name string

+ PostStageConfig string

+ PostStageConfigMapSecretNames string

+ PostTriggerType TriggerType

+ PreStageConfig string

+ PreStageConfigMapSecretNames string

+ PreTriggerType TriggerType

+ RunPostStageInEnv bool

+ RunPreStageInEnv bool

+ TriggerType TriggerType

+ type PipelineRepository interface

+ Delete func(id int, tx *pg.Tx) error

+ FindActiveByAppId func(appId int) (pipelines []*Pipeline, err error)

+ FindActiveByAppIdAndEnvironmentId func(appId int, environmentId int) (pipelines []*Pipeline, err error)

+ FindActiveByAppIdAndEnvironmentIdV2 func() (pipelines []*Pipeline, err error)

+ FindAutomaticByCiPipelineId func(ciPipelineId int) (pipelines []*Pipeline, err error)

+ FindByCiPipelineId func(ciPipelineId int) (pipelines []*Pipeline, err error)

+ FindByCiPipelineIdsIn func(ciPipelineIds []int) ([]*Pipeline, error)

+ FindById func(id int) (pipeline *Pipeline, err error)

+ FindByIdsIn func(ids []int) ([]*Pipeline, error)

+ FindByIdsInAndEnvironment func(ids []int, environmentId int) ([]*Pipeline, error)

+ FindByName func(pipelineName string) (pipeline *Pipeline, err error)

+ FindByPipelineTriggerGitHash func(gitHash string) (pipeline *Pipeline, err error)

+ GetByEnvOverrideId func(envOverrideId int) ([]Pipeline, error)

+ GetConnection func() *pg.DB

+ PipelineExists func(pipelineName string) (bool, error)

+ Save func(pipeline []*Pipeline, tx *pg.Tx) error

+ UndoDelete func(id int) error

+ UniqueAppEnvironmentPipelines func() ([]*Pipeline, error)

+ Update func(pipeline *Pipeline, tx *pg.Tx) error

+ type PipelineRepositoryImpl struct

+ func NewPipelineRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *PipelineRepositoryImpl

+ func (impl PipelineRepositoryImpl) Delete(id int, tx *pg.Tx) error

+ func (impl PipelineRepositoryImpl) FindActiveByAppId(appId int) (pipelines []*Pipeline, err error)

+ func (impl PipelineRepositoryImpl) FindActiveByAppIdAndEnvironmentId(appId int, environmentId int) (pipelines []*Pipeline, err error)

+ func (impl PipelineRepositoryImpl) FindActiveByAppIdAndEnvironmentIdV2() (pipelines []*Pipeline, err error)

+ func (impl PipelineRepositoryImpl) FindAutomaticByCiPipelineId(ciPipelineId int) (pipelines []*Pipeline, err error)

+ func (impl PipelineRepositoryImpl) FindByCiPipelineId(ciPipelineId int) (pipelines []*Pipeline, err error)

+ func (impl PipelineRepositoryImpl) FindByCiPipelineIdsIn(ciPipelineIds []int) ([]*Pipeline, error)

+ func (impl PipelineRepositoryImpl) FindByEnvOverrideId(envOverrideId int) (pipeline []Pipeline, err error)

+ func (impl PipelineRepositoryImpl) FindById(id int) (pipeline *Pipeline, err error)

+ func (impl PipelineRepositoryImpl) FindByIdsIn(ids []int) ([]*Pipeline, error)

+ func (impl PipelineRepositoryImpl) FindByIdsInAndEnvironment(ids []int, environmentId int) ([]*Pipeline, error)

+ func (impl PipelineRepositoryImpl) FindByName(pipelineName string) (pipeline *Pipeline, err error)

+ func (impl PipelineRepositoryImpl) FindByPipelineTriggerGitHash(gitHash string) (pipeline *Pipeline, err error)

+ func (impl PipelineRepositoryImpl) GetByEnvOverrideId(envOverrideId int) ([]Pipeline, error)

+ func (impl PipelineRepositoryImpl) GetConnection() *pg.DB

+ func (impl PipelineRepositoryImpl) PipelineExists(pipelineName string) (bool, error)

+ func (impl PipelineRepositoryImpl) Save(pipeline []*Pipeline, tx *pg.Tx) error

+ func (impl PipelineRepositoryImpl) UndoDelete(id int) error

+ func (impl PipelineRepositoryImpl) UniqueAppEnvironmentPipelines() ([]*Pipeline, error)

+ func (impl PipelineRepositoryImpl) Update(pipeline *Pipeline, tx *pg.Tx) error

+ type PipelineType string

+ type SourceType string

+ const SOURCE_TYPE_BRANCH_FIXED

+ const SOURCE_TYPE_BRANCH_REGEX

+ const SOURCE_TYPE_TAG_ANY

+ const SOURCE_TYPE_TAG_REGEX

+ type TriggerType string

+ const TRIGGER_TYPE_AUTOMATIC

+ const TRIGGER_TYPE_MANUAL

+ type TriggerWorkflowStatus struct

+ CdWorkflowStatus []*CdWorkflowStatus

+ CiWorkflowStatus []*CiWorkflowStatus

+ type WorkflowExecutorType string

+ type WorkflowStatus int

+ const DEQUE_ERROR

+ const DROPPED_STALE

+ const ENQUEUED

+ const QUE_ERROR

+ const REQUEST_ACCEPTED

+ const TRIGGER_ERROR

+ const WF_STARTED

+ const WF_UNKNOWN

+ func (a WorkflowStatus) String() string

+ type WorkflowWithArtifact struct

+ CiArtifactId int

+ CiArtifactLocation string

+ CiPipelineId int

+ EmailId string

+ FinishedOn time.Time

+ GitTriggers map[int]GitCommit

+ Id int

+ Image string

+ LogFilePath string

+ Message string

+ Name string

+ Namespace string

+ PodStatus string

+ StartedOn time.Time

+ Status string

+ TriggeredBy int32