pipelineConfig

package

Go to main page

Versions in this module

v0

v0.2.19

Jul 28, 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

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