Versions in this module Expand all Collapse all v1 v1.2.9 Apr 12, 2021 v1.2.8 Apr 12, 2021 v0 v0.2.8 Mar 30, 2021 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
Go to main page