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 + type Chart struct + Active bool + AppId int + ChartLocation string + ChartName string + ChartRefId int + ChartRepo string + ChartRepoId int + ChartRepoUrl string + ChartVersion string + GitRepoUrl string + GlobalOverride string + Id int + ImageDescriptorTemplate string + Latest bool + PipelineOverride string + Previous bool + ReferenceTemplate string + ReleaseOverride string + Status models.ChartStatus + Values string + type ChartRef struct + Active bool + Default bool + Id int + Location string + Version string + type ChartRefRepository interface + FindById func(id int) (*ChartRef, error) + GetAll func() ([]*ChartRef, error) + GetDefault func() (*ChartRef, error) + Save func(chartRepo *ChartRef) error + type ChartRefRepositoryImpl struct + func NewChartRefRepositoryImpl(dbConnection *pg.DB) *ChartRefRepositoryImpl + func (impl ChartRefRepositoryImpl) FindById(id int) (*ChartRef, error) + func (impl ChartRefRepositoryImpl) GetAll() ([]*ChartRef, error) + func (impl ChartRefRepositoryImpl) GetDefault() (*ChartRef, error) + func (impl ChartRefRepositoryImpl) Save(chartRepo *ChartRef) error + type ChartRepo struct + AccessToken string + Active bool + AuthMode repository.AuthMode + Default bool + External bool + Id int + Name string + Password string + SshKey string + Url string + UserName string + type ChartRepoRepository interface + FindAll func() ([]*ChartRepo, error) + FindById func(id int) (*ChartRepo, error) + GetConnection func() *pg.DB + GetDefault func() (*ChartRepo, error) + Save func(chartRepo *ChartRepo, tx *pg.Tx) error + Update func(chartRepo *ChartRepo, tx *pg.Tx) error + type ChartRepoRepositoryImpl struct + func NewChartRepoRepositoryImpl(dbConnection *pg.DB) *ChartRepoRepositoryImpl + func (impl ChartRepoRepositoryImpl) FindAll() ([]*ChartRepo, error) + func (impl ChartRepoRepositoryImpl) FindById(id int) (*ChartRepo, error) + func (impl ChartRepoRepositoryImpl) GetConnection() *pg.DB + func (impl ChartRepoRepositoryImpl) GetDefault() (*ChartRepo, error) + func (impl ChartRepoRepositoryImpl) Save(chartRepo *ChartRepo, tx *pg.Tx) error + func (impl ChartRepoRepositoryImpl) Update(chartRepo *ChartRepo, tx *pg.Tx) error + type ChartRepository interface + FindActiveChart func(appId int) (chart *Chart, err error) + FindActiveChartsByAppId func(appId int) (charts []*Chart, err error) + FindById func(id int) (chart *Chart, err error) + FindChartByAppIdAndRefId func(appId int, chartRefId int) (chart *Chart, err error) + FindCurrentChartVersion func(chartRepo, chartName, chartVersionPattern string) (string, error) + FindLatestByAppId func(appId int) (chart *Chart, err error) + FindLatestChartForAppByAppId func(appId int) (chart *Chart, err error) + FindNoLatestChartForAppByAppId func(appId int) ([]*Chart, error) + FindOne func(chartRepo, appName, chartVersion string) (*Chart, error) + FindPreviousChartByAppId func(appId int) (chart *Chart, err error) + Save func(*Chart) error + Update func(chart *Chart) error + type ChartRepositoryImpl struct + func NewChartRepository(dbConnection *pg.DB) *ChartRepositoryImpl + func (repositoryImpl ChartRepositoryImpl) FindActiveChart(appId int) (chart *Chart, err error) + func (repositoryImpl ChartRepositoryImpl) FindActiveChartsByAppId(appId int) (charts []*Chart, err error) + func (repositoryImpl ChartRepositoryImpl) FindById(id int) (chart *Chart, err error) + func (repositoryImpl ChartRepositoryImpl) FindChartByAppIdAndRefId(appId int, chartRefId int) (chart *Chart, err error) + func (repositoryImpl ChartRepositoryImpl) FindCurrentChartVersion(chartRepo, chartName, chartVersionPattern string) (string, error) + func (repositoryImpl ChartRepositoryImpl) FindLatestByAppId(appId int) (chart *Chart, err error) + func (repositoryImpl ChartRepositoryImpl) FindLatestChartForAppByAppId(appId int) (chart *Chart, err error) + func (repositoryImpl ChartRepositoryImpl) FindLatestChartForAppByAppIdAndEnvId(appId int, envId int) (chart *Chart, err error) + func (repositoryImpl ChartRepositoryImpl) FindNoLatestChartForAppByAppId(appId int) ([]*Chart, error) + func (repositoryImpl ChartRepositoryImpl) FindOne(chartRepo, chartName, chartVersion string) (*Chart, error) + func (repositoryImpl ChartRepositoryImpl) FindPreviousChartByAppId(appId int) (chart *Chart, err error) + func (repositoryImpl ChartRepositoryImpl) Save(chart *Chart) error + func (repositoryImpl ChartRepositoryImpl) Update(chart *Chart) error + type ConfigMapAppModel struct + AppId int + ConfigMapData string + Id int + SecretData string + TableName struct{} + type ConfigMapEnvModel struct + AppId int + ConfigMapData string + EnvironmentId int + Id int + SecretData string + TableName struct{} + type ConfigMapRepository interface + CreateAppLevel func(model *ConfigMapAppModel) (*ConfigMapAppModel, error) + CreateEnvLevel func(model *ConfigMapEnvModel) (*ConfigMapEnvModel, error) + GetAllAppLevel func() ([]ConfigMapAppModel, error) + GetAllEnvLevel func() ([]ConfigMapEnvModel, error) + GetByAppIdAndEnvIdEnvLevel func(appId int, envId int) (*ConfigMapEnvModel, error) + GetByAppIdAppLevel func(appId int) (*ConfigMapAppModel, error) + GetByIdAppLevel func(id int) (*ConfigMapAppModel, error) + GetByIdEnvLevel func(id int) (*ConfigMapEnvModel, error) + UpdateAppLevel func(model *ConfigMapAppModel) (*ConfigMapAppModel, error) + UpdateEnvLevel func(model *ConfigMapEnvModel) (*ConfigMapEnvModel, error) + type ConfigMapRepositoryImpl struct + Logger *zap.SugaredLogger + func NewConfigMapRepositoryImpl(Logger *zap.SugaredLogger, dbConnection *pg.DB) *ConfigMapRepositoryImpl + func (impl ConfigMapRepositoryImpl) CreateAppLevel(model *ConfigMapAppModel) (*ConfigMapAppModel, error) + func (impl ConfigMapRepositoryImpl) CreateEnvLevel(model *ConfigMapEnvModel) (*ConfigMapEnvModel, error) + func (impl ConfigMapRepositoryImpl) GetAllAppLevel() ([]ConfigMapAppModel, error) + func (impl ConfigMapRepositoryImpl) GetAllEnvLevel() ([]ConfigMapEnvModel, error) + func (impl ConfigMapRepositoryImpl) GetByAppIdAndEnvIdEnvLevel(appId int, envId int) (*ConfigMapEnvModel, error) + func (impl ConfigMapRepositoryImpl) GetByAppIdAppLevel(appId int) (*ConfigMapAppModel, error) + func (impl ConfigMapRepositoryImpl) GetByIdAppLevel(id int) (*ConfigMapAppModel, error) + func (impl ConfigMapRepositoryImpl) GetByIdEnvLevel(id int) (*ConfigMapEnvModel, error) + func (impl ConfigMapRepositoryImpl) UpdateAppLevel(model *ConfigMapAppModel) (*ConfigMapAppModel, error) + func (impl ConfigMapRepositoryImpl) UpdateEnvLevel(model *ConfigMapEnvModel) (*ConfigMapEnvModel, error) + type EnvConfigOverride struct + Active bool + Chart *Chart + ChartId int + EnvOverrideValues string + Environment *cluster.Environment + Id int + IsOverride bool + Latest bool + ManualReviewed bool + Namespace string + Previous bool + Status models.ChartStatus + TargetEnvironment int + type EnvConfigOverrideRepository interface + ActiveEnvConfigOverride func(appId, environmentId int) (*EnvConfigOverride, error) + Delete func(envConfigOverride *EnvConfigOverride) error + FindChartByAppIdAndEnvIdAndChartRefId func(appId, targetEnvironmentId int, chartRefId int) (*EnvConfigOverride, error) + FindChartForAppByAppIdAndEnvId func(appId, targetEnvironmentId int) (*EnvConfigOverride, error) + FindLatestChartForAppByAppIdAndEnvId func(appId, targetEnvironmentId int) (*EnvConfigOverride, error) + Get func(id int) (*EnvConfigOverride, error) + GetByChartAndEnvironment func(chartId, targetEnvironmentId int) (*EnvConfigOverride, error) + GetByEnvironment func(targetEnvironmentId int) ([]EnvConfigOverride, error) + GetEnvConfigByChartId func(chartId int) ([]EnvConfigOverride, error) + Save func(*EnvConfigOverride) error + Update func(envConfigOverride *EnvConfigOverride) (*EnvConfigOverride, error) + UpdateEnvConfigStatus func(config *EnvConfigOverride) error + UpdateProperties func(config *EnvConfigOverride) error + type EnvConfigOverrideRepositoryImpl struct + func NewEnvConfigOverrideRepository(dbConnection *pg.DB) *EnvConfigOverrideRepositoryImpl + func (r EnvConfigOverrideRepositoryImpl) ActiveEnvConfigOverride(appId, environmentId int) (*EnvConfigOverride, error) + func (r EnvConfigOverrideRepositoryImpl) Delete(envConfigOverride *EnvConfigOverride) error + func (r EnvConfigOverrideRepositoryImpl) FindChartByAppIdAndEnvIdAndChartRefId(appId, targetEnvironmentId int, chartRefId int) (*EnvConfigOverride, error) + func (r EnvConfigOverrideRepositoryImpl) FindChartForAppByAppIdAndEnvId(appId, targetEnvironmentId int) (*EnvConfigOverride, error) + func (r EnvConfigOverrideRepositoryImpl) FindLatestChartForAppByAppIdAndEnvId(appId, targetEnvironmentId int) (*EnvConfigOverride, error) + func (r EnvConfigOverrideRepositoryImpl) Get(id int) (*EnvConfigOverride, error) + func (r EnvConfigOverrideRepositoryImpl) GetByChartAndEnvironment(chartId, targetEnvironmentId int) (*EnvConfigOverride, error) + func (r EnvConfigOverrideRepositoryImpl) GetByEnvironment(targetEnvironmentId int) ([]EnvConfigOverride, error) + func (r EnvConfigOverrideRepositoryImpl) GetEnvConfigByChartId(chartId int) ([]EnvConfigOverride, error) + func (r EnvConfigOverrideRepositoryImpl) Save(override *EnvConfigOverride) error + func (r EnvConfigOverrideRepositoryImpl) Update(envConfigOverride *EnvConfigOverride) (*EnvConfigOverride, error) + func (r EnvConfigOverrideRepositoryImpl) UpdateEnvConfigStatus(config *EnvConfigOverride) error + func (r EnvConfigOverrideRepositoryImpl) UpdateProperties(config *EnvConfigOverride) error + type PipelineConfigRepository interface + Delete func(pipelineStrategy *PipelineStrategy, tx *pg.Tx) error + FindById func(id int) (chart *PipelineStrategy, err error) + FindByStrategy func(strategy pipelineConfig.DeploymentTemplate) (pipelineStrategy *PipelineStrategy, err error) + FindByStrategyAndPipelineId func(strategy pipelineConfig.DeploymentTemplate, pipelineId int) (pipelineStrategy *PipelineStrategy, err error) + GetAllStrategyByPipelineId func(pipelineId int) ([]*PipelineStrategy, error) + GetDefaultStrategyByPipelineId func(pipelineId int) (pipelineStrategy *PipelineStrategy, err error) + Save func(pipelineStrategy *PipelineStrategy, tx *pg.Tx) error + Update func(pipelineStrategy *PipelineStrategy, tx *pg.Tx) error + type PipelineConfigRepositoryImpl struct + func NewPipelineConfigRepository(dbConnection *pg.DB) *PipelineConfigRepositoryImpl + func (impl PipelineConfigRepositoryImpl) Delete(pipelineStrategy *PipelineStrategy, tx *pg.Tx) error + func (impl PipelineConfigRepositoryImpl) FindById(id int) (pipelineStrategy *PipelineStrategy, err error) + func (impl PipelineConfigRepositoryImpl) FindByStrategy(strategy pipelineConfig.DeploymentTemplate) (pipelineStrategy *PipelineStrategy, err error) + func (impl PipelineConfigRepositoryImpl) FindByStrategyAndPipelineId(strategy pipelineConfig.DeploymentTemplate, pipelineId int) (pipelineStrategy *PipelineStrategy, err error) + func (impl PipelineConfigRepositoryImpl) GetAllStrategyByPipelineId(pipelineId int) ([]*PipelineStrategy, error) + func (impl PipelineConfigRepositoryImpl) GetDefaultStrategyByPipelineId(pipelineId int) (pipelineStrategy *PipelineStrategy, err error) + func (impl PipelineConfigRepositoryImpl) Save(pipelineStrategy *PipelineStrategy, tx *pg.Tx) error + func (impl PipelineConfigRepositoryImpl) Update(pipelineStrategy *PipelineStrategy, tx *pg.Tx) error + type PipelineOverride struct + CdWorkflowId int + CiArtifact *repository.CiArtifact + CiArtifactId int + DeploymentType models.DeploymentType + EnvConfigOverride *EnvConfigOverride + EnvConfigOverrideId int + GitHash string + Id int + Pipeline *pipelineConfig.Pipeline + PipelineId int + PipelineMergedValues string + PipelineOverrideValues string + PipelineReleaseCounter int + RequestIdentifier string + Status models.ChartStatus + type PipelineOverrideRepository interface + FindById func(id int) (*PipelineOverride, error) + FindByPipelineTriggerGitHash func(gitHash string) (pipelineOverride *PipelineOverride, err error) + GetAllRelease func(appId, environmentId int) (pipelineOverrides []*PipelineOverride, err error) + GetByDeployedImage func(appId, environmentId int, images []string) (pipelineOverride *PipelineOverride, err error) + GetByPipelineIdAndReleaseNo func(pipelineId, releaseNo int) (pipelineOverrides []*PipelineOverride, err error) + GetCurrentPipelineReleaseCounter func(pipelineId int) (releaseCounter int, err error) + GetLatestConfigByEnvironmentConfigOverrideId func(envConfigOverrideId int) (pipelineOverride *PipelineOverride, err error) + GetLatestConfigByRequestIdentifier func(requestIdentifier string) (pipelineOverride *PipelineOverride, err error) + GetLatestRelease func(appId, environmentId int) (pipelineOverrides *PipelineOverride, err error) + GetLatestReleaseByPipelineIds func(pipelineIds []int) (pipelineOverrides []*PipelineOverride, err error) + GetLatestReleaseDeploymentType func(pipelineIds []int) ([]*PipelineOverride, error) + Save func(*PipelineOverride) error + Update func(pipelineOverride *PipelineOverride) error + UpdateStatusByRequestIdentifier func(requestId string, newStatus models.ChartStatus) (int, error) + type PipelineOverrideRepositoryImpl struct + func NewPipelineOverrideRepository(dbConnection *pg.DB) *PipelineOverrideRepositoryImpl + func (impl PipelineOverrideRepositoryImpl) FindById(id int) (*PipelineOverride, error) + func (impl PipelineOverrideRepositoryImpl) FindByPipelineTriggerGitHash(gitHash string) (pipelineOverride *PipelineOverride, err error) + func (impl PipelineOverrideRepositoryImpl) GetAllRelease(appId, environmentId int) (pipelineOverrides []*PipelineOverride, err error) + func (impl PipelineOverrideRepositoryImpl) GetByDeployedImage(appId, environmentId int, images []string) (pipelineOverride *PipelineOverride, err error) + func (impl PipelineOverrideRepositoryImpl) GetByPipelineIdAndReleaseNo(pipelineId, releaseNo int) (pipelineOverrides []*PipelineOverride, err error) + func (impl PipelineOverrideRepositoryImpl) GetCurrentPipelineReleaseCounter(pipelineId int) (releaseCounter int, err error) + func (impl PipelineOverrideRepositoryImpl) GetLatestConfigByEnvironmentConfigOverrideId(envConfigOverrideId int) (pipelineOverride *PipelineOverride, err error) + func (impl PipelineOverrideRepositoryImpl) GetLatestConfigByRequestIdentifier(requestIdentifier string) (pipelineOverride *PipelineOverride, err error) + func (impl PipelineOverrideRepositoryImpl) GetLatestRelease(appId, environmentId int) (pipelineOverrides *PipelineOverride, err error) + func (impl PipelineOverrideRepositoryImpl) GetLatestReleaseByPipelineIds(pipelineIds []int) (pipelineOverrides []*PipelineOverride, err error) + func (impl PipelineOverrideRepositoryImpl) GetLatestReleaseDeploymentType(pipelineIds []int) ([]*PipelineOverride, error) + func (impl PipelineOverrideRepositoryImpl) Save(pipelineOverride *PipelineOverride) error + func (impl PipelineOverrideRepositoryImpl) Update(pipelineOverride *PipelineOverride) error + func (impl PipelineOverrideRepositoryImpl) UpdateStatusByRequestIdentifier(requestId string, newStatus models.ChartStatus) (int, error) + type PipelineStrategy struct + Config string + Default bool + Deleted bool + Id int + PipelineId int + Strategy pipelineConfig.DeploymentTemplate