Versions in this module Expand all Collapse all v0 v0.2.20 Aug 10, 2021 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 v0.2.13 Jun 22, 2021 v0.2.11 May 24, 2021 v0.2.10 May 23, 2021 v0.2.8 Apr 23, 2021 v0.2.7 Apr 12, 2021 v0.2.6 Apr 7, 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
Go to main page