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 Failure + const NewDeployment + const REGISTRYTYPE_DOCKER_HUB + const REGISTRYTYPE_ECR + const REGISTRYTYPE_OTHER + const Success + type AppLevelMetrics struct + AppId int + AppMetrics bool + Id int + InfraMetrics bool + type AppLevelMetricsRepository interface + FindByAppId func(id int) (*AppLevelMetrics, error) + Save func(metrics *AppLevelMetrics) error + Update func(metrics *AppLevelMetrics) error + type AppLevelMetricsRepositoryImpl struct + func NewAppLevelMetricsRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *AppLevelMetricsRepositoryImpl + func (impl *AppLevelMetricsRepositoryImpl) FindByAppId(appId int) (*AppLevelMetrics, error) + func (impl *AppLevelMetricsRepositoryImpl) Save(metrics *AppLevelMetrics) error + func (impl *AppLevelMetricsRepositoryImpl) Update(metrics *AppLevelMetrics) error + type AppListingRepository interface + DeleteOldDeployments func(appName string) (int, error) + DeploymentDetailByArtifactId func(ciArtifactId int) (bean.DeploymentDetailContainer, error) + DeploymentDetailsByAppIdAndEnvId func(appId int, envId int) (bean.DeploymentDetailContainer, error) + FetchAppDetail func(appId int, envId int) (bean.AppDetailContainer, error) + FetchAppStageStatus func(appId int) ([]bean.AppStageStatus, error) + FetchAppTriggerView func(appId int) ([]bean.TriggerView, error) + FetchAppsByEnvironment func(appListingFilter helper.AppListingFilter) ([]*bean.AppEnvironmentContainer, error) + FetchOtherEnvironment func(appId int) ([]*bean.Environment, error) + FindLastDeployedStatus func(appName string) (DeploymentStatus, error) + FindLastDeployedStatuses func(appNames []string) ([]DeploymentStatus, error) + FindLastDeployedStatusesForAllApps func() ([]DeploymentStatus, error) + GetDeploymentStatusByAppName func(appName string) ([]DeploymentStatus, error) + PrometheusApiByEnvId func(id int) (*string, error) + SaveNewDeployment func(deploymentStatus *DeploymentStatus) error + type AppListingRepositoryImpl struct + Logger *zap.SugaredLogger + func NewAppListingRepositoryImpl(Logger *zap.SugaredLogger, dbConnection *pg.DB, ...) *AppListingRepositoryImpl + func (impl AppListingRepositoryImpl) DeleteOldDeployments(appName string) (int, error) + func (impl AppListingRepositoryImpl) DeploymentDetailByArtifactId(ciArtifactId int) (bean.DeploymentDetailContainer, error) + func (impl AppListingRepositoryImpl) DeploymentDetailsByAppIdAndEnvId(appId int, envId int) (bean.DeploymentDetailContainer, error) + func (impl AppListingRepositoryImpl) FetchAppDetail(appId int, envId int) (bean.AppDetailContainer, error) + func (impl AppListingRepositoryImpl) FetchAppStageStatus(appId int) ([]bean.AppStageStatus, error) + func (impl AppListingRepositoryImpl) FetchAppTriggerView(appId int) ([]bean.TriggerView, error) + func (impl AppListingRepositoryImpl) FetchAppsByEnvironment(appListingFilter helper.AppListingFilter) ([]*bean.AppEnvironmentContainer, error) + func (impl AppListingRepositoryImpl) FetchOtherEnvironment(appId int) ([]*bean.Environment, error) + func (impl AppListingRepositoryImpl) FindLastDeployedStatus(appName string) (DeploymentStatus, error) + func (impl AppListingRepositoryImpl) FindLastDeployedStatuses(appNames []string) ([]DeploymentStatus, error) + func (impl AppListingRepositoryImpl) FindLastDeployedStatusesForAllApps() ([]DeploymentStatus, error) + func (impl AppListingRepositoryImpl) GetDeploymentStatusByAppName(appName string) ([]DeploymentStatus, error) + func (impl AppListingRepositoryImpl) PrometheusApiByEnvId(id int) (*string, error) + func (impl AppListingRepositoryImpl) SaveNewDeployment(deploymentStatus *DeploymentStatus) error + type Attributes struct + Active bool + Id int + Key string + Value string + type AttributesRepository interface + FindActiveList func() ([]*Attributes, error) + FindById func(id int) (*Attributes, error) + FindByKey func(key string) (*Attributes, error) + GetConnection func() (dbConnection *pg.DB) + Save func(model *Attributes, tx *pg.Tx) (*Attributes, error) + Update func(model *Attributes, tx *pg.Tx) error + type AttributesRepositoryImpl struct + func NewAttributesRepositoryImpl(dbConnection *pg.DB) *AttributesRepositoryImpl + func (impl *AttributesRepositoryImpl) GetConnection() (dbConnection *pg.DB) + func (repo AttributesRepositoryImpl) FindActiveList() ([]*Attributes, error) + func (repo AttributesRepositoryImpl) FindById(id int) (*Attributes, error) + func (repo AttributesRepositoryImpl) FindByKey(key string) (*Attributes, error) + func (repo AttributesRepositoryImpl) Save(model *Attributes, tx *pg.Tx) (*Attributes, error) + func (repo AttributesRepositoryImpl) Update(model *Attributes, tx *pg.Tx) error + type AuthMode string + const AUTH_MODE_ACCESS_TOKEN + const AUTH_MODE_ANONYMOUS + const AUTH_MODE_SSH + const AUTH_MODE_USERNAME_PASSWORD + type CiArtifact struct + DataSource string + Deployed bool + DeployedTime time.Time + Id int + Image string + ImageDigest string + Latest bool + MaterialInfo string + ParentCiArtifact int + PipelineId int + ScanEnabled bool + Scanned bool + WorkflowId *int + func (info *CiArtifact) ParseMaterialInfo() (map[string]string, error) + type CiArtifactRepository interface + FetchArtifactForRollback func(cdPipelineId int) ([]CiArtifact, error) + FinDByParentCiArtifactAndCiId func(parentCiArtifact int, ciPipelineIds []int) ([]*CiArtifact, error) + Get func(id int) (artifact *CiArtifact, err error) + GetArtifactsByCDPipeline func(cdPipelineId int) ([]CiArtifact, error) + GetArtifactsByCDPipelineAndRunnerType func(cdPipelineId int, runnerType bean.CdWorkflowType) ([]CiArtifact, error) + GetArtifactsByCDPipelineV2 func(cdPipelineId int) ([]CiArtifact, error) + GetArtifactsByCiPipelineId func(ciPipelineId int) ([]CiArtifact, error) + GetByIds func(ids []int) ([]*CiArtifact, error) + GetByImageDigest func(imageDigest string) (artifact *CiArtifact, err error) + GetByWfId func(wfId int) (artifact *CiArtifact, err error) + GetLatest func(cdPipelineId int) (int, error) + Save func(artifact *CiArtifact) error + SaveAll func(artifacts []*CiArtifact) error + type CiArtifactRepositoryImpl struct + func NewCiArtifactRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *CiArtifactRepositoryImpl + func (impl CiArtifactRepositoryImpl) FetchArtifactForRollback(cdPipelineId int) ([]CiArtifact, error) + func (impl CiArtifactRepositoryImpl) FinDByParentCiArtifactAndCiId(parentCiArtifact int, ciPipelineIds []int) ([]*CiArtifact, error) + func (impl CiArtifactRepositoryImpl) Get(id int) (artifact *CiArtifact, err error) + func (impl CiArtifactRepositoryImpl) GetArtifactsByCDPipeline(cdPipelineId int) ([]CiArtifact, error) + func (impl CiArtifactRepositoryImpl) GetArtifactsByCDPipelineAndRunnerType(cdPipelineId int, runnerType bean.CdWorkflowType) ([]CiArtifact, error) + func (impl CiArtifactRepositoryImpl) GetArtifactsByCDPipelineV2(cdPipelineId int) ([]CiArtifact, error) + func (impl CiArtifactRepositoryImpl) GetArtifactsByCiPipelineId(ciPipelineId int) ([]CiArtifact, error) + func (impl CiArtifactRepositoryImpl) GetByIds(ids []int) ([]*CiArtifact, error) + func (impl CiArtifactRepositoryImpl) GetByImageDigest(imageDigest string) (*CiArtifact, error) + func (impl CiArtifactRepositoryImpl) GetByWfId(wfId int) (*CiArtifact, error) + func (impl CiArtifactRepositoryImpl) GetLatest(cdPipelineId int) (int, error) + func (impl CiArtifactRepositoryImpl) Save(artifact *CiArtifact) error + func (impl CiArtifactRepositoryImpl) SaveAll(artifacts []*CiArtifact) error + type CiMaterialInfo struct + Changed bool + Material Material + Modifications []Modification + func GetCiMaterialInfo(materialInfo string, source string) ([]CiMaterialInfo, error) + type DbConfig struct + Active bool + DbName string + Host string + Id int + Name string + Password string + Port string + Type DbType + UserName string + type DbConfigRepository interface + GetActiveForAutocomplete func() (configs []*DbConfig, err error) + GetAll func() (configs []*DbConfig, err error) + GetById func(id int) (*DbConfig, error) + Save func(config *DbConfig) error + Update func(config *DbConfig) (*DbConfig, error) + type DbConfigRepositoryImpl struct + func NewDbConfigRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *DbConfigRepositoryImpl + func (impl DbConfigRepositoryImpl) GetActiveForAutocomplete() (configs []*DbConfig, err error) + func (impl DbConfigRepositoryImpl) GetAll() (configs []*DbConfig, err error) + func (impl DbConfigRepositoryImpl) GetById(id int) (*DbConfig, error) + func (impl DbConfigRepositoryImpl) Save(config *DbConfig) error + func (impl DbConfigRepositoryImpl) Update(config *DbConfig) (*DbConfig, error) + type DbType string + const DB_TYPE_MARIADB + const Db_TYPE_MYSQL + const Db_TYPE_POSTGRESS + func (t DbType) IsValid() bool + type DeploymentGroup struct + Active bool + AppCount int + CiPipelineId int + DeploymentGroupApps []*DeploymentGroupApp + EnvironmentId int + Id int + Name string + NoOfApps string + TableName struct{} + type DeploymentGroupApp struct + Active bool + AppId int + DeploymentGroupId int + Id int + TableName struct{} + type DeploymentGroupAppRepository interface + Create func(model *DeploymentGroupApp) (*DeploymentGroupApp, error) + Delete func(model *DeploymentGroupApp) error + GetAll func() ([]*DeploymentGroupApp, error) + GetByDeploymentGroup func(deploymentGroupId int) ([]*DeploymentGroupApp, error) + GetById func(id int) (*DeploymentGroupApp, error) + Update func(model *DeploymentGroupApp) (*DeploymentGroupApp, error) + type DeploymentGroupAppRepositoryImpl struct + Logger *zap.SugaredLogger + func NewDeploymentGroupAppRepositoryImpl(Logger *zap.SugaredLogger, dbConnection *pg.DB) *DeploymentGroupAppRepositoryImpl + func (impl DeploymentGroupAppRepositoryImpl) Create(model *DeploymentGroupApp) (*DeploymentGroupApp, error) + func (impl DeploymentGroupAppRepositoryImpl) Delete(model *DeploymentGroupApp) error + func (impl DeploymentGroupAppRepositoryImpl) GetAll() ([]*DeploymentGroupApp, error) + func (impl DeploymentGroupAppRepositoryImpl) GetByDeploymentGroup(deploymentGroupId int) ([]*DeploymentGroupApp, error) + func (impl DeploymentGroupAppRepositoryImpl) GetById(id int) (*DeploymentGroupApp, error) + func (impl DeploymentGroupAppRepositoryImpl) Update(model *DeploymentGroupApp) (*DeploymentGroupApp, error) + type DeploymentGroupRepository interface + Create func(model *DeploymentGroup) (*DeploymentGroup, error) + Delete func(model *DeploymentGroup) error + FindByIdWithApp func(id int) (*DeploymentGroup, error) + GetAll func() ([]DeploymentGroup, error) + GetById func(id int) (*DeploymentGroup, error) + Update func(model *DeploymentGroup) (*DeploymentGroup, error) + type DeploymentGroupRepositoryImpl struct + Logger *zap.SugaredLogger + func NewDeploymentGroupRepositoryImpl(Logger *zap.SugaredLogger, dbConnection *pg.DB) *DeploymentGroupRepositoryImpl + func (impl *DeploymentGroupRepositoryImpl) Create(model *DeploymentGroup) (*DeploymentGroup, error) + func (impl *DeploymentGroupRepositoryImpl) Delete(model *DeploymentGroup) error + func (impl *DeploymentGroupRepositoryImpl) FindByIdWithApp(id int) (*DeploymentGroup, error) + func (impl *DeploymentGroupRepositoryImpl) GetAll() ([]DeploymentGroup, error) + func (impl *DeploymentGroupRepositoryImpl) GetById(id int) (*DeploymentGroup, error) + func (impl *DeploymentGroupRepositoryImpl) Update(model *DeploymentGroup) (*DeploymentGroup, error) + type DeploymentStatus struct + AppId int + AppName string + CreatedOn time.Time + EnvId int + Id int + Status string + UpdatedOn time.Time + type DockerArtifactStore struct + AWSAccessKeyId string + AWSRegion string + AWSSecretAccessKey string + Active bool + Id string + IsDefault bool + Password string + PluginId string + RegistryType RegistryType + RegistryURL string + Username string + func (store *DockerArtifactStore) GetRegistryLocation() (registryLocation string, err error) + type DockerArtifactStoreRepository interface + Delete func(storeId string) error + FindActiveDefaultStore func() (*DockerArtifactStore, error) + FindAll func() ([]DockerArtifactStore, error) + FindAllActiveForAutocomplete func() ([]DockerArtifactStore, error) + FindOne func(storeId string) (*DockerArtifactStore, error) + Save func(artifactStore *DockerArtifactStore) error + Update func(artifactStore *DockerArtifactStore) error + type DockerArtifactStoreRepositoryImpl struct + func NewDockerArtifactStoreRepositoryImpl(dbConnection *pg.DB) *DockerArtifactStoreRepositoryImpl + func (impl DockerArtifactStoreRepositoryImpl) Delete(storeId string) error + func (impl DockerArtifactStoreRepositoryImpl) FindActiveDefaultStore() (*DockerArtifactStore, error) + func (impl DockerArtifactStoreRepositoryImpl) FindAll() ([]DockerArtifactStore, error) + func (impl DockerArtifactStoreRepositoryImpl) FindAllActiveForAutocomplete() ([]DockerArtifactStore, error) + func (impl DockerArtifactStoreRepositoryImpl) FindOne(storeId string) (*DockerArtifactStore, error) + func (impl DockerArtifactStoreRepositoryImpl) Save(artifactStore *DockerArtifactStore) error + func (impl DockerArtifactStoreRepositoryImpl) Update(artifactStore *DockerArtifactStore) error + type EnvLevelAppMetrics struct + AppId int + AppMetrics *bool + EnvId int + Id int + InfraMetrics *bool + type EnvLevelAppMetricsRepository interface + Delete func(metrics *EnvLevelAppMetrics) error + FindByAppId func(appId int) ([]*EnvLevelAppMetrics, error) + FindByAppIdAndEnvId func(appId int, envId int) (*EnvLevelAppMetrics, error) + Save func(metrics *EnvLevelAppMetrics) error + Update func(metrics *EnvLevelAppMetrics) error + type EnvLevelAppMetricsRepositoryImpl struct + func NewEnvLevelAppMetricsRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *EnvLevelAppMetricsRepositoryImpl + func (impl *EnvLevelAppMetricsRepositoryImpl) Delete(metrics *EnvLevelAppMetrics) error + func (impl *EnvLevelAppMetricsRepositoryImpl) FindByAppId(appId int) ([]*EnvLevelAppMetrics, error) + func (impl *EnvLevelAppMetricsRepositoryImpl) FindByAppIdAndEnvId(appId int, envId int) (*EnvLevelAppMetrics, error) + func (impl *EnvLevelAppMetricsRepositoryImpl) Save(metrics *EnvLevelAppMetrics) error + func (impl *EnvLevelAppMetricsRepositoryImpl) Update(metrics *EnvLevelAppMetrics) error + type EventRepository interface + FindLastCompletedEvent func(eventTypeId int) (*JobEvent, error) + Save func(event *JobEvent) error + Update func(event *JobEvent) error + type EventRepositoryImpl struct + func NewEventRepositoryImpl(logger *zap.SugaredLogger, dbConnection *pg.DB) *EventRepositoryImpl + func (impl *EventRepositoryImpl) FindLastCompletedEvent(eventTypeId int) (*JobEvent, error) + func (impl *EventRepositoryImpl) Save(event *JobEvent) error + func (impl *EventRepositoryImpl) Update(event *JobEvent) error + type GitConfiguration struct + URL string + type GitOpsConfig struct + Active bool + GitHubOrgId string + GitLabGroupId string + Host string + Id int + Provider string + Token string + Username string + type GitOpsConfigRepository interface + CreateGitOpsConfig func(model *GitOpsConfig, tx *pg.Tx) (*GitOpsConfig, error) + GetAllGitOpsConfig func() ([]*GitOpsConfig, error) + GetConnection func() *pg.DB + GetGitOpsConfigActive func() (*GitOpsConfig, error) + GetGitOpsConfigById func(id int) (*GitOpsConfig, error) + GetGitOpsConfigByProvider func(provider string) (*GitOpsConfig, error) + UpdateGitOpsConfig func(model *GitOpsConfig, tx *pg.Tx) error + type GitOpsConfigRepositoryImpl struct + func NewGitOpsConfigRepositoryImpl(logger *zap.SugaredLogger, dbConnection *pg.DB) *GitOpsConfigRepositoryImpl + func (impl *GitOpsConfigRepositoryImpl) CreateGitOpsConfig(model *GitOpsConfig, tx *pg.Tx) (*GitOpsConfig, error) + func (impl *GitOpsConfigRepositoryImpl) GetAllGitOpsConfig() ([]*GitOpsConfig, error) + func (impl *GitOpsConfigRepositoryImpl) GetConnection() *pg.DB + func (impl *GitOpsConfigRepositoryImpl) GetGitOpsConfigActive() (*GitOpsConfig, error) + func (impl *GitOpsConfigRepositoryImpl) GetGitOpsConfigById(id int) (*GitOpsConfig, error) + func (impl *GitOpsConfigRepositoryImpl) GetGitOpsConfigByProvider(provider string) (*GitOpsConfig, error) + func (impl *GitOpsConfigRepositoryImpl) UpdateGitOpsConfig(model *GitOpsConfig, tx *pg.Tx) error + type GitProvider struct + AccessToken string + Active bool + AuthMode AuthMode + Id int + Name string + Password string + SshKey string + Url string + UserName string + type GitProviderRepository interface + FindAll func() ([]GitProvider, error) + FindAllActiveForAutocomplete func() ([]GitProvider, error) + FindOne func(providerId string) (GitProvider, error) + ProviderExists func(url string) (bool, error) + Save func(gitProvider *GitProvider) error + Update func(gitProvider *GitProvider) error + type GitProviderRepositoryImpl struct + func NewGitProviderRepositoryImpl(dbConnection *pg.DB) *GitProviderRepositoryImpl + func (impl GitProviderRepositoryImpl) FindAll() ([]GitProvider, error) + func (impl GitProviderRepositoryImpl) FindAllActiveForAutocomplete() ([]GitProvider, error) + func (impl GitProviderRepositoryImpl) FindOne(providerId string) (GitProvider, error) + func (impl GitProviderRepositoryImpl) ProviderExists(url string) (bool, error) + func (impl GitProviderRepositoryImpl) Save(gitProvider *GitProvider) error + func (impl GitProviderRepositoryImpl) Update(gitProvider *GitProvider) error + type GitWebhook struct + Active bool + CiMaterialId int + CreatedOn time.Time + GitMaterialId int + Id int + LastSeenHash string + Type string + Value string + type GitWebhookRepository interface + Save func(gitWebhook *GitWebhook) error + type GitWebhookRepositoryImpl struct + func NewGitWebhookRepositoryImpl(dbConnection *pg.DB) *GitWebhookRepositoryImpl + func (impl *GitWebhookRepositoryImpl) Save(gitWebhook *GitWebhook) error + type JiraAccountDetails struct + AccountURL string + AuthToken string + CommitMessageRegex string + FinalIssueStatus string + Id int32 + PipelineId int32 + PipelineStage string + UserName string + type JiraAccountRepository interface + FindByPipelineIdAndStage func(pipelineId int32, pipelineStage string) (*JiraAccountDetails, error) + Save func(accountDetails *JiraAccountDetails) error + Update func(accountDetails *JiraAccountDetails) error + type JiraAccountRepositoryImpl struct + func NewJiraAccountRepositoryImpl(dbConnection *pg.DB) *JiraAccountRepositoryImpl + func (impl *JiraAccountRepositoryImpl) FindByPipelineIdAndStage(pipelineId int32, pipelineStage string) (*JiraAccountDetails, error) + func (impl *JiraAccountRepositoryImpl) Save(jiraAccountDetails *JiraAccountDetails) error + func (impl *JiraAccountRepositoryImpl) Update(jiraAccountDetails *JiraAccountDetails) error + type JobEvent struct + CreatedOn time.Time + EventName string + EventTriggerTime time.Time + Id int + Message string + Status string + UpdatedOn time.Time + type LinkoutsModel struct + AppId int + Description string + EnvironmentId int + Id int + Link string + Name string + TableName struct{} + type LinkoutsRepository interface + Create func(model *LinkoutsModel) (*LinkoutsModel, error) + FetchLinkoutById func(Id int) (bean.LinkOuts, error) + FetchLinkoutsByAppIdAndEnvId func(appId int, envId int) ([]LinkoutsModel, error) + GetAll func() ([]LinkoutsModel, error) + GetById func(id int) (*LinkoutsModel, error) + Update func(model *LinkoutsModel) (*LinkoutsModel, error) + type LinkoutsRepositoryImpl struct + Logger *zap.SugaredLogger + func NewLinkoutsRepositoryImpl(Logger *zap.SugaredLogger, dbConnection *pg.DB) *LinkoutsRepositoryImpl + func (impl LinkoutsRepositoryImpl) Create(model *LinkoutsModel) (*LinkoutsModel, error) + func (impl LinkoutsRepositoryImpl) FetchLinkoutById(Id int) (bean.LinkOuts, error) + func (impl LinkoutsRepositoryImpl) FetchLinkoutsByAppIdAndEnvId(appId int, envId int) ([]LinkoutsModel, error) + func (impl LinkoutsRepositoryImpl) GetAll() ([]LinkoutsModel, error) + func (impl LinkoutsRepositoryImpl) GetById(id int) (*LinkoutsModel, error) + func (impl LinkoutsRepositoryImpl) Update(model *LinkoutsModel) (*LinkoutsModel, error) + type Material struct + GitConfiguration GitConfiguration + PluginID string + ScmConfiguration ScmConfiguration + Type string + type Modification struct + Author string + Branch string + Data map[string]string + Message string + ModifiedTime string + Revision string + Tag string + type NotificationSettings struct + AppId *int + Config string + EnvId *int + EventTypeId int + Id int + PipelineId *int + PipelineType string + TeamId *int + ViewId int + type NotificationSettingsRepository interface + DeleteNotificationSettingsByConfigId func(viewId int, tx *pg.Tx) (int, error) + DeleteNotificationSettingsViewById func(id int, tx *pg.Tx) (int, error) + FetchNotificationSettingGroupBy func(viewId int) ([]NotificationSettings, error) + FindAll func(offset int, size int) ([]*NotificationSettingsView, error) + FindNSViewCount func() (int, error) + FindNotificationSettingBuildOptions func(settingRequest *SearchRequest) ([]*SettingOptionDTO, error) + FindNotificationSettingDeploymentOptions func(settingRequest *SearchRequest) ([]*SettingOptionDTO, error) + FindNotificationSettingsByViewId func(viewId int) ([]NotificationSettings, error) + FindNotificationSettingsViewById func(id int) (*NotificationSettingsView, error) + FindNotificationSettingsViewByIds func(id []*int) ([]*NotificationSettingsView, error) + SaveAllNotificationSettings func(notificationSettings []NotificationSettings, tx *pg.Tx) (int, error) + SaveNotificationSetting func(notificationSettings *NotificationSettings, tx *pg.Tx) (*NotificationSettings, error) + SaveNotificationSettingsConfig func(notificationSettingsView *NotificationSettingsView, tx *pg.Tx) (*NotificationSettingsView, error) + UpdateNotificationSettings func(notificationSettings *NotificationSettings, tx *pg.Tx) (*NotificationSettings, error) + UpdateNotificationSettingsView func(notificationSettingsView *NotificationSettingsView, tx *pg.Tx) (*NotificationSettingsView, error) + type NotificationSettingsRepositoryImpl struct + func NewNotificationSettingsRepositoryImpl(dbConnection *pg.DB) *NotificationSettingsRepositoryImpl + func (impl *NotificationSettingsRepositoryImpl) DeleteNotificationSettingsByConfigId(viewId int, tx *pg.Tx) (int, error) + func (impl *NotificationSettingsRepositoryImpl) DeleteNotificationSettingsViewById(id int, tx *pg.Tx) (int, error) + func (impl *NotificationSettingsRepositoryImpl) FetchNotificationSettingGroupBy(viewId int) ([]NotificationSettings, error) + func (impl *NotificationSettingsRepositoryImpl) FindAll(offset int, size int) ([]*NotificationSettingsView, error) + func (impl *NotificationSettingsRepositoryImpl) FindNSViewCount() (int, error) + func (impl *NotificationSettingsRepositoryImpl) FindNotificationSettingBuildOptions(settingRequest *SearchRequest) ([]*SettingOptionDTO, error) + func (impl *NotificationSettingsRepositoryImpl) FindNotificationSettingDeploymentOptions(settingRequest *SearchRequest) ([]*SettingOptionDTO, error) + func (impl *NotificationSettingsRepositoryImpl) FindNotificationSettingsByViewId(viewId int) ([]NotificationSettings, error) + func (impl *NotificationSettingsRepositoryImpl) FindNotificationSettingsViewById(id int) (*NotificationSettingsView, error) + func (impl *NotificationSettingsRepositoryImpl) FindNotificationSettingsViewByIds(ids []*int) ([]*NotificationSettingsView, error) + func (impl *NotificationSettingsRepositoryImpl) SaveAllNotificationSettings(notificationSettings []NotificationSettings, tx *pg.Tx) (int, error) + func (impl *NotificationSettingsRepositoryImpl) SaveNotificationSetting(notificationSettings *NotificationSettings, tx *pg.Tx) (*NotificationSettings, error) + func (impl *NotificationSettingsRepositoryImpl) SaveNotificationSettingsConfig(notificationSettingsView *NotificationSettingsView, tx *pg.Tx) (*NotificationSettingsView, error) + func (impl *NotificationSettingsRepositoryImpl) UpdateNotificationSettings(notificationSettings *NotificationSettings, tx *pg.Tx) (*NotificationSettings, error) + func (impl *NotificationSettingsRepositoryImpl) UpdateNotificationSettingsView(notificationSettingsView *NotificationSettingsView, tx *pg.Tx) (*NotificationSettingsView, error) + type NotificationSettingsView struct + Config string + Id int + type NotificationSettingsViewWithAppEnv struct + AppId *int + AppName string + Config string + ConfigName string + EnvId *int + EnvironmentName string + Id int + type RegistryType string + type RoleGroup struct + Active bool + CasbinName string + Description string + Id int32 + Name string + TableName struct{} + type RoleGroupRepository interface + CreateRoleGroup func(model *RoleGroup, tx *pg.Tx) (*RoleGroup, error) + CreateRoleGroupRoleMapping func(model *RoleGroupRoleMapping, tx *pg.Tx) (*RoleGroupRoleMapping, error) + DeleteRoleGroupRoleMapping func(model *RoleGroupRoleMapping, tx *pg.Tx) (bool, error) + GetAllRoleGroup func() ([]*RoleGroup, error) + GetConnection func() (dbConnection *pg.DB) + GetRoleGroupById func(id int32) (*RoleGroup, error) + GetRoleGroupByName func(name string) (*RoleGroup, error) + GetRoleGroupListByCasbinNames func(name []string) ([]*RoleGroup, error) + GetRoleGroupListByName func(name string) ([]*RoleGroup, error) + GetRoleGroupRoleMapping func(model int32) (*RoleGroupRoleMapping, error) + GetRoleGroupRoleMappingByRoleGroupId func(roleGroupId int32) ([]*RoleGroupRoleMapping, error) + UpdateRoleGroup func(model *RoleGroup, tx *pg.Tx) (*RoleGroup, error) + type RoleGroupRepositoryImpl struct + Logger *zap.SugaredLogger + func NewRoleGroupRepositoryImpl(dbConnection *pg.DB, Logger *zap.SugaredLogger) *RoleGroupRepositoryImpl + func (impl *RoleGroupRepositoryImpl) GetConnection() (dbConnection *pg.DB) + func (impl RoleGroupRepositoryImpl) CreateRoleGroup(model *RoleGroup, tx *pg.Tx) (*RoleGroup, error) + func (impl RoleGroupRepositoryImpl) CreateRoleGroupRoleMapping(model *RoleGroupRoleMapping, tx *pg.Tx) (*RoleGroupRoleMapping, error) + func (impl RoleGroupRepositoryImpl) DeleteRoleGroupRoleMapping(model *RoleGroupRoleMapping, tx *pg.Tx) (bool, error) + func (impl RoleGroupRepositoryImpl) GetAllRoleGroup() ([]*RoleGroup, error) + func (impl RoleGroupRepositoryImpl) GetRoleGroupById(id int32) (*RoleGroup, error) + func (impl RoleGroupRepositoryImpl) GetRoleGroupByName(name string) (*RoleGroup, error) + func (impl RoleGroupRepositoryImpl) GetRoleGroupListByCasbinNames(names []string) ([]*RoleGroup, error) + func (impl RoleGroupRepositoryImpl) GetRoleGroupListByName(name string) ([]*RoleGroup, error) + func (impl RoleGroupRepositoryImpl) GetRoleGroupRoleMapping(userRoleModelId int32) (*RoleGroupRoleMapping, error) + func (impl RoleGroupRepositoryImpl) GetRoleGroupRoleMappingByRoleGroupId(roleGroupId int32) ([]*RoleGroupRoleMapping, error) + func (impl RoleGroupRepositoryImpl) UpdateRoleGroup(model *RoleGroup, tx *pg.Tx) (*RoleGroup, error) + type RoleGroupRoleMapping struct + Id int + RoleGroupId int32 + RoleId int + TableName struct{} + type RoleModel struct + Action string + Entity string + EntityName string + Environment string + Id int + Role string + TableName struct{} + Team string + type SESConfig struct + AccessKey string + ConfigName string + Default bool + Description string + FromEmail string + Id int + OwnerId int32 + Region string + SecretKey string + SessionToken string + type SESNotificationRepository interface + FindAll func() ([]*SESConfig, error) + FindByIds func(ids []*int) ([]*SESConfig, error) + FindByIdsIn func(ids []int) ([]*SESConfig, error) + FindByTeamIdOrOwnerId func(ownerId int32) ([]*SESConfig, error) + FindDefault func() (*SESConfig, error) + FindOne func(id int) (*SESConfig, error) + SaveSESConfig func(sesConfig *SESConfig) (*SESConfig, error) + UpdateSESConfig func(sesConfig *SESConfig) (*SESConfig, error) + UpdateSESConfigDefault func() (bool, error) + type SESNotificationRepositoryImpl struct + func NewSESNotificationRepositoryImpl(dbConnection *pg.DB) *SESNotificationRepositoryImpl + func (impl *SESNotificationRepositoryImpl) FindAll() ([]*SESConfig, error) + func (impl *SESNotificationRepositoryImpl) FindByIdsIn(ids []int) ([]*SESConfig, error) + func (impl *SESNotificationRepositoryImpl) FindByTeamIdOrOwnerId(ownerId int32) ([]*SESConfig, error) + func (impl *SESNotificationRepositoryImpl) FindDefault() (*SESConfig, error) + func (impl *SESNotificationRepositoryImpl) FindOne(id int) (*SESConfig, error) + func (impl *SESNotificationRepositoryImpl) SaveSESConfig(sesConfig *SESConfig) (*SESConfig, error) + func (impl *SESNotificationRepositoryImpl) UpdateSESConfig(sesConfig *SESConfig) (*SESConfig, error) + func (impl *SESNotificationRepositoryImpl) UpdateSESConfigDefault() (bool, error) + func (repo *SESNotificationRepositoryImpl) FindByIds(ids []*int) ([]*SESConfig, error) + type SSOLoginModel struct + Active bool + Config string + Id int32 + Label string + Name string + TableName struct{} + Url string + type SSOLoginRepository interface + Create func(userModel *SSOLoginModel, tx *pg.Tx) (*SSOLoginModel, error) + Delete func(userModel *SSOLoginModel, tx *pg.Tx) (bool, error) + GetActive func() (*SSOLoginModel, error) + GetAll func() ([]SSOLoginModel, error) + GetById func(id int32) (*SSOLoginModel, error) + GetByName func(name string) (*SSOLoginModel, error) + GetConnection func() (dbConnection *pg.DB) + Update func(userModel *SSOLoginModel, tx *pg.Tx) (*SSOLoginModel, error) + type SSOLoginRepositoryImpl struct + Logger *zap.SugaredLogger + func NewSSOLoginRepositoryImpl(dbConnection *pg.DB) *SSOLoginRepositoryImpl + func (impl *SSOLoginRepositoryImpl) GetConnection() (dbConnection *pg.DB) + func (impl SSOLoginRepositoryImpl) Create(userModel *SSOLoginModel, tx *pg.Tx) (*SSOLoginModel, error) + func (impl SSOLoginRepositoryImpl) Delete(userModel *SSOLoginModel, tx *pg.Tx) (bool, error) + func (impl SSOLoginRepositoryImpl) GetActive() (*SSOLoginModel, error) + func (impl SSOLoginRepositoryImpl) GetAll() ([]SSOLoginModel, error) + func (impl SSOLoginRepositoryImpl) GetById(id int32) (*SSOLoginModel, error) + func (impl SSOLoginRepositoryImpl) GetByName(name string) (*SSOLoginModel, error) + func (impl SSOLoginRepositoryImpl) Update(userModel *SSOLoginModel, tx *pg.Tx) (*SSOLoginModel, error) + type ScmConfiguration struct + URL string + type SearchRequest struct + AppId []*int + EnvId []*int + PipelineName string + TeamId []*int + UserId int32 + type SettingOptionDTO struct + EnvironmentName string + PipelineId int + PipelineName string + PipelineType string + type SlackConfig struct + ConfigName string + Description string + Id int + OwnerId int32 + TeamId int + WebHookUrl string + type SlackNotificationRepository interface + FindAll func() ([]SlackConfig, error) + FindByIds func(ids []*int) ([]*SlackConfig, error) + FindByIdsIn func(ids []int) ([]*SlackConfig, error) + FindByName func(value string) ([]SlackConfig, error) + FindByTeamIdOrOwnerId func(ownerId int32, teamIds []int) ([]SlackConfig, error) + FindOne func(id int) (*SlackConfig, error) + SaveSlackConfig func(slackConfig *SlackConfig) (*SlackConfig, error) + UpdateSlackConfig func(slackConfig *SlackConfig) (*SlackConfig, error) + type SlackNotificationRepositoryImpl struct + func NewSlackNotificationRepositoryImpl(dbConnection *pg.DB) *SlackNotificationRepositoryImpl + func (impl *SlackNotificationRepositoryImpl) FindAll() ([]SlackConfig, error) + func (impl *SlackNotificationRepositoryImpl) FindByIdsIn(ids []int) ([]*SlackConfig, error) + func (impl *SlackNotificationRepositoryImpl) FindByName(value string) ([]SlackConfig, error) + func (impl *SlackNotificationRepositoryImpl) FindByTeamIdOrOwnerId(ownerId int32, teamIds []int) ([]SlackConfig, error) + func (impl *SlackNotificationRepositoryImpl) FindOne(id int) (*SlackConfig, error) + func (impl *SlackNotificationRepositoryImpl) SaveSlackConfig(slackConfig *SlackConfig) (*SlackConfig, error) + func (impl *SlackNotificationRepositoryImpl) UpdateSlackConfig(slackConfig *SlackConfig) (*SlackConfig, error) + func (repo *SlackNotificationRepositoryImpl) FindByIds(ids []*int) ([]*SlackConfig, error) + type UserAuthRepository interface + CreateDefaultPolicies func(team string, entityName string, env string, tx *pg.Tx) (bool, error) + CreateDefaultPoliciesForGlobalEntity func(entity string, entityName string, action string, tx *pg.Tx) (bool, error) + CreateRole func(userModel *RoleModel, tx *pg.Tx) (*RoleModel, error) + CreateUpdateDefaultPoliciesForSuperAdmin func(tx *pg.Tx) (bool, error) + CreateUserRoleMapping func(userRoleModel *UserRoleModel, tx *pg.Tx) (*UserRoleModel, error) + DeleteRole func(roleModel *RoleModel, tx *pg.Tx) (bool, error) + DeleteUserRoleMapping func(userRoleModel *UserRoleModel, tx *pg.Tx) (bool, error) + GetAllRole func() ([]RoleModel, error) + GetRole func(role string) (*RoleModel, error) + GetRoleByFilter func(entity string, team string, app string, env string, act string) (RoleModel, error) + GetRoleById func(id int) (*RoleModel, error) + GetRolesByGroupId func(userId int32) ([]*RoleModel, error) + GetRolesByUserId func(userId int32) ([]RoleModel, error) + GetUserRoleMapping func(userRoleModelId int) (*UserRoleModel, error) + GetUserRoleMappingByRoleId func(roleId int) ([]*UserRoleModel, error) + GetUserRoleMappingByUserId func(userId int32) ([]*UserRoleModel, error) + SyncOrchestratorToCasbin func(team string, entityName string, env string, tx *pg.Tx) (bool, error) + UpdateRole func(userModel *RoleModel, tx *pg.Tx) (*RoleModel, error) + type UserAuthRepositoryImpl struct + Logger *zap.SugaredLogger + func NewUserAuthRepositoryImpl(dbConnection *pg.DB, Logger *zap.SugaredLogger) *UserAuthRepositoryImpl + func (impl UserAuthRepositoryImpl) CreateDefaultPolicies(team string, entityName string, env string, tx *pg.Tx) (bool, error) + func (impl UserAuthRepositoryImpl) CreateDefaultPoliciesForGlobalEntity(entity string, entityName string, action string, tx *pg.Tx) (bool, error) + func (impl UserAuthRepositoryImpl) CreateRole(userModel *RoleModel, tx *pg.Tx) (*RoleModel, error) + func (impl UserAuthRepositoryImpl) CreateUpdateDefaultPoliciesForSuperAdmin(tx *pg.Tx) (bool, error) + func (impl UserAuthRepositoryImpl) CreateUserRoleMapping(userRoleModel *UserRoleModel, tx *pg.Tx) (*UserRoleModel, error) + func (impl UserAuthRepositoryImpl) DeleteRole(roleModel *RoleModel, tx *pg.Tx) (bool, error) + func (impl UserAuthRepositoryImpl) DeleteUserRoleMapping(userRoleModel *UserRoleModel, tx *pg.Tx) (bool, error) + func (impl UserAuthRepositoryImpl) GetAllRole() ([]RoleModel, error) + func (impl UserAuthRepositoryImpl) GetRole(role string) (*RoleModel, error) + func (impl UserAuthRepositoryImpl) GetRoleByFilter(entity string, team string, app string, env string, act string) (RoleModel, error) + func (impl UserAuthRepositoryImpl) GetRoleById(id int) (*RoleModel, error) + func (impl UserAuthRepositoryImpl) GetRolesByGroupId(roleGroupId int32) ([]*RoleModel, error) + func (impl UserAuthRepositoryImpl) GetRolesByUserId(userId int32) ([]RoleModel, error) + func (impl UserAuthRepositoryImpl) GetUserRoleMapping(userRoleModelId int) (*UserRoleModel, error) + func (impl UserAuthRepositoryImpl) GetUserRoleMappingByRoleId(roleId int) ([]*UserRoleModel, error) + func (impl UserAuthRepositoryImpl) GetUserRoleMappingByUserId(userId int32) ([]*UserRoleModel, error) + func (impl UserAuthRepositoryImpl) SyncOrchestratorToCasbin(team string, entityName string, env string, tx *pg.Tx) (bool, error) + func (impl UserAuthRepositoryImpl) UpdateRole(userModel *RoleModel, tx *pg.Tx) (*RoleModel, error) + type UserModel struct + AccessToken string + Active bool + EmailId string + Id int32 + TableName struct{} + type UserRepository interface + CreateUser func(userModel *UserModel, tx *pg.Tx) (*UserModel, error) + DeleteUser func(userModel *UserModel, tx *pg.Tx) (bool, error) + FetchActiveOrDeletedUserByEmail func(email string) (*UserModel, error) + FetchActiveUserByEmail func(email string) (bean.UserInfo, error) + FetchUserDetailByEmail func(email string) (bean.UserInfo, error) + FetchUserMatchesByEmailId func(email string) ([]UserModel, error) + GetAll func() ([]UserModel, error) + GetById func(id int32) (*UserModel, error) + GetByIds func(ids []int32) ([]UserModel, error) + GetConnection func() (dbConnection *pg.DB) + GetUsersByFilter func(size int, from int) ([]UserModel, error) + UpdateUser func(userModel *UserModel, tx *pg.Tx) (*UserModel, error) + type UserRepositoryImpl struct + Logger *zap.SugaredLogger + func NewUserRepositoryImpl(dbConnection *pg.DB) *UserRepositoryImpl + func (impl *UserRepositoryImpl) GetConnection() (dbConnection *pg.DB) + func (impl UserRepositoryImpl) CreateUser(userModel *UserModel, tx *pg.Tx) (*UserModel, error) + func (impl UserRepositoryImpl) DeleteUser(userModel *UserModel, tx *pg.Tx) (bool, error) + func (impl UserRepositoryImpl) FetchActiveOrDeletedUserByEmail(email string) (*UserModel, error) + func (impl UserRepositoryImpl) FetchActiveUserByEmail(email string) (bean.UserInfo, error) + func (impl UserRepositoryImpl) FetchUserDetailByEmail(email string) (bean.UserInfo, error) + func (impl UserRepositoryImpl) FetchUserMatchesByEmailId(email string) ([]UserModel, error) + func (impl UserRepositoryImpl) GetAll() ([]UserModel, error) + func (impl UserRepositoryImpl) GetById(id int32) (*UserModel, error) + func (impl UserRepositoryImpl) GetByIds(ids []int32) ([]UserModel, error) + func (impl UserRepositoryImpl) GetUsersByFilter(size int, from int) ([]UserModel, error) + func (impl UserRepositoryImpl) UpdateUser(userModel *UserModel, tx *pg.Tx) (*UserModel, error) + type UserRoleModel struct + Id int + RoleId int + TableName struct{} + User UserModel + UserId int32