Documentation ¶
Overview ¶
@description: app listing view
Index ¶
- Constants
- type AppLevelMetrics
- type AppLevelMetricsRepository
- type AppLevelMetricsRepositoryImpl
- type AppListingRepository
- type AppListingRepositoryImpl
- func (impl AppListingRepositoryImpl) DeploymentDetailByArtifactId(ciArtifactId int, envId int) (bean.DeploymentDetailContainer, error)
- func (impl AppListingRepositoryImpl) FetchAppDetail(ctx context.Context, appId int, envId int) (bean.AppDetailContainer, error)
- func (impl AppListingRepositoryImpl) FetchAppStageStatus(appId int, appType 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) FetchAppsByEnvironmentV2(appListingFilter helper.AppListingFilter) ([]*bean.AppEnvironmentContainer, int, error)
- func (impl AppListingRepositoryImpl) FetchJobs(appIds []int, statuses []string, sortOrder string) ([]*bean.JobListingContainer, error)
- func (impl AppListingRepositoryImpl) FetchJobsLastSucceededOn(CiPipelineIDs []int) ([]*bean.CiPipelineLastSucceededTime, error)
- func (impl AppListingRepositoryImpl) FetchMinDetailOtherEnvironment(appId int) ([]*bean.Environment, error)
- func (impl AppListingRepositoryImpl) FetchOtherEnvironment(appId int) ([]*bean.Environment, error)
- func (impl AppListingRepositoryImpl) FetchOverviewAppsByEnvironment(envId, limit, offset int) ([]*bean.AppEnvironmentContainer, error)
- func (impl AppListingRepositoryImpl) FetchOverviewCiPipelines(jobId int) ([]*bean.JobListingContainer, error)
- func (impl AppListingRepositoryImpl) FindAppCount(isProd bool) (int, error)
- func (impl AppListingRepositoryImpl) PrometheusApiByEnvId(id int) (*string, error)
- type AppNameTypeIdContainerDBResponse
- type Attributes
- type AttributesRepository
- type AttributesRepositoryImpl
- func (repo AttributesRepositoryImpl) FindActiveList() ([]*Attributes, error)
- func (repo AttributesRepositoryImpl) FindById(id int) (*Attributes, error)
- func (repo AttributesRepositoryImpl) FindByKey(key string) (*Attributes, error)
- func (impl *AttributesRepositoryImpl) GetConnection() (dbConnection *pg.DB)
- func (repo AttributesRepositoryImpl) Save(model *Attributes, tx *pg.Tx) (*Attributes, error)
- func (repo AttributesRepositoryImpl) Update(model *Attributes, tx *pg.Tx) error
- type AuthMode
- type CiArtifact
- type CiArtifactRepository
- type CiArtifactRepositoryImpl
- func (impl CiArtifactRepositoryImpl) Delete(artifact *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) GetArtifactByCdWorkflowId(cdWorkflowId int) (artifact *CiArtifact, err error)
- func (impl CiArtifactRepositoryImpl) GetArtifactParentCiAndWorkflowDetailsByIds(ids []int) ([]*CiArtifact, error)
- func (impl CiArtifactRepositoryImpl) GetArtifactsByCDPipeline(cdPipelineId, limit int, parentId int, parentType bean.WorkflowType) ([]*CiArtifact, error)
- func (impl CiArtifactRepositoryImpl) GetArtifactsByCDPipelineAndRunnerType(cdPipelineId int, runnerType bean.WorkflowType) ([]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
- type DbConfig
- type DbConfigRepository
- type 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
- type DeploymentGroup
- type DeploymentGroupApp
- type DeploymentGroupAppRepository
- type 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
- type DeploymentGroupRepositoryImpl
- func (impl *DeploymentGroupRepositoryImpl) Create(model *DeploymentGroup) (*DeploymentGroup, error)
- func (impl *DeploymentGroupRepositoryImpl) Delete(model *DeploymentGroup) error
- func (impl *DeploymentGroupRepositoryImpl) FindByAppIdAndEnvId(envId, appId int) ([]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) GetNamesByAppIdAndEnvId(envId, appId int) ([]string, error)
- func (impl *DeploymentGroupRepositoryImpl) Update(model *DeploymentGroup) (*DeploymentGroup, error)
- type DeploymentStatus
- type EnvLevelAppMetrics
- type EnvLevelAppMetricsRepository
- type 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) FindByAppIdAndEnvIds(appId int, envIds []int) ([]*EnvLevelAppMetrics, error)
- func (impl *EnvLevelAppMetricsRepositoryImpl) Save(metrics *EnvLevelAppMetrics) error
- func (impl *EnvLevelAppMetricsRepositoryImpl) Update(metrics *EnvLevelAppMetrics) error
- type GitConfiguration
- type GitHost
- type GitHostRepository
- type GitHostRepositoryImpl
- func (impl GitHostRepositoryImpl) Exists(name string) (bool, error)
- func (impl GitHostRepositoryImpl) FindAll() ([]GitHost, error)
- func (impl GitHostRepositoryImpl) FindOneById(id int) (GitHost, error)
- func (impl GitHostRepositoryImpl) FindOneByName(name string) (GitHost, error)
- func (impl GitHostRepositoryImpl) Save(gitHost *GitHost) error
- type GitOpsConfig
- type GitOpsConfigRepository
- type 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) GetEmailIdFromActiveGitOpsConfig() (string, error)
- 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) IsGitOpsConfigured() (bool, error)
- func (impl *GitOpsConfigRepositoryImpl) UpdateGitOpsConfig(model *GitOpsConfig, tx *pg.Tx) error
- type GitProvider
- type GitProviderRepository
- type GitProviderRepositoryImpl
- func (impl GitProviderRepositoryImpl) FindAll() ([]GitProvider, error)
- func (impl GitProviderRepositoryImpl) FindAllActiveForAutocomplete() ([]GitProvider, error)
- func (impl GitProviderRepositoryImpl) FindByUrl(providerUrl string) (GitProvider, error)
- func (impl GitProviderRepositoryImpl) FindOne(providerId string) (GitProvider, error)
- func (impl GitProviderRepositoryImpl) MarkProviderDeleted(gitProvider *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
- type GitWebhookRepository
- type GitWebhookRepositoryImpl
- type GlobalCMCS
- type GlobalCMCSRepository
- type GlobalCMCSRepositoryImpl
- func (impl *GlobalCMCSRepositoryImpl) Delete(model *GlobalCMCS) error
- func (impl *GlobalCMCSRepositoryImpl) FindAllActive() ([]*GlobalCMCS, error)
- func (impl *GlobalCMCSRepositoryImpl) FindAllActiveByPipelineType(pipelineType string) ([]*GlobalCMCS, error)
- func (impl *GlobalCMCSRepositoryImpl) FindByConfigTypeAndName(configType, name string) (*GlobalCMCS, error)
- func (impl *GlobalCMCSRepositoryImpl) FindById(id int) (*GlobalCMCS, error)
- func (impl *GlobalCMCSRepositoryImpl) FindByMountPath(mountPath string) (*GlobalCMCS, error)
- func (impl *GlobalCMCSRepositoryImpl) Save(model *GlobalCMCS) (*GlobalCMCS, error)
- func (impl *GlobalCMCSRepositoryImpl) Update(model *GlobalCMCS) (*GlobalCMCS, error)
- type JiraAccountDetails
- type JiraAccountRepository
- type 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 LinkoutsModel
- type LinkoutsRepository
- type 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
- type Modification
- type NotificationSettings
- type NotificationSettingsRepository
- type 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) FindNotificationSettingsByConfigIdAndConfigType(configId int, configType string) ([]*NotificationSettings, 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
- type NotificationSettingsViewWithAppEnv
- type SESConfig
- type SESNotificationRepository
- type SESNotificationRepositoryImpl
- func (impl *SESNotificationRepositoryImpl) FindAll() ([]*SESConfig, error)
- func (repo *SESNotificationRepositoryImpl) FindByIds(ids []*int) ([]*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) MarkSESConfigDeleted(sesConfig *SESConfig) error
- func (impl *SESNotificationRepositoryImpl) SaveSESConfig(sesConfig *SESConfig) (*SESConfig, error)
- func (impl *SESNotificationRepositoryImpl) UpdateSESConfig(sesConfig *SESConfig) (*SESConfig, error)
- func (impl *SESNotificationRepositoryImpl) UpdateSESConfigDefault() (bool, error)
- type SMTPConfig
- type SMTPNotificationRepository
- type SMTPNotificationRepositoryImpl
- func (impl *SMTPNotificationRepositoryImpl) FindAll() ([]*SMTPConfig, error)
- func (impl *SMTPNotificationRepositoryImpl) FindByIds(ids []*int) ([]*SMTPConfig, error)
- func (impl *SMTPNotificationRepositoryImpl) FindByIdsIn(ids []int) ([]*SMTPConfig, error)
- func (impl *SMTPNotificationRepositoryImpl) FindByTeamIdOrOwnerId(ownerId int32) ([]*SMTPConfig, error)
- func (impl *SMTPNotificationRepositoryImpl) FindDefault() (*SMTPConfig, error)
- func (impl *SMTPNotificationRepositoryImpl) FindOne(id int) (*SMTPConfig, error)
- func (impl *SMTPNotificationRepositoryImpl) MarkSMTPConfigDeleted(smtpConfig *SMTPConfig) error
- func (impl *SMTPNotificationRepositoryImpl) SaveSMTPConfig(smtpConfig *SMTPConfig) (*SMTPConfig, error)
- func (impl *SMTPNotificationRepositoryImpl) UpdateSMTPConfig(smtpConfig *SMTPConfig) (*SMTPConfig, error)
- func (impl *SMTPNotificationRepositoryImpl) UpdateSMTPConfigDefault() (bool, error)
- type ScmConfiguration
- type SearchRequest
- type SettingOptionDTO
- type SlackConfig
- type SlackNotificationRepository
- type SlackNotificationRepositoryImpl
- func (impl *SlackNotificationRepositoryImpl) FindAll() ([]SlackConfig, error)
- func (repo *SlackNotificationRepositoryImpl) FindByIds(ids []*int) ([]*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) MarkSlackConfigDeleted(slackConfig *SlackConfig) error
- func (impl *SlackNotificationRepositoryImpl) SaveSlackConfig(slackConfig *SlackConfig) (*SlackConfig, error)
- func (impl *SlackNotificationRepositoryImpl) UpdateSlackConfig(slackConfig *SlackConfig) (*SlackConfig, error)
- type TerminalAccessRepository
- type TerminalAccessRepositoryImpl
- func (impl TerminalAccessRepositoryImpl) FetchAllTemplates() ([]*models.TerminalAccessTemplates, error)
- func (impl TerminalAccessRepositoryImpl) FetchTerminalAccessTemplate(templateName string) (*models.TerminalAccessTemplates, error)
- func (impl TerminalAccessRepositoryImpl) GetAllRunningUserTerminalData() ([]*models.UserTerminalAccessData, error)
- func (impl TerminalAccessRepositoryImpl) GetUserTerminalAccessData(id int) (*models.UserTerminalAccessData, error)
- func (impl TerminalAccessRepositoryImpl) SaveUserTerminalAccessData(data *models.UserTerminalAccessData) error
- func (impl TerminalAccessRepositoryImpl) UpdateUserTerminalAccessData(data *models.UserTerminalAccessData) error
- func (impl TerminalAccessRepositoryImpl) UpdateUserTerminalStatus(id int, status string) error
- type UserAttributes
- type UserAttributesDao
- type UserAttributesRepository
- type UserAttributesRepositoryImpl
- func (repo UserAttributesRepositoryImpl) AddUserAttribute(attrDto *UserAttributesDao) (*UserAttributesDao, error)
- func (impl *UserAttributesRepositoryImpl) GetConnection() (dbConnection *pg.DB)
- func (repo UserAttributesRepositoryImpl) GetDataValueByKey(attrDto *UserAttributesDao) (string, error)
- func (repo UserAttributesRepositoryImpl) GetUserDataByEmailId(emailId string) (string, error)
- func (repo UserAttributesRepositoryImpl) UpdateDataValByKey(attrDto *UserAttributesDao) error
- type WebhookData
- type WebhookEventData
- type WebhookEventDataRepository
- type WebhookEventDataRepositoryImpl
Constants ¶
View Source
const ( CM_TYPE_CONFIG = "CONFIGMAP" CS_TYPE_CONFIG = "SECRET" ENVIRONMENT_CONFIG = "environment" VOLUME_CONFIG = "volume" )
View Source
const ( PIPELINE_TYPE_CI = "CI" PIPELINE_TYPE_CD = "CD" PIPELINE_TYPE_CI_CD = "CI/CD" )
View Source
const NewDeployment string = "Deployment Initiated"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AppLevelMetrics ¶
type AppLevelMetricsRepository ¶
type AppLevelMetricsRepository interface { Save(metrics *AppLevelMetrics) error FindByAppId(id int) (*AppLevelMetrics, error) Update(metrics *AppLevelMetrics) error }
type AppLevelMetricsRepositoryImpl ¶
type AppLevelMetricsRepositoryImpl struct {
// contains filtered or unexported fields
}
func NewAppLevelMetricsRepositoryImpl ¶
func NewAppLevelMetricsRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *AppLevelMetricsRepositoryImpl
func (*AppLevelMetricsRepositoryImpl) FindByAppId ¶
func (impl *AppLevelMetricsRepositoryImpl) FindByAppId(appId int) (*AppLevelMetrics, error)
func (*AppLevelMetricsRepositoryImpl) Save ¶
func (impl *AppLevelMetricsRepositoryImpl) Save(metrics *AppLevelMetrics) error
func (*AppLevelMetricsRepositoryImpl) Update ¶
func (impl *AppLevelMetricsRepositoryImpl) Update(metrics *AppLevelMetrics) error
type AppListingRepository ¶
type AppListingRepository interface { FetchAppsByEnvironment(appListingFilter helper.AppListingFilter) ([]*bean.AppEnvironmentContainer, error) FetchJobs(appIds []int, statuses []string, sortOrder string) ([]*bean.JobListingContainer, error) FetchOverviewCiPipelines(jobId int) ([]*bean.JobListingContainer, error) FetchJobsLastSucceededOn(ciPipelineIDs []int) ([]*bean.CiPipelineLastSucceededTime, error) FetchAppDetail(ctx context.Context, appId int, envId int) (bean.AppDetailContainer, error) FetchAppTriggerView(appId int) ([]bean.TriggerView, error) FetchAppStageStatus(appId int, appType int) ([]bean.AppStageStatus, error) //Not in used PrometheusApiByEnvId(id int) (*string, error) FetchOtherEnvironment(appId int) ([]*bean.Environment, error) FetchMinDetailOtherEnvironment(appId int) ([]*bean.Environment, error) DeploymentDetailByArtifactId(ciArtifactId int, envId int) (bean.DeploymentDetailContainer, error) FindAppCount(isProd bool) (int, error) FetchAppsByEnvironmentV2(appListingFilter helper.AppListingFilter) ([]*bean.AppEnvironmentContainer, int, error) FetchOverviewAppsByEnvironment(envId, limit, offset int) ([]*bean.AppEnvironmentContainer, error) }
type AppListingRepositoryImpl ¶
type AppListingRepositoryImpl struct { Logger *zap.SugaredLogger // contains filtered or unexported fields }
func NewAppListingRepositoryImpl ¶
func NewAppListingRepositoryImpl(Logger *zap.SugaredLogger, dbConnection *pg.DB, appListingRepositoryQueryBuilder helper.AppListingRepositoryQueryBuilder) *AppListingRepositoryImpl
func (AppListingRepositoryImpl) DeploymentDetailByArtifactId ¶
func (impl AppListingRepositoryImpl) DeploymentDetailByArtifactId(ciArtifactId int, envId int) (bean.DeploymentDetailContainer, error)
func (AppListingRepositoryImpl) FetchAppDetail ¶
func (impl AppListingRepositoryImpl) FetchAppDetail(ctx context.Context, appId int, envId int) (bean.AppDetailContainer, error)
func (AppListingRepositoryImpl) FetchAppStageStatus ¶
func (impl AppListingRepositoryImpl) FetchAppStageStatus(appId int, appType int) ([]bean.AppStageStatus, error)
func (AppListingRepositoryImpl) FetchAppTriggerView ¶
func (impl AppListingRepositoryImpl) FetchAppTriggerView(appId int) ([]bean.TriggerView, error)
func (AppListingRepositoryImpl) FetchAppsByEnvironment ¶
func (impl AppListingRepositoryImpl) FetchAppsByEnvironment(appListingFilter helper.AppListingFilter) ([]*bean.AppEnvironmentContainer, error)
func (AppListingRepositoryImpl) FetchAppsByEnvironmentV2 ¶ added in v0.6.17
func (impl AppListingRepositoryImpl) FetchAppsByEnvironmentV2(appListingFilter helper.AppListingFilter) ([]*bean.AppEnvironmentContainer, int, error)
func (AppListingRepositoryImpl) FetchJobs ¶ added in v0.6.15
func (impl AppListingRepositoryImpl) FetchJobs(appIds []int, statuses []string, sortOrder string) ([]*bean.JobListingContainer, error)
func (AppListingRepositoryImpl) FetchJobsLastSucceededOn ¶ added in v0.6.15
func (impl AppListingRepositoryImpl) FetchJobsLastSucceededOn(CiPipelineIDs []int) ([]*bean.CiPipelineLastSucceededTime, error)
func (AppListingRepositoryImpl) FetchMinDetailOtherEnvironment ¶ added in v0.6.17
func (impl AppListingRepositoryImpl) FetchMinDetailOtherEnvironment(appId int) ([]*bean.Environment, error)
func (AppListingRepositoryImpl) FetchOtherEnvironment ¶
func (impl AppListingRepositoryImpl) FetchOtherEnvironment(appId int) ([]*bean.Environment, error)
func (AppListingRepositoryImpl) FetchOverviewAppsByEnvironment ¶ added in v0.6.17
func (impl AppListingRepositoryImpl) FetchOverviewAppsByEnvironment(envId, limit, offset int) ([]*bean.AppEnvironmentContainer, error)
func (AppListingRepositoryImpl) FetchOverviewCiPipelines ¶ added in v0.6.15
func (impl AppListingRepositoryImpl) FetchOverviewCiPipelines(jobId int) ([]*bean.JobListingContainer, error)
func (AppListingRepositoryImpl) FindAppCount ¶ added in v0.2.14
func (impl AppListingRepositoryImpl) FindAppCount(isProd bool) (int, error)
func (AppListingRepositoryImpl) PrometheusApiByEnvId ¶
func (impl AppListingRepositoryImpl) PrometheusApiByEnvId(id int) (*string, error)
type AppNameTypeIdContainerDBResponse ¶ added in v0.6.9
type Attributes ¶
type AttributesRepository ¶
type AttributesRepository interface { Save(model *Attributes, tx *pg.Tx) (*Attributes, error) Update(model *Attributes, tx *pg.Tx) error FindByKey(key string) (*Attributes, error) FindById(id int) (*Attributes, error) FindActiveList() ([]*Attributes, error) GetConnection() (dbConnection *pg.DB) }
type AttributesRepositoryImpl ¶
type AttributesRepositoryImpl struct {
// contains filtered or unexported fields
}
func NewAttributesRepositoryImpl ¶
func NewAttributesRepositoryImpl(dbConnection *pg.DB) *AttributesRepositoryImpl
func (AttributesRepositoryImpl) FindActiveList ¶
func (repo AttributesRepositoryImpl) FindActiveList() ([]*Attributes, error)
func (AttributesRepositoryImpl) FindById ¶
func (repo AttributesRepositoryImpl) FindById(id int) (*Attributes, error)
func (AttributesRepositoryImpl) FindByKey ¶
func (repo AttributesRepositoryImpl) FindByKey(key string) (*Attributes, error)
func (*AttributesRepositoryImpl) GetConnection ¶
func (impl *AttributesRepositoryImpl) GetConnection() (dbConnection *pg.DB)
func (AttributesRepositoryImpl) Save ¶
func (repo AttributesRepositoryImpl) Save(model *Attributes, tx *pg.Tx) (*Attributes, error)
func (AttributesRepositoryImpl) Update ¶
func (repo AttributesRepositoryImpl) Update(model *Attributes, tx *pg.Tx) error
type CiArtifact ¶
type CiArtifact struct { Id int `sql:"id,pk"` PipelineId int `sql:"pipeline_id"` //id of the ci pipeline from which this webhook was triggered Image string `sql:"image,notnull"` ImageDigest string `sql:"image_digest,notnull"` MaterialInfo string `sql:"material_info"` //git material metadata json array string DataSource string `sql:"data_source,notnull"` WorkflowId *int `sql:"ci_workflow_id"` ParentCiArtifact int `sql:"parent_ci_artifact"` ScanEnabled bool `sql:"scan_enabled,notnull"` Scanned bool `sql:"scanned,notnull"` ExternalCiPipelineId int `sql:"external_ci_pipeline_id"` IsArtifactUploaded bool `sql:"is_artifact_uploaded"` DeployedTime time.Time `sql:"-"` Deployed bool `sql:"-"` Latest bool `sql:"-"` RunningOnParent bool `sql:"-"` sql.AuditLog // contains filtered or unexported fields }
func (*CiArtifact) ParseMaterialInfo ¶
func (info *CiArtifact) ParseMaterialInfo() (map[string]string, error)
return map of gitUrl:hash
type CiArtifactRepository ¶
type CiArtifactRepository interface { Save(artifact *CiArtifact) error Delete(artifact *CiArtifact) error Get(id int) (artifact *CiArtifact, err error) GetArtifactParentCiAndWorkflowDetailsByIds(ids []int) ([]*CiArtifact, error) GetByWfId(wfId int) (artifact *CiArtifact, err error) GetArtifactsByCDPipeline(cdPipelineId, limit int, parentId int, parentType bean.WorkflowType) ([]*CiArtifact, error) GetArtifactsByCDPipelineV2(cdPipelineId int) ([]CiArtifact, error) GetArtifactsByCDPipelineAndRunnerType(cdPipelineId int, runnerType bean.WorkflowType) ([]CiArtifact, error) SaveAll(artifacts []*CiArtifact) error GetArtifactsByCiPipelineId(ciPipelineId int) ([]CiArtifact, error) FinDByParentCiArtifactAndCiId(parentCiArtifact int, ciPipelineIds []int) ([]*CiArtifact, error) GetLatest(cdPipelineId int) (int, error) GetByImageDigest(imageDigest string) (artifact *CiArtifact, err error) GetByIds(ids []int) ([]*CiArtifact, error) GetArtifactByCdWorkflowId(cdWorkflowId int) (artifact *CiArtifact, err error) }
type CiArtifactRepositoryImpl ¶
type CiArtifactRepositoryImpl struct {
// contains filtered or unexported fields
}
func NewCiArtifactRepositoryImpl ¶
func NewCiArtifactRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *CiArtifactRepositoryImpl
func (CiArtifactRepositoryImpl) Delete ¶ added in v0.6.9
func (impl CiArtifactRepositoryImpl) Delete(artifact *CiArtifact) error
func (CiArtifactRepositoryImpl) FinDByParentCiArtifactAndCiId ¶
func (impl CiArtifactRepositoryImpl) FinDByParentCiArtifactAndCiId(parentCiArtifact int, ciPipelineIds []int) ([]*CiArtifact, error)
func (CiArtifactRepositoryImpl) Get ¶
func (impl CiArtifactRepositoryImpl) Get(id int) (artifact *CiArtifact, err error)
func (CiArtifactRepositoryImpl) GetArtifactByCdWorkflowId ¶ added in v0.3.12
func (impl CiArtifactRepositoryImpl) GetArtifactByCdWorkflowId(cdWorkflowId int) (artifact *CiArtifact, err error)
func (CiArtifactRepositoryImpl) GetArtifactParentCiAndWorkflowDetailsByIds ¶ added in v0.6.17
func (impl CiArtifactRepositoryImpl) GetArtifactParentCiAndWorkflowDetailsByIds(ids []int) ([]*CiArtifact, error)
func (CiArtifactRepositoryImpl) GetArtifactsByCDPipeline ¶
func (impl CiArtifactRepositoryImpl) GetArtifactsByCDPipeline(cdPipelineId, limit int, parentId int, parentType bean.WorkflowType) ([]*CiArtifact, error)
this method takes CD Pipeline id and Returns List of Artifacts Latest By last deployed
func (CiArtifactRepositoryImpl) GetArtifactsByCDPipelineAndRunnerType ¶
func (impl CiArtifactRepositoryImpl) GetArtifactsByCDPipelineAndRunnerType(cdPipelineId int, runnerType bean.WorkflowType) ([]CiArtifact, error)
func (CiArtifactRepositoryImpl) GetArtifactsByCDPipelineV2 ¶
func (impl CiArtifactRepositoryImpl) GetArtifactsByCDPipelineV2(cdPipelineId int) ([]CiArtifact, error)
func (CiArtifactRepositoryImpl) GetArtifactsByCiPipelineId ¶
func (impl CiArtifactRepositoryImpl) GetArtifactsByCiPipelineId(ciPipelineId int) ([]CiArtifact, error)
func (CiArtifactRepositoryImpl) GetByIds ¶
func (impl CiArtifactRepositoryImpl) GetByIds(ids []int) ([]*CiArtifact, error)
func (CiArtifactRepositoryImpl) GetByImageDigest ¶
func (impl CiArtifactRepositoryImpl) GetByImageDigest(imageDigest string) (*CiArtifact, error)
func (CiArtifactRepositoryImpl) GetByWfId ¶
func (impl CiArtifactRepositoryImpl) GetByWfId(wfId int) (*CiArtifact, error)
func (CiArtifactRepositoryImpl) GetLatest ¶
func (impl CiArtifactRepositoryImpl) GetLatest(cdPipelineId int) (int, error)
func (CiArtifactRepositoryImpl) Save ¶
func (impl CiArtifactRepositoryImpl) Save(artifact *CiArtifact) error
func (CiArtifactRepositoryImpl) SaveAll ¶
func (impl CiArtifactRepositoryImpl) SaveAll(artifacts []*CiArtifact) error
type CiMaterialInfo ¶
type CiMaterialInfo struct { Material Material `json:"material"` Changed bool `json:"changed"` Modifications []Modification `json:"modifications"` }
func GetCiMaterialInfo ¶
func GetCiMaterialInfo(materialInfo string, source string) ([]CiMaterialInfo, error)
type DbConfig ¶
type DbConfig struct { Id int `sql:"id,pk"` Name string `sql:"name"` //name by which user identifies this db Type DbType `sql:"type"` //type of db, PG, MYsql, MariaDb Host string `sql:"host"` Port string `sql:"port"` DbName string `sql:"db_name"` //name of database inside PG UserName string `sql:"user_name"` Password string `sql:"password"` Active bool `sql:"active"` sql.AuditLog // contains filtered or unexported fields }
type DbConfigRepository ¶
type DbConfigRepositoryImpl ¶
type DbConfigRepositoryImpl struct {
// contains filtered or unexported fields
}
func NewDbConfigRepositoryImpl ¶
func NewDbConfigRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *DbConfigRepositoryImpl
func (DbConfigRepositoryImpl) GetActiveForAutocomplete ¶
func (impl DbConfigRepositoryImpl) GetActiveForAutocomplete() (configs []*DbConfig, err error)
func (DbConfigRepositoryImpl) GetAll ¶
func (impl DbConfigRepositoryImpl) GetAll() (configs []*DbConfig, err error)
func (DbConfigRepositoryImpl) GetById ¶
func (impl DbConfigRepositoryImpl) GetById(id int) (*DbConfig, error)
func (DbConfigRepositoryImpl) Save ¶
func (impl DbConfigRepositoryImpl) Save(config *DbConfig) error
type DeploymentGroup ¶
type DeploymentGroup struct { TableName struct{} `sql:"deployment_group" pg:",discard_unknown_columns"` Id int `sql:"id,pk"` Name string `sql:"name,notnull"` AppCount int `sql:"app_count,notnull"` NoOfApps string `sql:"no_of_apps"` EnvironmentId int `sql:"environment_id"` CiPipelineId int `sql:"ci_pipeline_id"` Active bool `sql:"active,notnull"` DeploymentGroupApps []*DeploymentGroupApp sql.AuditLog }
type DeploymentGroupApp ¶
type DeploymentGroupAppRepository ¶
type DeploymentGroupAppRepository interface { Create(model *DeploymentGroupApp) (*DeploymentGroupApp, error) GetById(id int) (*DeploymentGroupApp, error) GetAll() ([]*DeploymentGroupApp, error) Update(model *DeploymentGroupApp) (*DeploymentGroupApp, error) Delete(model *DeploymentGroupApp) error GetByDeploymentGroup(deploymentGroupId int) ([]*DeploymentGroupApp, error) }
type DeploymentGroupAppRepositoryImpl ¶
type DeploymentGroupAppRepositoryImpl struct { Logger *zap.SugaredLogger // contains filtered or unexported fields }
func NewDeploymentGroupAppRepositoryImpl ¶
func NewDeploymentGroupAppRepositoryImpl(Logger *zap.SugaredLogger, dbConnection *pg.DB) *DeploymentGroupAppRepositoryImpl
func (DeploymentGroupAppRepositoryImpl) Create ¶
func (impl DeploymentGroupAppRepositoryImpl) Create(model *DeploymentGroupApp) (*DeploymentGroupApp, error)
func (DeploymentGroupAppRepositoryImpl) Delete ¶
func (impl DeploymentGroupAppRepositoryImpl) Delete(model *DeploymentGroupApp) error
func (DeploymentGroupAppRepositoryImpl) GetAll ¶
func (impl DeploymentGroupAppRepositoryImpl) GetAll() ([]*DeploymentGroupApp, error)
func (DeploymentGroupAppRepositoryImpl) GetByDeploymentGroup ¶
func (impl DeploymentGroupAppRepositoryImpl) GetByDeploymentGroup(deploymentGroupId int) ([]*DeploymentGroupApp, error)
func (DeploymentGroupAppRepositoryImpl) GetById ¶
func (impl DeploymentGroupAppRepositoryImpl) GetById(id int) (*DeploymentGroupApp, error)
func (DeploymentGroupAppRepositoryImpl) Update ¶
func (impl DeploymentGroupAppRepositoryImpl) Update(model *DeploymentGroupApp) (*DeploymentGroupApp, error)
type DeploymentGroupRepository ¶
type DeploymentGroupRepository interface { Create(model *DeploymentGroup) (*DeploymentGroup, error) GetById(id int) (*DeploymentGroup, error) GetAll() ([]DeploymentGroup, error) Update(model *DeploymentGroup) (*DeploymentGroup, error) Delete(model *DeploymentGroup) error FindByIdWithApp(id int) (*DeploymentGroup, error) FindByAppIdAndEnvId(envId, appId int) ([]DeploymentGroup, error) GetNamesByAppIdAndEnvId(envId, appId int) ([]string, error) }
type DeploymentGroupRepositoryImpl ¶
type DeploymentGroupRepositoryImpl struct { Logger *zap.SugaredLogger // contains filtered or unexported fields }
func NewDeploymentGroupRepositoryImpl ¶
func NewDeploymentGroupRepositoryImpl(Logger *zap.SugaredLogger, dbConnection *pg.DB) *DeploymentGroupRepositoryImpl
func (*DeploymentGroupRepositoryImpl) Create ¶
func (impl *DeploymentGroupRepositoryImpl) Create(model *DeploymentGroup) (*DeploymentGroup, error)
func (*DeploymentGroupRepositoryImpl) Delete ¶
func (impl *DeploymentGroupRepositoryImpl) Delete(model *DeploymentGroup) error
func (*DeploymentGroupRepositoryImpl) FindByAppIdAndEnvId ¶ added in v0.4.21
func (impl *DeploymentGroupRepositoryImpl) FindByAppIdAndEnvId(envId, appId int) ([]DeploymentGroup, error)
func (*DeploymentGroupRepositoryImpl) FindByIdWithApp ¶
func (impl *DeploymentGroupRepositoryImpl) FindByIdWithApp(id int) (*DeploymentGroup, error)
func (*DeploymentGroupRepositoryImpl) GetAll ¶
func (impl *DeploymentGroupRepositoryImpl) GetAll() ([]DeploymentGroup, error)
func (*DeploymentGroupRepositoryImpl) GetById ¶
func (impl *DeploymentGroupRepositoryImpl) GetById(id int) (*DeploymentGroup, error)
func (*DeploymentGroupRepositoryImpl) GetNamesByAppIdAndEnvId ¶ added in v0.6.4
func (impl *DeploymentGroupRepositoryImpl) GetNamesByAppIdAndEnvId(envId, appId int) ([]string, error)
func (*DeploymentGroupRepositoryImpl) Update ¶
func (impl *DeploymentGroupRepositoryImpl) Update(model *DeploymentGroup) (*DeploymentGroup, error)
type DeploymentStatus ¶
type DeploymentStatus struct { Id int `sql:"id,pk"` AppName string `sql:"app_name,notnull"` Status string `sql:"status,notnull"` AppId int `sql:"app_id"` EnvId int `sql:"env_id"` CreatedOn time.Time `sql:"created_on"` UpdatedOn time.Time `sql:"updated_on"` // contains filtered or unexported fields }
below table is deprecated, not being used anywhere
type EnvLevelAppMetrics ¶
type EnvLevelAppMetricsRepository ¶
type EnvLevelAppMetricsRepository interface { Save(metrics *EnvLevelAppMetrics) error Update(metrics *EnvLevelAppMetrics) error FindByAppIdAndEnvId(appId int, envId int) (*EnvLevelAppMetrics, error) Delete(metrics *EnvLevelAppMetrics) error FindByAppId(appId int) ([]*EnvLevelAppMetrics, error) FindByAppIdAndEnvIds(appId int, envIds []int) ([]*EnvLevelAppMetrics, error) }
type EnvLevelAppMetricsRepositoryImpl ¶
type EnvLevelAppMetricsRepositoryImpl struct {
// contains filtered or unexported fields
}
func NewEnvLevelAppMetricsRepositoryImpl ¶
func NewEnvLevelAppMetricsRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *EnvLevelAppMetricsRepositoryImpl
func (*EnvLevelAppMetricsRepositoryImpl) Delete ¶
func (impl *EnvLevelAppMetricsRepositoryImpl) Delete(metrics *EnvLevelAppMetrics) error
func (*EnvLevelAppMetricsRepositoryImpl) FindByAppId ¶
func (impl *EnvLevelAppMetricsRepositoryImpl) FindByAppId(appId int) ([]*EnvLevelAppMetrics, error)
func (*EnvLevelAppMetricsRepositoryImpl) FindByAppIdAndEnvId ¶
func (impl *EnvLevelAppMetricsRepositoryImpl) FindByAppIdAndEnvId(appId int, envId int) (*EnvLevelAppMetrics, error)
func (*EnvLevelAppMetricsRepositoryImpl) FindByAppIdAndEnvIds ¶ added in v0.6.17
func (impl *EnvLevelAppMetricsRepositoryImpl) FindByAppIdAndEnvIds(appId int, envIds []int) ([]*EnvLevelAppMetrics, error)
func (*EnvLevelAppMetricsRepositoryImpl) Save ¶
func (impl *EnvLevelAppMetricsRepositoryImpl) Save(metrics *EnvLevelAppMetrics) error
func (*EnvLevelAppMetricsRepositoryImpl) Update ¶
func (impl *EnvLevelAppMetricsRepositoryImpl) Update(metrics *EnvLevelAppMetrics) error
type GitConfiguration ¶
type GitConfiguration struct {
URL string `json:"url"`
}
type GitHost ¶ added in v0.2.22
type GitHost struct { Id int `sql:"id,pk"` Name string `sql:"name,notnull"` Active bool `sql:"active,notnull"` WebhookUrl string `sql:"webhook_url"` WebhookSecret string `sql:"webhook_secret"` EventTypeHeader string `sql:"event_type_header"` SecretHeader string `sql:"secret_header"` SecretValidator string `sql:"secret_validator"` sql.AuditLog // contains filtered or unexported fields }
type GitHostRepository ¶ added in v0.2.22
type GitHostRepositoryImpl ¶ added in v0.2.22
type GitHostRepositoryImpl struct {
// contains filtered or unexported fields
}
func NewGitHostRepositoryImpl ¶ added in v0.2.22
func NewGitHostRepositoryImpl(dbConnection *pg.DB) *GitHostRepositoryImpl
func (GitHostRepositoryImpl) Exists ¶ added in v0.2.22
func (impl GitHostRepositoryImpl) Exists(name string) (bool, error)
func (GitHostRepositoryImpl) FindAll ¶ added in v0.2.22
func (impl GitHostRepositoryImpl) FindAll() ([]GitHost, error)
func (GitHostRepositoryImpl) FindOneById ¶ added in v0.2.22
func (impl GitHostRepositoryImpl) FindOneById(id int) (GitHost, error)
func (GitHostRepositoryImpl) FindOneByName ¶ added in v0.2.22
func (impl GitHostRepositoryImpl) FindOneByName(name string) (GitHost, error)
func (GitHostRepositoryImpl) Save ¶ added in v0.2.22
func (impl GitHostRepositoryImpl) Save(gitHost *GitHost) error
type GitOpsConfig ¶
type GitOpsConfig struct { Id int `sql:"id,pk"` Provider string `sql:"provider"` Username string `sql:"username"` Token string `sql:"token"` GitLabGroupId string `sql:"gitlab_group_id"` GitHubOrgId string `sql:"github_org_id"` AzureProject string `sql:"azure_project"` Host string `sql:"host"` Active bool `sql:"active,notnull"` BitBucketWorkspaceId string `sql:"bitbucket_workspace_id"` BitBucketProjectKey string `sql:"bitbucket_project_key"` EmailId string `sql:"email_id"` sql.AuditLog // contains filtered or unexported fields }
type GitOpsConfigRepository ¶
type GitOpsConfigRepository interface { CreateGitOpsConfig(model *GitOpsConfig, tx *pg.Tx) (*GitOpsConfig, error) UpdateGitOpsConfig(model *GitOpsConfig, tx *pg.Tx) error GetGitOpsConfigById(id int) (*GitOpsConfig, error) GetAllGitOpsConfig() ([]*GitOpsConfig, error) GetGitOpsConfigByProvider(provider string) (*GitOpsConfig, error) GetGitOpsConfigActive() (*GitOpsConfig, error) GetConnection() *pg.DB GetEmailIdFromActiveGitOpsConfig() (string, error) IsGitOpsConfigured() (bool, error) }
type GitOpsConfigRepositoryImpl ¶
type GitOpsConfigRepositoryImpl struct {
// contains filtered or unexported fields
}
func NewGitOpsConfigRepositoryImpl ¶
func NewGitOpsConfigRepositoryImpl(logger *zap.SugaredLogger, dbConnection *pg.DB) *GitOpsConfigRepositoryImpl
func (*GitOpsConfigRepositoryImpl) CreateGitOpsConfig ¶
func (impl *GitOpsConfigRepositoryImpl) CreateGitOpsConfig(model *GitOpsConfig, tx *pg.Tx) (*GitOpsConfig, error)
func (*GitOpsConfigRepositoryImpl) GetAllGitOpsConfig ¶
func (impl *GitOpsConfigRepositoryImpl) GetAllGitOpsConfig() ([]*GitOpsConfig, error)
func (*GitOpsConfigRepositoryImpl) GetConnection ¶
func (impl *GitOpsConfigRepositoryImpl) GetConnection() *pg.DB
func (*GitOpsConfigRepositoryImpl) GetEmailIdFromActiveGitOpsConfig ¶ added in v0.4.1
func (impl *GitOpsConfigRepositoryImpl) GetEmailIdFromActiveGitOpsConfig() (string, error)
func (*GitOpsConfigRepositoryImpl) GetGitOpsConfigActive ¶
func (impl *GitOpsConfigRepositoryImpl) GetGitOpsConfigActive() (*GitOpsConfig, error)
func (*GitOpsConfigRepositoryImpl) GetGitOpsConfigById ¶
func (impl *GitOpsConfigRepositoryImpl) GetGitOpsConfigById(id int) (*GitOpsConfig, error)
func (*GitOpsConfigRepositoryImpl) GetGitOpsConfigByProvider ¶
func (impl *GitOpsConfigRepositoryImpl) GetGitOpsConfigByProvider(provider string) (*GitOpsConfig, error)
func (*GitOpsConfigRepositoryImpl) IsGitOpsConfigured ¶ added in v0.5.3
func (impl *GitOpsConfigRepositoryImpl) IsGitOpsConfigured() (bool, error)
func (*GitOpsConfigRepositoryImpl) UpdateGitOpsConfig ¶
func (impl *GitOpsConfigRepositoryImpl) UpdateGitOpsConfig(model *GitOpsConfig, tx *pg.Tx) error
type GitProvider ¶
type GitProvider struct { Id int `sql:"id,pk"` Name string `sql:"name,notnull"` Url string `sql:"url,notnull"` UserName string `sql:"user_name"` Password string `sql:"password"` SshPrivateKey string `sql:"ssh_private_key"` AccessToken string `sql:"access_token"` AuthMode AuthMode `sql:"auth_mode,notnull"` Active bool `sql:"active,notnull"` Deleted bool `sql:"deleted,notnull"` GitHostId int `sql:"git_host_id"` //id stored in db git_host( foreign key) sql.AuditLog // contains filtered or unexported fields }
type GitProviderRepository ¶
type GitProviderRepository interface { Save(gitProvider *GitProvider) error ProviderExists(url string) (bool, error) FindAllActiveForAutocomplete() ([]GitProvider, error) FindAll() ([]GitProvider, error) FindOne(providerId string) (GitProvider, error) FindByUrl(providerUrl string) (GitProvider, error) Update(gitProvider *GitProvider) error MarkProviderDeleted(gitProvider *GitProvider) error }
type GitProviderRepositoryImpl ¶
type GitProviderRepositoryImpl struct {
// contains filtered or unexported fields
}
func NewGitProviderRepositoryImpl ¶
func NewGitProviderRepositoryImpl(dbConnection *pg.DB) *GitProviderRepositoryImpl
func (GitProviderRepositoryImpl) FindAll ¶
func (impl GitProviderRepositoryImpl) FindAll() ([]GitProvider, error)
func (GitProviderRepositoryImpl) FindAllActiveForAutocomplete ¶
func (impl GitProviderRepositoryImpl) FindAllActiveForAutocomplete() ([]GitProvider, error)
func (GitProviderRepositoryImpl) FindByUrl ¶ added in v0.3.6
func (impl GitProviderRepositoryImpl) FindByUrl(providerUrl string) (GitProvider, error)
func (GitProviderRepositoryImpl) FindOne ¶
func (impl GitProviderRepositoryImpl) FindOne(providerId string) (GitProvider, error)
func (GitProviderRepositoryImpl) MarkProviderDeleted ¶ added in v0.3.15
func (impl GitProviderRepositoryImpl) MarkProviderDeleted(gitProvider *GitProvider) error
func (GitProviderRepositoryImpl) ProviderExists ¶
func (impl GitProviderRepositoryImpl) ProviderExists(url string) (bool, error)
func (GitProviderRepositoryImpl) Save ¶
func (impl GitProviderRepositoryImpl) Save(gitProvider *GitProvider) error
func (GitProviderRepositoryImpl) Update ¶
func (impl GitProviderRepositoryImpl) Update(gitProvider *GitProvider) error
type GitWebhook ¶
type GitWebhook struct { Id int `sql:"id,pk"` CiMaterialId int `sql:"ci_material_id"` GitMaterialId int `sql:"git_material_id"` Type string `sql:"type"` Value string `sql:"value"` Active bool `sql:"active"` LastSeenHash string `sql:"last_seen_hash"` CreatedOn time.Time `sql:"created_on"` // contains filtered or unexported fields }
type GitWebhookRepository ¶
type GitWebhookRepository interface {
Save(gitWebhook *GitWebhook) error
}
type GitWebhookRepositoryImpl ¶
type GitWebhookRepositoryImpl struct {
// contains filtered or unexported fields
}
func NewGitWebhookRepositoryImpl ¶
func NewGitWebhookRepositoryImpl(dbConnection *pg.DB) *GitWebhookRepositoryImpl
func (*GitWebhookRepositoryImpl) Save ¶
func (impl *GitWebhookRepositoryImpl) Save(gitWebhook *GitWebhook) error
type GlobalCMCS ¶ added in v0.6.1
type GlobalCMCS struct { TableName struct{} `sql:"global_cm_cs" pg:",discard_unknown_columns"` Id int `sql:"id,pk"` ConfigType string `sql:"config_type"` // [CONFIGMAP, SECRET] Name string `sql:"name"` Type string `sql:"type"` // [environment, volume] //json string of map of key:value, example: '{ "a" : "b", "c" : "d"}' Data string `sql:"data"` MountPath string `sql:"mount_path"` Deleted bool `sql:"deleted,notnull"` SecretIngestionFor string `sql:"secret_ingestion_for,notnull"` // [CI, CD, CI/CD] sql.AuditLog }
type GlobalCMCSRepository ¶ added in v0.6.1
type GlobalCMCSRepository interface { Save(model *GlobalCMCS) (*GlobalCMCS, error) Update(model *GlobalCMCS) (*GlobalCMCS, error) FindAllActive() ([]*GlobalCMCS, error) FindById(id int) (*GlobalCMCS, error) FindByConfigTypeAndName(configType, name string) (*GlobalCMCS, error) FindByMountPath(mountPath string) (*GlobalCMCS, error) FindAllActiveByPipelineType(pipelineType string) ([]*GlobalCMCS, error) Delete(model *GlobalCMCS) error }
type GlobalCMCSRepositoryImpl ¶ added in v0.6.1
type GlobalCMCSRepositoryImpl struct {
// contains filtered or unexported fields
}
func NewGlobalCMCSRepositoryImpl ¶ added in v0.6.1
func NewGlobalCMCSRepositoryImpl(logger *zap.SugaredLogger, dbConnection *pg.DB) *GlobalCMCSRepositoryImpl
func (*GlobalCMCSRepositoryImpl) Delete ¶ added in v0.6.15
func (impl *GlobalCMCSRepositoryImpl) Delete(model *GlobalCMCS) error
func (*GlobalCMCSRepositoryImpl) FindAllActive ¶ added in v0.6.1
func (impl *GlobalCMCSRepositoryImpl) FindAllActive() ([]*GlobalCMCS, error)
func (*GlobalCMCSRepositoryImpl) FindAllActiveByPipelineType ¶ added in v0.6.15
func (impl *GlobalCMCSRepositoryImpl) FindAllActiveByPipelineType(pipelineType string) ([]*GlobalCMCS, error)
func (*GlobalCMCSRepositoryImpl) FindByConfigTypeAndName ¶ added in v0.6.1
func (impl *GlobalCMCSRepositoryImpl) FindByConfigTypeAndName(configType, name string) (*GlobalCMCS, error)
func (*GlobalCMCSRepositoryImpl) FindById ¶ added in v0.6.15
func (impl *GlobalCMCSRepositoryImpl) FindById(id int) (*GlobalCMCS, error)
func (*GlobalCMCSRepositoryImpl) FindByMountPath ¶ added in v0.6.1
func (impl *GlobalCMCSRepositoryImpl) FindByMountPath(mountPath string) (*GlobalCMCS, error)
func (*GlobalCMCSRepositoryImpl) Save ¶ added in v0.6.1
func (impl *GlobalCMCSRepositoryImpl) Save(model *GlobalCMCS) (*GlobalCMCS, error)
func (*GlobalCMCSRepositoryImpl) Update ¶ added in v0.6.1
func (impl *GlobalCMCSRepositoryImpl) Update(model *GlobalCMCS) (*GlobalCMCS, error)
type JiraAccountDetails ¶
type JiraAccountDetails struct { Id int32 `sql:"id,pk"` UserName string `sql:"user_name"` AccountURL string `sql:"account_url"` AuthToken string `sql:"auth_token"` CommitMessageRegex string `sql:"commit_message_regex"` FinalIssueStatus string `sql:"final_issue_status"` PipelineStage string `sql:"pipeline_stage"` PipelineId int32 `sql:"pipeline_id"` sql.AuditLog // contains filtered or unexported fields }
type JiraAccountRepository ¶
type JiraAccountRepository interface { Save(accountDetails *JiraAccountDetails) error FindByPipelineIdAndStage(pipelineId int32, pipelineStage string) (*JiraAccountDetails, error) Update(accountDetails *JiraAccountDetails) error }
type JiraAccountRepositoryImpl ¶
type JiraAccountRepositoryImpl struct {
// contains filtered or unexported fields
}
func NewJiraAccountRepositoryImpl ¶
func NewJiraAccountRepositoryImpl(dbConnection *pg.DB) *JiraAccountRepositoryImpl
func (*JiraAccountRepositoryImpl) FindByPipelineIdAndStage ¶
func (impl *JiraAccountRepositoryImpl) FindByPipelineIdAndStage(pipelineId int32, pipelineStage string) (*JiraAccountDetails, error)
func (*JiraAccountRepositoryImpl) Save ¶
func (impl *JiraAccountRepositoryImpl) Save(jiraAccountDetails *JiraAccountDetails) error
func (*JiraAccountRepositoryImpl) Update ¶
func (impl *JiraAccountRepositoryImpl) Update(jiraAccountDetails *JiraAccountDetails) error
type LinkoutsModel ¶
type LinkoutsModel struct { TableName struct{} `sql:"app_env_linkouts" pg:",discard_unknown_columns"` Id int `sql:"id,pk"` AppId int `sql:"app_id,notnull"` EnvironmentId int `sql:"environment_id,notnull"` Link string `sql:"link"` Description string `sql:"description"` Name string `sql:"name"` sql.AuditLog }
type LinkoutsRepository ¶
type LinkoutsRepository interface { Create(model *LinkoutsModel) (*LinkoutsModel, error) GetById(id int) (*LinkoutsModel, error) GetAll() ([]LinkoutsModel, error) Update(model *LinkoutsModel) (*LinkoutsModel, error) FetchLinkoutsByAppIdAndEnvId(appId int, envId int) ([]LinkoutsModel, error) FetchLinkoutById(Id int) (bean.LinkOuts, error) }
type LinkoutsRepositoryImpl ¶
type LinkoutsRepositoryImpl struct { Logger *zap.SugaredLogger // contains filtered or unexported fields }
func NewLinkoutsRepositoryImpl ¶
func NewLinkoutsRepositoryImpl(Logger *zap.SugaredLogger, dbConnection *pg.DB) *LinkoutsRepositoryImpl
func (LinkoutsRepositoryImpl) Create ¶
func (impl LinkoutsRepositoryImpl) Create(model *LinkoutsModel) (*LinkoutsModel, error)
func (LinkoutsRepositoryImpl) FetchLinkoutById ¶
func (impl LinkoutsRepositoryImpl) FetchLinkoutById(Id int) (bean.LinkOuts, error)
func (LinkoutsRepositoryImpl) FetchLinkoutsByAppIdAndEnvId ¶
func (impl LinkoutsRepositoryImpl) FetchLinkoutsByAppIdAndEnvId(appId int, envId int) ([]LinkoutsModel, error)
func (LinkoutsRepositoryImpl) GetAll ¶
func (impl LinkoutsRepositoryImpl) GetAll() ([]LinkoutsModel, error)
func (LinkoutsRepositoryImpl) GetById ¶
func (impl LinkoutsRepositoryImpl) GetById(id int) (*LinkoutsModel, error)
func (LinkoutsRepositoryImpl) Update ¶
func (impl LinkoutsRepositoryImpl) Update(model *LinkoutsModel) (*LinkoutsModel, error)
type Material ¶
type Material struct { PluginID string `json:"plugin-id"` GitConfiguration GitConfiguration `json:"git-configuration"` ScmConfiguration ScmConfiguration `json:"scm-configuration"` Type string `json:"type"` }
type Modification ¶
type Modification struct { Revision string `json:"revision"` ModifiedTime string `json:"modified-time"` Data map[string]string `json:"data"` Author string `json:"author"` Message string `json:"message"` Branch string `json:"branch"` Tag string `json:"tag,omitempty"` WebhookData WebhookData `json:"webhookData,omitempty"` }
type NotificationSettings ¶
type NotificationSettings struct { Id int `sql:"id,pk"` TeamId *int `sql:"team_id"` AppId *int `sql:"app_id"` EnvId *int `sql:"env_id"` PipelineId *int `sql:"pipeline_id"` PipelineType string `sql:"pipeline_type"` EventTypeId int `sql:"event_type_id"` Config string `sql:"config"` ViewId int `sql:"view_id"` // contains filtered or unexported fields }
type NotificationSettingsRepository ¶
type NotificationSettingsRepository interface { FindNSViewCount() (int, error) SaveNotificationSettingsConfig(notificationSettingsView *NotificationSettingsView, tx *pg.Tx) (*NotificationSettingsView, error) FindNotificationSettingsViewById(id int) (*NotificationSettingsView, error) FindNotificationSettingsViewByIds(id []*int) ([]*NotificationSettingsView, error) UpdateNotificationSettingsView(notificationSettingsView *NotificationSettingsView, tx *pg.Tx) (*NotificationSettingsView, error) SaveNotificationSetting(notificationSettings *NotificationSettings, tx *pg.Tx) (*NotificationSettings, error) UpdateNotificationSettings(notificationSettings *NotificationSettings, tx *pg.Tx) (*NotificationSettings, error) FindNotificationSettingsByViewId(viewId int) ([]NotificationSettings, error) SaveAllNotificationSettings(notificationSettings []NotificationSettings, tx *pg.Tx) (int, error) DeleteNotificationSettingsByConfigId(viewId int, tx *pg.Tx) (int, error) FindAll(offset int, size int) ([]*NotificationSettingsView, error) DeleteNotificationSettingsViewById(id int, tx *pg.Tx) (int, error) FindNotificationSettingDeploymentOptions(settingRequest *SearchRequest) ([]*SettingOptionDTO, error) FindNotificationSettingBuildOptions(settingRequest *SearchRequest) ([]*SettingOptionDTO, error) FetchNotificationSettingGroupBy(viewId int) ([]NotificationSettings, error) FindNotificationSettingsByConfigIdAndConfigType(configId int, configType string) ([]*NotificationSettings, error) }
type NotificationSettingsRepositoryImpl ¶
type NotificationSettingsRepositoryImpl struct {
// contains filtered or unexported fields
}
func NewNotificationSettingsRepositoryImpl ¶
func NewNotificationSettingsRepositoryImpl(dbConnection *pg.DB) *NotificationSettingsRepositoryImpl
func (*NotificationSettingsRepositoryImpl) DeleteNotificationSettingsByConfigId ¶
func (*NotificationSettingsRepositoryImpl) DeleteNotificationSettingsViewById ¶
func (*NotificationSettingsRepositoryImpl) FetchNotificationSettingGroupBy ¶
func (impl *NotificationSettingsRepositoryImpl) FetchNotificationSettingGroupBy(viewId int) ([]NotificationSettings, error)
func (*NotificationSettingsRepositoryImpl) FindAll ¶
func (impl *NotificationSettingsRepositoryImpl) FindAll(offset int, size int) ([]*NotificationSettingsView, error)
func (*NotificationSettingsRepositoryImpl) FindNSViewCount ¶
func (impl *NotificationSettingsRepositoryImpl) FindNSViewCount() (int, error)
func (*NotificationSettingsRepositoryImpl) FindNotificationSettingBuildOptions ¶
func (impl *NotificationSettingsRepositoryImpl) FindNotificationSettingBuildOptions(settingRequest *SearchRequest) ([]*SettingOptionDTO, error)
func (*NotificationSettingsRepositoryImpl) FindNotificationSettingDeploymentOptions ¶
func (impl *NotificationSettingsRepositoryImpl) FindNotificationSettingDeploymentOptions(settingRequest *SearchRequest) ([]*SettingOptionDTO, error)
func (*NotificationSettingsRepositoryImpl) FindNotificationSettingsByConfigIdAndConfigType ¶ added in v0.3.15
func (impl *NotificationSettingsRepositoryImpl) FindNotificationSettingsByConfigIdAndConfigType(configId int, configType string) ([]*NotificationSettings, error)
func (*NotificationSettingsRepositoryImpl) FindNotificationSettingsByViewId ¶
func (impl *NotificationSettingsRepositoryImpl) FindNotificationSettingsByViewId(viewId int) ([]NotificationSettings, error)
func (*NotificationSettingsRepositoryImpl) FindNotificationSettingsViewById ¶
func (impl *NotificationSettingsRepositoryImpl) FindNotificationSettingsViewById(id int) (*NotificationSettingsView, error)
func (*NotificationSettingsRepositoryImpl) FindNotificationSettingsViewByIds ¶
func (impl *NotificationSettingsRepositoryImpl) FindNotificationSettingsViewByIds(ids []*int) ([]*NotificationSettingsView, error)
func (*NotificationSettingsRepositoryImpl) SaveAllNotificationSettings ¶
func (impl *NotificationSettingsRepositoryImpl) SaveAllNotificationSettings(notificationSettings []NotificationSettings, tx *pg.Tx) (int, error)
func (*NotificationSettingsRepositoryImpl) SaveNotificationSetting ¶
func (impl *NotificationSettingsRepositoryImpl) SaveNotificationSetting(notificationSettings *NotificationSettings, tx *pg.Tx) (*NotificationSettings, error)
func (*NotificationSettingsRepositoryImpl) SaveNotificationSettingsConfig ¶
func (impl *NotificationSettingsRepositoryImpl) SaveNotificationSettingsConfig(notificationSettingsView *NotificationSettingsView, tx *pg.Tx) (*NotificationSettingsView, error)
func (*NotificationSettingsRepositoryImpl) UpdateNotificationSettings ¶
func (impl *NotificationSettingsRepositoryImpl) UpdateNotificationSettings(notificationSettings *NotificationSettings, tx *pg.Tx) (*NotificationSettings, error)
func (*NotificationSettingsRepositoryImpl) UpdateNotificationSettingsView ¶
func (impl *NotificationSettingsRepositoryImpl) UpdateNotificationSettingsView(notificationSettingsView *NotificationSettingsView, tx *pg.Tx) (*NotificationSettingsView, error)
type SESConfig ¶
type SESConfig struct { Id int `sql:"id,pk"` Region string `sql:"region"` AccessKey string `sql:"access_key"` SecretKey string `sql:"secret_access_key"` FromEmail string `sql:"from_email"` SessionToken string `sql:"session_token"` ConfigName string `sql:"config_name"` Description string `sql:"description"` OwnerId int32 `sql:"owner_id"` Default bool `sql:"default,notnull"` Deleted bool `sql:"deleted,notnull"` sql.AuditLog // contains filtered or unexported fields }
type SESNotificationRepository ¶
type SESNotificationRepository interface { FindOne(id int) (*SESConfig, error) UpdateSESConfig(sesConfig *SESConfig) (*SESConfig, error) SaveSESConfig(sesConfig *SESConfig) (*SESConfig, error) FindAll() ([]*SESConfig, error) FindByIdsIn(ids []int) ([]*SESConfig, error) FindByTeamIdOrOwnerId(ownerId int32) ([]*SESConfig, error) UpdateSESConfigDefault() (bool, error) FindByIds(ids []*int) ([]*SESConfig, error) FindDefault() (*SESConfig, error) MarkSESConfigDeleted(sesConfig *SESConfig) error }
type SESNotificationRepositoryImpl ¶
type SESNotificationRepositoryImpl struct {
// contains filtered or unexported fields
}
func NewSESNotificationRepositoryImpl ¶
func NewSESNotificationRepositoryImpl(dbConnection *pg.DB) *SESNotificationRepositoryImpl
func (*SESNotificationRepositoryImpl) FindAll ¶
func (impl *SESNotificationRepositoryImpl) FindAll() ([]*SESConfig, error)
func (*SESNotificationRepositoryImpl) FindByIds ¶
func (repo *SESNotificationRepositoryImpl) FindByIds(ids []*int) ([]*SESConfig, error)
func (*SESNotificationRepositoryImpl) FindByIdsIn ¶
func (impl *SESNotificationRepositoryImpl) FindByIdsIn(ids []int) ([]*SESConfig, error)
func (*SESNotificationRepositoryImpl) FindByTeamIdOrOwnerId ¶
func (impl *SESNotificationRepositoryImpl) FindByTeamIdOrOwnerId(ownerId int32) ([]*SESConfig, error)
func (*SESNotificationRepositoryImpl) FindDefault ¶
func (impl *SESNotificationRepositoryImpl) FindDefault() (*SESConfig, error)
func (*SESNotificationRepositoryImpl) FindOne ¶
func (impl *SESNotificationRepositoryImpl) FindOne(id int) (*SESConfig, error)
func (*SESNotificationRepositoryImpl) MarkSESConfigDeleted ¶ added in v0.3.15
func (impl *SESNotificationRepositoryImpl) MarkSESConfigDeleted(sesConfig *SESConfig) error
func (*SESNotificationRepositoryImpl) SaveSESConfig ¶
func (impl *SESNotificationRepositoryImpl) SaveSESConfig(sesConfig *SESConfig) (*SESConfig, error)
func (*SESNotificationRepositoryImpl) UpdateSESConfig ¶
func (impl *SESNotificationRepositoryImpl) UpdateSESConfig(sesConfig *SESConfig) (*SESConfig, error)
func (*SESNotificationRepositoryImpl) UpdateSESConfigDefault ¶
func (impl *SESNotificationRepositoryImpl) UpdateSESConfigDefault() (bool, error)
type SMTPConfig ¶ added in v0.4.24
type SMTPConfig struct { Id int `sql:"id,pk"` Port string `sql:"port"` Host string `sql:"host"` AuthType string `sql:"auth_type"` AuthUser string `sql:"auth_user"` AuthPassword string `sql:"auth_password"` FromEmail string `sql:"from_email"` ConfigName string `sql:"config_name"` Description string `sql:"description"` OwnerId int32 `sql:"owner_id"` Default bool `sql:"default,notnull"` Deleted bool `sql:"deleted,notnull"` sql.AuditLog // contains filtered or unexported fields }
type SMTPNotificationRepository ¶ added in v0.4.24
type SMTPNotificationRepository interface { FindOne(id int) (*SMTPConfig, error) UpdateSMTPConfig(smtpConfig *SMTPConfig) (*SMTPConfig, error) SaveSMTPConfig(smtpConfig *SMTPConfig) (*SMTPConfig, error) FindAll() ([]*SMTPConfig, error) FindByIdsIn(ids []int) ([]*SMTPConfig, error) FindByTeamIdOrOwnerId(ownerId int32) ([]*SMTPConfig, error) UpdateSMTPConfigDefault() (bool, error) FindByIds(ids []*int) ([]*SMTPConfig, error) FindDefault() (*SMTPConfig, error) MarkSMTPConfigDeleted(smtpConfig *SMTPConfig) error }
type SMTPNotificationRepositoryImpl ¶ added in v0.4.24
type SMTPNotificationRepositoryImpl struct {
// contains filtered or unexported fields
}
func NewSMTPNotificationRepositoryImpl ¶ added in v0.4.24
func NewSMTPNotificationRepositoryImpl(dbConnection *pg.DB) *SMTPNotificationRepositoryImpl
func (*SMTPNotificationRepositoryImpl) FindAll ¶ added in v0.4.24
func (impl *SMTPNotificationRepositoryImpl) FindAll() ([]*SMTPConfig, error)
func (*SMTPNotificationRepositoryImpl) FindByIds ¶ added in v0.4.24
func (impl *SMTPNotificationRepositoryImpl) FindByIds(ids []*int) ([]*SMTPConfig, error)
func (*SMTPNotificationRepositoryImpl) FindByIdsIn ¶ added in v0.4.24
func (impl *SMTPNotificationRepositoryImpl) FindByIdsIn(ids []int) ([]*SMTPConfig, error)
func (*SMTPNotificationRepositoryImpl) FindByTeamIdOrOwnerId ¶ added in v0.4.24
func (impl *SMTPNotificationRepositoryImpl) FindByTeamIdOrOwnerId(ownerId int32) ([]*SMTPConfig, error)
func (*SMTPNotificationRepositoryImpl) FindDefault ¶ added in v0.4.24
func (impl *SMTPNotificationRepositoryImpl) FindDefault() (*SMTPConfig, error)
func (*SMTPNotificationRepositoryImpl) FindOne ¶ added in v0.4.24
func (impl *SMTPNotificationRepositoryImpl) FindOne(id int) (*SMTPConfig, error)
func (*SMTPNotificationRepositoryImpl) MarkSMTPConfigDeleted ¶ added in v0.4.24
func (impl *SMTPNotificationRepositoryImpl) MarkSMTPConfigDeleted(smtpConfig *SMTPConfig) error
func (*SMTPNotificationRepositoryImpl) SaveSMTPConfig ¶ added in v0.4.24
func (impl *SMTPNotificationRepositoryImpl) SaveSMTPConfig(smtpConfig *SMTPConfig) (*SMTPConfig, error)
func (*SMTPNotificationRepositoryImpl) UpdateSMTPConfig ¶ added in v0.4.24
func (impl *SMTPNotificationRepositoryImpl) UpdateSMTPConfig(smtpConfig *SMTPConfig) (*SMTPConfig, error)
func (*SMTPNotificationRepositoryImpl) UpdateSMTPConfigDefault ¶ added in v0.4.24
func (impl *SMTPNotificationRepositoryImpl) UpdateSMTPConfigDefault() (bool, error)
type ScmConfiguration ¶
type ScmConfiguration struct {
URL string `json:"url"`
}
type SearchRequest ¶
type SettingOptionDTO ¶
type SettingOptionDTO struct { //TeamId int `json:"-"` //AppId int `json:"-"` //EnvId int `json:"-"` PipelineId int `json:"pipelineId"` PipelineName string `json:"pipelineName"` PipelineType string `json:"pipelineType"` AppName string `json:"appName"` EnvironmentName string `json:"environmentName,omitempty"` }
type SlackConfig ¶
type SlackConfig struct { Id int `sql:"id,pk"` WebHookUrl string `sql:"web_hook_url"` ConfigName string `sql:"config_name"` Description string `sql:"description"` OwnerId int32 `sql:"owner_id"` TeamId int `sql:"team_id"` Deleted bool `sql:"deleted,notnull"` sql.AuditLog // contains filtered or unexported fields }
type SlackNotificationRepository ¶
type SlackNotificationRepository interface { FindOne(id int) (*SlackConfig, error) UpdateSlackConfig(slackConfig *SlackConfig) (*SlackConfig, error) SaveSlackConfig(slackConfig *SlackConfig) (*SlackConfig, error) FindAll() ([]SlackConfig, error) FindByIdsIn(ids []int) ([]*SlackConfig, error) FindByTeamIdOrOwnerId(ownerId int32, teamIds []int) ([]SlackConfig, error) FindByName(value string) ([]SlackConfig, error) FindByIds(ids []*int) ([]*SlackConfig, error) MarkSlackConfigDeleted(slackConfig *SlackConfig) error }
type SlackNotificationRepositoryImpl ¶
type SlackNotificationRepositoryImpl struct {
// contains filtered or unexported fields
}
func NewSlackNotificationRepositoryImpl ¶
func NewSlackNotificationRepositoryImpl(dbConnection *pg.DB) *SlackNotificationRepositoryImpl
func (*SlackNotificationRepositoryImpl) FindAll ¶
func (impl *SlackNotificationRepositoryImpl) FindAll() ([]SlackConfig, error)
func (*SlackNotificationRepositoryImpl) FindByIds ¶
func (repo *SlackNotificationRepositoryImpl) FindByIds(ids []*int) ([]*SlackConfig, error)
func (*SlackNotificationRepositoryImpl) FindByIdsIn ¶
func (impl *SlackNotificationRepositoryImpl) FindByIdsIn(ids []int) ([]*SlackConfig, error)
func (*SlackNotificationRepositoryImpl) FindByName ¶
func (impl *SlackNotificationRepositoryImpl) FindByName(value string) ([]SlackConfig, error)
func (*SlackNotificationRepositoryImpl) FindByTeamIdOrOwnerId ¶
func (impl *SlackNotificationRepositoryImpl) FindByTeamIdOrOwnerId(ownerId int32, teamIds []int) ([]SlackConfig, error)
func (*SlackNotificationRepositoryImpl) FindOne ¶
func (impl *SlackNotificationRepositoryImpl) FindOne(id int) (*SlackConfig, error)
func (*SlackNotificationRepositoryImpl) MarkSlackConfigDeleted ¶ added in v0.3.15
func (impl *SlackNotificationRepositoryImpl) MarkSlackConfigDeleted(slackConfig *SlackConfig) error
func (*SlackNotificationRepositoryImpl) SaveSlackConfig ¶
func (impl *SlackNotificationRepositoryImpl) SaveSlackConfig(slackConfig *SlackConfig) (*SlackConfig, error)
func (*SlackNotificationRepositoryImpl) UpdateSlackConfig ¶
func (impl *SlackNotificationRepositoryImpl) UpdateSlackConfig(slackConfig *SlackConfig) (*SlackConfig, error)
type TerminalAccessRepository ¶ added in v0.6.10
type TerminalAccessRepository interface { FetchTerminalAccessTemplate(templateName string) (*models.TerminalAccessTemplates, error) FetchAllTemplates() ([]*models.TerminalAccessTemplates, error) GetUserTerminalAccessData(id int) (*models.UserTerminalAccessData, error) GetAllRunningUserTerminalData() ([]*models.UserTerminalAccessData, error) SaveUserTerminalAccessData(data *models.UserTerminalAccessData) error UpdateUserTerminalAccessData(data *models.UserTerminalAccessData) error UpdateUserTerminalStatus(id int, status string) error }
type TerminalAccessRepositoryImpl ¶ added in v0.6.10
type TerminalAccessRepositoryImpl struct { Logger *zap.SugaredLogger // contains filtered or unexported fields }
func NewTerminalAccessRepositoryImpl ¶ added in v0.6.10
func NewTerminalAccessRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *TerminalAccessRepositoryImpl
func (TerminalAccessRepositoryImpl) FetchAllTemplates ¶ added in v0.6.10
func (impl TerminalAccessRepositoryImpl) FetchAllTemplates() ([]*models.TerminalAccessTemplates, error)
func (TerminalAccessRepositoryImpl) FetchTerminalAccessTemplate ¶ added in v0.6.10
func (impl TerminalAccessRepositoryImpl) FetchTerminalAccessTemplate(templateName string) (*models.TerminalAccessTemplates, error)
func (TerminalAccessRepositoryImpl) GetAllRunningUserTerminalData ¶ added in v0.6.10
func (impl TerminalAccessRepositoryImpl) GetAllRunningUserTerminalData() ([]*models.UserTerminalAccessData, error)
func (TerminalAccessRepositoryImpl) GetUserTerminalAccessData ¶ added in v0.6.10
func (impl TerminalAccessRepositoryImpl) GetUserTerminalAccessData(id int) (*models.UserTerminalAccessData, error)
func (TerminalAccessRepositoryImpl) SaveUserTerminalAccessData ¶ added in v0.6.10
func (impl TerminalAccessRepositoryImpl) SaveUserTerminalAccessData(data *models.UserTerminalAccessData) error
func (TerminalAccessRepositoryImpl) UpdateUserTerminalAccessData ¶ added in v0.6.10
func (impl TerminalAccessRepositoryImpl) UpdateUserTerminalAccessData(data *models.UserTerminalAccessData) error
func (TerminalAccessRepositoryImpl) UpdateUserTerminalStatus ¶ added in v0.6.10
func (impl TerminalAccessRepositoryImpl) UpdateUserTerminalStatus(id int, status string) error
type UserAttributes ¶ added in v0.5.3
type UserAttributesDao ¶ added in v0.5.3
type UserAttributesRepository ¶ added in v0.5.3
type UserAttributesRepository interface { GetConnection() (dbConnection *pg.DB) AddUserAttribute(attrDto *UserAttributesDao) (*UserAttributesDao, error) UpdateDataValByKey(attrDto *UserAttributesDao) error GetDataValueByKey(attrDto *UserAttributesDao) (string, error) GetUserDataByEmailId(emailId string) (string, error) }
type UserAttributesRepositoryImpl ¶ added in v0.5.3
type UserAttributesRepositoryImpl struct {
// contains filtered or unexported fields
}
func NewUserAttributesRepositoryImpl ¶ added in v0.5.3
func NewUserAttributesRepositoryImpl(dbConnection *pg.DB) *UserAttributesRepositoryImpl
func (UserAttributesRepositoryImpl) AddUserAttribute ¶ added in v0.5.3
func (repo UserAttributesRepositoryImpl) AddUserAttribute(attrDto *UserAttributesDao) (*UserAttributesDao, error)
func (*UserAttributesRepositoryImpl) GetConnection ¶ added in v0.5.3
func (impl *UserAttributesRepositoryImpl) GetConnection() (dbConnection *pg.DB)
func (UserAttributesRepositoryImpl) GetDataValueByKey ¶ added in v0.5.3
func (repo UserAttributesRepositoryImpl) GetDataValueByKey(attrDto *UserAttributesDao) (string, error)
func (UserAttributesRepositoryImpl) GetUserDataByEmailId ¶ added in v0.6.7
func (repo UserAttributesRepositoryImpl) GetUserDataByEmailId(emailId string) (string, error)
func (UserAttributesRepositoryImpl) UpdateDataValByKey ¶ added in v0.5.3
func (repo UserAttributesRepositoryImpl) UpdateDataValByKey(attrDto *UserAttributesDao) error
type WebhookData ¶ added in v0.2.22
type WebhookEventData ¶ added in v0.2.22
type WebhookEventDataRepository ¶ added in v0.2.22
type WebhookEventDataRepository interface { Save(webhookEventData *WebhookEventData) error GetById(id int) (*WebhookEventData, error) }
type WebhookEventDataRepositoryImpl ¶ added in v0.2.22
type WebhookEventDataRepositoryImpl struct {
// contains filtered or unexported fields
}
func NewWebhookEventDataRepositoryImpl ¶ added in v0.2.22
func NewWebhookEventDataRepositoryImpl(dbConnection *pg.DB) *WebhookEventDataRepositoryImpl
func (WebhookEventDataRepositoryImpl) GetById ¶ added in v0.2.27
func (impl WebhookEventDataRepositoryImpl) GetById(id int) (*WebhookEventData, error)
func (WebhookEventDataRepositoryImpl) Save ¶ added in v0.2.22
func (impl WebhookEventDataRepositoryImpl) Save(webhookEventData *WebhookEventData) error
Source Files ¶
- AppLevelMetricsRepository.go
- AppListingRepository.go
- AttributesRepository.go
- CiArtifactRepository.go
- DbConfigRepository.go
- DeploymentGroupAppRepository.go
- DeploymentGroupRepository.go
- EnvLevelAppMetricsRepository.go
- GitHostRepository.go
- GitOpsConfigRepository.go
- GitProviderRepository.go
- GitWebhookRepository.go
- GlobalCMCSRepository.go
- JiraAccountRepository.go
- LinkoutsRepository.go
- NotificationSettingsRepository.go
- SESNotificationRepository.go
- SMTPNotificationRepository.go
- SlackNotificationRepository.go
- TerminalAccessRepository.go
- UserAttributesRepository.go
- WebhookEventDataRepository.go
Click to show internal directories.
Click to hide internal directories.