pipelineConfig

package

Go to main page

Versions in this module

v0

v0.2.21

Aug 13, 2021

v0.2.20

Aug 10, 2021

Changes in this version

type AppRepository

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

type AppRepositoryImpl

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

v0.2.19

Jul 28, 2021

v0.2.18

Jul 20, 2021

v0.2.17

Jul 16, 2021

v0.2.16

Jul 9, 2021

v0.2.15

Jul 2, 2021

v0.2.14

Jun 28, 2021

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)

v0.2.13

Jun 22, 2021

v0.2.12

Jun 1, 2021

v0.2.11

May 24, 2021

v0.2.10

May 23, 2021

v0.2.9

May 5, 2021

v0.2.8

Apr 23, 2021

v0.2.7

Apr 12, 2021

v0.2.6

Apr 7, 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

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

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

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

+ FindActiveListByName func(appName string) ([]*App, 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) CheckAppExists(appNames []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) FindActiveListByName(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

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