Documentation
¶
Index ¶
- type ChartGroup
- type ChartGroupDeployment
- type ChartGroupDeploymentRepository
- type ChartGroupDeploymentRepositoryImpl
- func (impl *ChartGroupDeploymentRepositoryImpl) FindByChartGroupId(chartGroupId int) ([]*ChartGroupDeployment, error)
- func (impl *ChartGroupDeploymentRepositoryImpl) FindByInstalledAppId(installedAppId int) (*ChartGroupDeployment, error)
- func (impl *ChartGroupDeploymentRepositoryImpl) Save(tx *pg.Tx, chartGroupDeployment *ChartGroupDeployment) error
- func (impl *ChartGroupDeploymentRepositoryImpl) Update(model *ChartGroupDeployment, tx *pg.Tx) (*ChartGroupDeployment, error)
- type ChartGroupEntriesRepository
- type ChartGroupEntriesRepositoryImpl
- func (impl *ChartGroupEntriesRepositoryImpl) FindEntriesWithChartMetaByChartGroupId(chartGroupId []int) ([]*ChartGroupEntry, error)
- func (impl *ChartGroupEntriesRepositoryImpl) MarkChartGroupEntriesDeleted(chartGroupId []int, tx *pg.Tx) ([]*ChartGroupEntry, error)
- func (impl *ChartGroupEntriesRepositoryImpl) Save(model *ChartGroupEntry) (*ChartGroupEntry, error)
- func (impl *ChartGroupEntriesRepositoryImpl) SaveAndUpdateInTransaction(saveEntry []*ChartGroupEntry, updateEntry []*ChartGroupEntry) ([]*ChartGroupEntry, error)
- type ChartGroupEntry
- type ChartGroupReposotory
- type ChartGroupReposotoryImpl
- func (impl *ChartGroupReposotoryImpl) FindById(chartGroupId int) (*ChartGroup, error)
- func (impl *ChartGroupReposotoryImpl) FindByIdWithEntries(chertGroupId int) (*ChartGroup, error)
- func (impl *ChartGroupReposotoryImpl) FindByName(chartGroupName string) (bool, error)
- func (impl *ChartGroupReposotoryImpl) GetAll(max int) ([]*ChartGroup, error)
- func (impl *ChartGroupReposotoryImpl) MarkChartGroupDeleted(chartGroupId int, tx *pg.Tx) error
- func (impl *ChartGroupReposotoryImpl) Save(model *ChartGroup) (*ChartGroup, error)
- func (impl *ChartGroupReposotoryImpl) Update(model *ChartGroup) (*ChartGroup, error)
- type ClusterInstalledApps
- type ClusterInstalledAppsRepository
- type ClusterInstalledAppsRepositoryImpl
- func (impl ClusterInstalledAppsRepositoryImpl) Delete(model *ClusterInstalledApps) error
- func (impl ClusterInstalledAppsRepositoryImpl) FindAll() ([]ClusterInstalledApps, error)
- func (impl ClusterInstalledAppsRepositoryImpl) FindByClusterId(clusterId int) ([]*ClusterInstalledApps, error)
- func (impl ClusterInstalledAppsRepositoryImpl) FindByClusterIds(clusterIds []int) ([]*ClusterInstalledApps, error)
- func (impl ClusterInstalledAppsRepositoryImpl) Save(model *ClusterInstalledApps, tx *pg.Tx) error
- func (impl ClusterInstalledAppsRepositoryImpl) Update(model *ClusterInstalledApps) error
- type GitOpsAppDetails
- type InstallAppDeleteRequest
- type InstalledAppAndEnvDetails
- type InstalledAppRepository
- type InstalledAppRepositoryImpl
- func (impl InstalledAppRepositoryImpl) CreateInstalledApp(model *InstalledApps, tx *pg.Tx) (*InstalledApps, error)
- func (impl InstalledAppRepositoryImpl) CreateInstalledAppVersion(model *InstalledAppVersions, tx *pg.Tx) (*InstalledAppVersions, error)
- func (impl InstalledAppRepositoryImpl) DeleteInstalledApp(model *InstalledApps) (*InstalledApps, error)
- func (impl InstalledAppRepositoryImpl) DeleteInstalledAppVersion(model *InstalledAppVersions) (*InstalledAppVersions, error)
- func (impl InstalledAppRepositoryImpl) FetchNotes(installedAppId int) (*InstalledApps, error)
- func (impl InstalledAppRepositoryImpl) GetActiveInstalledAppVersionByInstalledAppId(installedAppId int) (*InstalledAppVersions, error)
- func (impl InstalledAppRepositoryImpl) GetAllGitOpsAppNameAndInstalledAppMapping() ([]*GitOpsAppDetails, error)
- func (impl InstalledAppRepositoryImpl) GetAllGitOpsDeploymentAppName() ([]string, error)
- func (impl InstalledAppRepositoryImpl) GetAllInstalledApps(filter *appStoreBean.AppStoreFilter) ([]InstalledAppsWithChartDetails, error)
- func (impl InstalledAppRepositoryImpl) GetAllInstalledAppsByChartRepoId(chartRepoId int) ([]InstalledAppAndEnvDetails, error)
- func (impl InstalledAppRepositoryImpl) GetAllIntalledAppsByAppStoreId(appStoreId int) ([]InstalledAppAndEnvDetails, error)
- func (impl InstalledAppRepositoryImpl) GetAppAndEnvDetailsForDeploymentAppTypeInstalledApps(deploymentAppType string, clusterIds []int) ([]*InstalledApps, error)
- func (impl InstalledAppRepositoryImpl) GetArgoPipelinesHavingLatestTriggerStuckInNonTerminalStatusesForAppStore(getPipelineDeployedBeforeMinutes int, getPipelineDeployedWithinHours int) ([]*InstalledAppVersions, error)
- func (impl InstalledAppRepositoryImpl) GetArgoPipelinesHavingTriggersStuckInLastPossibleNonTerminalTimelinesForAppStore(pendingSinceSeconds int, timeForDegradation int) ([]*InstalledAppVersions, error)
- func (impl InstalledAppRepositoryImpl) GetClusterComponentByClusterId(clusterId int) ([]*InstalledApps, error)
- func (impl InstalledAppRepositoryImpl) GetClusterComponentByClusterIds(clusterIds []int) ([]*InstalledApps, error)
- func (impl *InstalledAppRepositoryImpl) GetConnection() (dbConnection *pg.DB)
- func (impl InstalledAppRepositoryImpl) GetDeploymentSuccessfulStatusCountForTelemetry() (int, error)
- func (impl InstalledAppRepositoryImpl) GetGitOpsInstalledAppsWhereArgoAppDeletedIsTrue(installedAppId int, envId int) (InstalledApps, error)
- func (impl InstalledAppRepositoryImpl) GetInstalledApp(id int) (*InstalledApps, error)
- func (impl InstalledAppRepositoryImpl) GetInstalledAppByAppId(appId int) (InstalledApps, error)
- func (impl InstalledAppRepositoryImpl) GetInstalledAppByGitHash(gitHash string) (InstallAppDeleteRequest, error)
- func (impl InstalledAppRepositoryImpl) GetInstalledAppByInstalledAppVersionId(installedAppVersionId int) (InstalledApps, error)
- func (impl InstalledAppRepositoryImpl) GetInstalledAppVersion(id int) (*InstalledAppVersions, error)
- func (impl InstalledAppRepositoryImpl) GetInstalledAppVersionAny(id int) (*InstalledAppVersions, error)
- func (impl InstalledAppRepositoryImpl) GetInstalledAppVersionByAppIdAndEnvId(appId int, envId int) (*InstalledAppVersions, error)
- func (impl InstalledAppRepositoryImpl) GetInstalledAppVersionByAppStoreId(appStoreId int) ([]*InstalledAppVersions, error)
- func (impl InstalledAppRepositoryImpl) GetInstalledAppVersionByClusterIds(clusterIds []int) ([]*InstalledAppVersions, error)
- func (impl InstalledAppRepositoryImpl) GetInstalledAppVersionByClusterIdsV2(clusterIds []int) ([]*InstalledAppVersions, error)
- func (impl InstalledAppRepositoryImpl) GetInstalledAppVersionByInstalledAppId(installedAppId int) ([]*InstalledAppVersions, error)
- func (impl InstalledAppRepositoryImpl) GetInstalledAppVersionByInstalledAppIdAndEnvId(installedAppId int, envId int) (*InstalledAppVersions, error)
- func (impl InstalledAppRepositoryImpl) GetInstalledAppVersionByInstalledAppIdMeta(installedAppId int) ([]*InstalledAppVersions, error)
- func (impl InstalledAppRepositoryImpl) GetInstalledApplicationByClusterIdAndNamespaceAndAppName(clusterId int, namespace string, appName string) (*InstalledApps, error)
- func (impl InstalledAppRepositoryImpl) GetLatestInstalledAppVersionByGitHash(gitHash string) (*InstalledAppVersions, error)
- func (impl InstalledAppRepositoryImpl) UpdateInstalledApp(model *InstalledApps, tx *pg.Tx) (*InstalledApps, error)
- func (impl InstalledAppRepositoryImpl) UpdateInstalledAppVersion(model *InstalledAppVersions, tx *pg.Tx) (*InstalledAppVersions, error)
- type InstalledAppVersionHistory
- type InstalledAppVersionHistoryRepository
- type InstalledAppVersionHistoryRepositoryImpl
- func (impl InstalledAppVersionHistoryRepositoryImpl) CreateInstalledAppVersionHistory(model *InstalledAppVersionHistory, tx *pg.Tx) (*InstalledAppVersionHistory, error)
- func (impl InstalledAppVersionHistoryRepositoryImpl) FindPreviousInstalledAppVersionHistoryByStatus(installedAppVersionId int, installedAppVersionHistoryId int, status []string) ([]*InstalledAppVersionHistory, error)
- func (impl InstalledAppVersionHistoryRepositoryImpl) GetAppIdAndEnvIdWithInstalledAppVersionId(id int) (int, int, error)
- func (impl InstalledAppVersionHistoryRepositoryImpl) GetAppStoreApplicationVersionIdByInstalledAppVersionHistoryId(installedAppVersionHistoryId int) (int, error)
- func (impl InstalledAppVersionHistoryRepositoryImpl) GetConnection() *pg.DB
- func (impl InstalledAppVersionHistoryRepositoryImpl) GetInstalledAppVersionHistory(id int) (*InstalledAppVersionHistory, error)
- func (impl InstalledAppVersionHistoryRepositoryImpl) GetInstalledAppVersionHistoryByVersionId(installAppVersionId int) ([]*InstalledAppVersionHistory, error)
- func (impl InstalledAppVersionHistoryRepositoryImpl) GetLatestInstalledAppVersionHistory(installAppVersionId int) (*InstalledAppVersionHistory, error)
- func (impl InstalledAppVersionHistoryRepositoryImpl) GetLatestInstalledAppVersionHistoryByGitHash(gitHash string) (*InstalledAppVersionHistory, error)
- func (impl InstalledAppVersionHistoryRepositoryImpl) GetLatestInstalledAppVersionHistoryByInstalledAppId(installedAppId int) (*InstalledAppVersionHistory, error)
- func (impl InstalledAppVersionHistoryRepositoryImpl) UpdateInstalledAppVersionHistory(model *InstalledAppVersionHistory, tx *pg.Tx) (*InstalledAppVersionHistory, error)
- func (impl InstalledAppVersionHistoryRepositoryImpl) UpdateInstalledAppVersionHistoryWithTxn(models []*InstalledAppVersionHistory, tx *pg.Tx) error
- type InstalledAppVersions
- type InstalledApps
- type InstalledAppsWithChartDetails
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChartGroup ¶
type ChartGroupDeployment ¶
type ChartGroupDeployment struct {
TableName struct{} `sql:"chart_group_deployment" pg:",discard_unknown_columns"`
Id int `sql:"id,pk"`
ChartGroupId int `sql:"chart_group_id"`
ChartGroupEntryId int `sql:"chart_group_entry_id"`
InstalledAppId int `sql:"installed_app_id"`
GroupInstallationId string `sql:"group_installation_id"`
Deleted bool `sql:"deleted,notnull"`
sql.AuditLog
}
type ChartGroupDeploymentRepository ¶
type ChartGroupDeploymentRepository interface {
Save(tx *pg.Tx, chartGroupDeployment *ChartGroupDeployment) error
FindByChartGroupId(chartGroupId int) ([]*ChartGroupDeployment, error)
Update(model *ChartGroupDeployment, tx *pg.Tx) (*ChartGroupDeployment, error)
FindByInstalledAppId(installedAppId int) (*ChartGroupDeployment, error)
}
type ChartGroupDeploymentRepositoryImpl ¶
type ChartGroupDeploymentRepositoryImpl struct {
Logger *zap.SugaredLogger
// contains filtered or unexported fields
}
func NewChartGroupDeploymentRepositoryImpl ¶
func NewChartGroupDeploymentRepositoryImpl( dbConnection *pg.DB, Logger *zap.SugaredLogger) *ChartGroupDeploymentRepositoryImpl
func (*ChartGroupDeploymentRepositoryImpl) FindByChartGroupId ¶
func (impl *ChartGroupDeploymentRepositoryImpl) FindByChartGroupId(chartGroupId int) ([]*ChartGroupDeployment, error)
func (*ChartGroupDeploymentRepositoryImpl) FindByInstalledAppId ¶
func (impl *ChartGroupDeploymentRepositoryImpl) FindByInstalledAppId(installedAppId int) (*ChartGroupDeployment, error)
func (*ChartGroupDeploymentRepositoryImpl) Save ¶
func (impl *ChartGroupDeploymentRepositoryImpl) Save(tx *pg.Tx, chartGroupDeployment *ChartGroupDeployment) error
func (*ChartGroupDeploymentRepositoryImpl) Update ¶
func (impl *ChartGroupDeploymentRepositoryImpl) Update(model *ChartGroupDeployment, tx *pg.Tx) (*ChartGroupDeployment, error)
type ChartGroupEntriesRepository ¶
type ChartGroupEntriesRepository interface {
Save(model *ChartGroupEntry) (*ChartGroupEntry, error)
SaveAndUpdateInTransaction(saveEntry []*ChartGroupEntry, updateEntry []*ChartGroupEntry) ([]*ChartGroupEntry, error)
FindEntriesWithChartMetaByChartGroupId(chartGroupId []int) ([]*ChartGroupEntry, error)
MarkChartGroupEntriesDeleted(chartGroupId []int, tx *pg.Tx) ([]*ChartGroupEntry, error)
}
type ChartGroupEntriesRepositoryImpl ¶
type ChartGroupEntriesRepositoryImpl struct {
Logger *zap.SugaredLogger
// contains filtered or unexported fields
}
func NewChartGroupEntriesRepositoryImpl ¶
func NewChartGroupEntriesRepositoryImpl(dbConnection *pg.DB, Logger *zap.SugaredLogger) *ChartGroupEntriesRepositoryImpl
func (*ChartGroupEntriesRepositoryImpl) FindEntriesWithChartMetaByChartGroupId ¶
func (impl *ChartGroupEntriesRepositoryImpl) FindEntriesWithChartMetaByChartGroupId(chartGroupId []int) ([]*ChartGroupEntry, error)
func (*ChartGroupEntriesRepositoryImpl) MarkChartGroupEntriesDeleted ¶
func (impl *ChartGroupEntriesRepositoryImpl) MarkChartGroupEntriesDeleted(chartGroupId []int, tx *pg.Tx) ([]*ChartGroupEntry, error)
func (*ChartGroupEntriesRepositoryImpl) Save ¶
func (impl *ChartGroupEntriesRepositoryImpl) Save(model *ChartGroupEntry) (*ChartGroupEntry, error)
func (*ChartGroupEntriesRepositoryImpl) SaveAndUpdateInTransaction ¶
func (impl *ChartGroupEntriesRepositoryImpl) SaveAndUpdateInTransaction(saveEntry []*ChartGroupEntry, updateEntry []*ChartGroupEntry) ([]*ChartGroupEntry, error)
type ChartGroupEntry ¶
type ChartGroupEntry struct {
TableName struct{} `sql:"chart_group_entry" pg:",discard_unknown_columns"`
Id int `sql:"id,pk"`
AppStoreValuesVersionId int `sql:"app_store_values_version_id"` //AppStoreVersionValuesId
AppStoreApplicationVersionId int `sql:"app_store_application_version_id"` //AppStoreApplicationVersionId
ChartGroupId int `sql:"chart_group_id"`
Deleted bool `sql:"deleted,notnull"`
sql.AuditLog
AppStoreApplicationVersion *appStoreDiscoverRepository.AppStoreApplicationVersion
AppStoreValuesVersion *appStoreValuesRepository.AppStoreVersionValues
}
type ChartGroupReposotory ¶
type ChartGroupReposotory interface {
Save(model *ChartGroup) (*ChartGroup, error)
Update(model *ChartGroup) (*ChartGroup, error)
FindByIdWithEntries(chertGroupId int) (*ChartGroup, error)
FindById(chartGroupId int) (*ChartGroup, error)
GetAll(max int) ([]*ChartGroup, error)
MarkChartGroupDeleted(chartGroupId int, tx *pg.Tx) error
FindByName(chartGroupName string) (bool, error)
}
type ChartGroupReposotoryImpl ¶
type ChartGroupReposotoryImpl struct {
Logger *zap.SugaredLogger
// contains filtered or unexported fields
}
func NewChartGroupReposotoryImpl ¶
func NewChartGroupReposotoryImpl(dbConnection *pg.DB, Logger *zap.SugaredLogger) *ChartGroupReposotoryImpl
func (*ChartGroupReposotoryImpl) FindById ¶
func (impl *ChartGroupReposotoryImpl) FindById(chartGroupId int) (*ChartGroup, error)
func (*ChartGroupReposotoryImpl) FindByIdWithEntries ¶
func (impl *ChartGroupReposotoryImpl) FindByIdWithEntries(chertGroupId int) (*ChartGroup, error)
func (*ChartGroupReposotoryImpl) FindByName ¶ added in v0.6.13
func (impl *ChartGroupReposotoryImpl) FindByName(chartGroupName string) (bool, error)
func (*ChartGroupReposotoryImpl) GetAll ¶
func (impl *ChartGroupReposotoryImpl) GetAll(max int) ([]*ChartGroup, error)
func (*ChartGroupReposotoryImpl) MarkChartGroupDeleted ¶
func (impl *ChartGroupReposotoryImpl) MarkChartGroupDeleted(chartGroupId int, tx *pg.Tx) error
func (*ChartGroupReposotoryImpl) Save ¶
func (impl *ChartGroupReposotoryImpl) Save(model *ChartGroup) (*ChartGroup, error)
func (*ChartGroupReposotoryImpl) Update ¶
func (impl *ChartGroupReposotoryImpl) Update(model *ChartGroup) (*ChartGroup, error)
type ClusterInstalledApps ¶
type ClusterInstalledAppsRepository ¶
type ClusterInstalledAppsRepository interface {
Save(model *ClusterInstalledApps, tx *pg.Tx) error
FindByClusterId(clusterId int) ([]*ClusterInstalledApps, error)
FindByClusterIds(clusterIds []int) ([]*ClusterInstalledApps, error)
FindAll() ([]ClusterInstalledApps, error)
Update(model *ClusterInstalledApps) error
Delete(model *ClusterInstalledApps) error
}
type ClusterInstalledAppsRepositoryImpl ¶
type ClusterInstalledAppsRepositoryImpl struct {
// contains filtered or unexported fields
}
func NewClusterInstalledAppsRepositoryImpl ¶
func NewClusterInstalledAppsRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *ClusterInstalledAppsRepositoryImpl
func (ClusterInstalledAppsRepositoryImpl) Delete ¶
func (impl ClusterInstalledAppsRepositoryImpl) Delete(model *ClusterInstalledApps) error
func (ClusterInstalledAppsRepositoryImpl) FindAll ¶
func (impl ClusterInstalledAppsRepositoryImpl) FindAll() ([]ClusterInstalledApps, error)
func (ClusterInstalledAppsRepositoryImpl) FindByClusterId ¶
func (impl ClusterInstalledAppsRepositoryImpl) FindByClusterId(clusterId int) ([]*ClusterInstalledApps, error)
func (ClusterInstalledAppsRepositoryImpl) FindByClusterIds ¶
func (impl ClusterInstalledAppsRepositoryImpl) FindByClusterIds(clusterIds []int) ([]*ClusterInstalledApps, error)
func (ClusterInstalledAppsRepositoryImpl) Save ¶
func (impl ClusterInstalledAppsRepositoryImpl) Save(model *ClusterInstalledApps, tx *pg.Tx) error
func (ClusterInstalledAppsRepositoryImpl) Update ¶
func (impl ClusterInstalledAppsRepositoryImpl) Update(model *ClusterInstalledApps) error
type GitOpsAppDetails ¶ added in v0.6.17
type InstallAppDeleteRequest ¶ added in v0.6.13
type InstallAppDeleteRequest struct {
InstalledAppId int `json:"installed_app_id,omitempty,notnull"`
AppName string `json:"app_name,omitempty"`
AppId int `json:"app_id,omitempty"`
EnvironmentId int `json:"environment_id,omitempty"`
AppOfferingMode string `json:"app_offering_mode"`
ClusterId int `json:"cluster_id"`
Namespace string `json:"namespace"`
}
type InstalledAppAndEnvDetails ¶
type InstalledAppAndEnvDetails struct {
EnvironmentName string `json:"environment_name"`
EnvironmentId int `json:"environment_id"`
AppName string `json:"app_name"`
AppOfferingMode string `json:"appOfferingMode"`
UpdatedOn time.Time `json:"updated_on"`
EmailId string `json:"email_id"`
InstalledAppVersionId int `json:"installed_app_version_id"`
AppId int `json:"app_id"`
InstalledAppId int `json:"installed_app_id"`
AppStoreApplicationVersionId int `json:"app_store_application_version_id"`
AppStatus string `json:"app_status"`
DeploymentAppType string `json:"-"`
}
type InstalledAppRepository ¶
type InstalledAppRepository interface {
CreateInstalledApp(model *InstalledApps, tx *pg.Tx) (*InstalledApps, error)
CreateInstalledAppVersion(model *InstalledAppVersions, tx *pg.Tx) (*InstalledAppVersions, error)
UpdateInstalledApp(model *InstalledApps, tx *pg.Tx) (*InstalledApps, error)
UpdateInstalledAppVersion(model *InstalledAppVersions, tx *pg.Tx) (*InstalledAppVersions, error)
GetInstalledApp(id int) (*InstalledApps, error)
GetInstalledAppVersion(id int) (*InstalledAppVersions, error)
GetInstalledAppVersionAny(id int) (*InstalledAppVersions, error)
GetAllInstalledApps(filter *appStoreBean.AppStoreFilter) ([]InstalledAppsWithChartDetails, error)
GetAllIntalledAppsByAppStoreId(appStoreId int) ([]InstalledAppAndEnvDetails, error)
GetAllInstalledAppsByChartRepoId(chartRepoId int) ([]InstalledAppAndEnvDetails, error)
GetInstalledAppVersionByInstalledAppIdAndEnvId(installedAppId int, envId int) (*InstalledAppVersions, error)
FetchNotes(installedAppId int) (*InstalledApps, error)
GetInstalledAppVersionByAppStoreId(appStoreId int) ([]*InstalledAppVersions, error)
DeleteInstalledApp(model *InstalledApps) (*InstalledApps, error)
DeleteInstalledAppVersion(model *InstalledAppVersions) (*InstalledAppVersions, error)
GetInstalledAppVersionByInstalledAppId(id int) ([]*InstalledAppVersions, error)
GetConnection() (dbConnection *pg.DB)
GetInstalledAppVersionByInstalledAppIdMeta(installedAppId int) ([]*InstalledAppVersions, error)
GetActiveInstalledAppVersionByInstalledAppId(installedAppId int) (*InstalledAppVersions, error)
GetLatestInstalledAppVersionByGitHash(gitHash string) (*InstalledAppVersions, error)
GetClusterComponentByClusterId(clusterId int) ([]*InstalledApps, error) //unused
GetClusterComponentByClusterIds(clusterIds []int) ([]*InstalledApps, error) //unused
GetInstalledAppVersionByAppIdAndEnvId(appId int, envId int) (*InstalledAppVersions, error)
GetInstalledAppVersionByClusterIds(clusterIds []int) ([]*InstalledAppVersions, error) //unused
GetInstalledAppVersionByClusterIdsV2(clusterIds []int) ([]*InstalledAppVersions, error)
GetInstalledApplicationByClusterIdAndNamespaceAndAppName(clusterId int, namespace string, appName string) (*InstalledApps, error)
GetAppAndEnvDetailsForDeploymentAppTypeInstalledApps(deploymentAppType string, clusterIds []int) ([]*InstalledApps, error)
GetDeploymentSuccessfulStatusCountForTelemetry() (int, error)
GetGitOpsInstalledAppsWhereArgoAppDeletedIsTrue(installedAppId int, envId int) (InstalledApps, error)
GetInstalledAppByGitHash(gitHash string) (InstallAppDeleteRequest, error)
GetInstalledAppByAppId(appId int) (InstalledApps, error)
GetInstalledAppByInstalledAppVersionId(installedAppVersionId int) (InstalledApps, error)
GetAllGitOpsDeploymentAppName() ([]string, error)
GetAllGitOpsAppNameAndInstalledAppMapping() ([]*GitOpsAppDetails, error)
GetArgoPipelinesHavingLatestTriggerStuckInNonTerminalStatusesForAppStore(getPipelineDeployedBeforeMinutes int, getPipelineDeployedWithinHours int) ([]*InstalledAppVersions, error)
GetArgoPipelinesHavingTriggersStuckInLastPossibleNonTerminalTimelinesForAppStore(pendingSinceSeconds int, timeForDegradation int) ([]*InstalledAppVersions, error)
}
type InstalledAppRepositoryImpl ¶
type InstalledAppRepositoryImpl struct {
Logger *zap.SugaredLogger
// contains filtered or unexported fields
}
func NewInstalledAppRepositoryImpl ¶
func NewInstalledAppRepositoryImpl(Logger *zap.SugaredLogger, dbConnection *pg.DB) *InstalledAppRepositoryImpl
func (InstalledAppRepositoryImpl) CreateInstalledApp ¶
func (impl InstalledAppRepositoryImpl) CreateInstalledApp(model *InstalledApps, tx *pg.Tx) (*InstalledApps, error)
func (InstalledAppRepositoryImpl) CreateInstalledAppVersion ¶
func (impl InstalledAppRepositoryImpl) CreateInstalledAppVersion(model *InstalledAppVersions, tx *pg.Tx) (*InstalledAppVersions, error)
func (InstalledAppRepositoryImpl) DeleteInstalledApp ¶
func (impl InstalledAppRepositoryImpl) DeleteInstalledApp(model *InstalledApps) (*InstalledApps, error)
func (InstalledAppRepositoryImpl) DeleteInstalledAppVersion ¶
func (impl InstalledAppRepositoryImpl) DeleteInstalledAppVersion(model *InstalledAppVersions) (*InstalledAppVersions, error)
func (InstalledAppRepositoryImpl) FetchNotes ¶ added in v0.6.15
func (impl InstalledAppRepositoryImpl) FetchNotes(installedAppId int) (*InstalledApps, error)
func (InstalledAppRepositoryImpl) GetActiveInstalledAppVersionByInstalledAppId ¶
func (impl InstalledAppRepositoryImpl) GetActiveInstalledAppVersionByInstalledAppId(installedAppId int) (*InstalledAppVersions, error)
func (InstalledAppRepositoryImpl) GetAllGitOpsAppNameAndInstalledAppMapping ¶ added in v0.6.17
func (impl InstalledAppRepositoryImpl) GetAllGitOpsAppNameAndInstalledAppMapping() ([]*GitOpsAppDetails, error)
func (InstalledAppRepositoryImpl) GetAllGitOpsDeploymentAppName ¶ added in v0.6.17
func (impl InstalledAppRepositoryImpl) GetAllGitOpsDeploymentAppName() ([]string, error)
func (InstalledAppRepositoryImpl) GetAllInstalledApps ¶
func (impl InstalledAppRepositoryImpl) GetAllInstalledApps(filter *appStoreBean.AppStoreFilter) ([]InstalledAppsWithChartDetails, error)
func (InstalledAppRepositoryImpl) GetAllInstalledAppsByChartRepoId ¶
func (impl InstalledAppRepositoryImpl) GetAllInstalledAppsByChartRepoId(chartRepoId int) ([]InstalledAppAndEnvDetails, error)
func (InstalledAppRepositoryImpl) GetAllIntalledAppsByAppStoreId ¶
func (impl InstalledAppRepositoryImpl) GetAllIntalledAppsByAppStoreId(appStoreId int) ([]InstalledAppAndEnvDetails, error)
func (InstalledAppRepositoryImpl) GetAppAndEnvDetailsForDeploymentAppTypeInstalledApps ¶ added in v0.6.1
func (impl InstalledAppRepositoryImpl) GetAppAndEnvDetailsForDeploymentAppTypeInstalledApps(deploymentAppType string, clusterIds []int) ([]*InstalledApps, error)
func (InstalledAppRepositoryImpl) GetArgoPipelinesHavingLatestTriggerStuckInNonTerminalStatusesForAppStore ¶ added in v0.6.17
func (impl InstalledAppRepositoryImpl) GetArgoPipelinesHavingLatestTriggerStuckInNonTerminalStatusesForAppStore(getPipelineDeployedBeforeMinutes int, getPipelineDeployedWithinHours int) ([]*InstalledAppVersions, error)
func (InstalledAppRepositoryImpl) GetArgoPipelinesHavingTriggersStuckInLastPossibleNonTerminalTimelinesForAppStore ¶ added in v0.6.17
func (impl InstalledAppRepositoryImpl) GetArgoPipelinesHavingTriggersStuckInLastPossibleNonTerminalTimelinesForAppStore(pendingSinceSeconds int, timeForDegradation int) ([]*InstalledAppVersions, error)
func (InstalledAppRepositoryImpl) GetClusterComponentByClusterId ¶
func (impl InstalledAppRepositoryImpl) GetClusterComponentByClusterId(clusterId int) ([]*InstalledApps, error)
func (InstalledAppRepositoryImpl) GetClusterComponentByClusterIds ¶
func (impl InstalledAppRepositoryImpl) GetClusterComponentByClusterIds(clusterIds []int) ([]*InstalledApps, error)
func (*InstalledAppRepositoryImpl) GetConnection ¶
func (impl *InstalledAppRepositoryImpl) GetConnection() (dbConnection *pg.DB)
func (InstalledAppRepositoryImpl) GetDeploymentSuccessfulStatusCountForTelemetry ¶ added in v0.6.7
func (impl InstalledAppRepositoryImpl) GetDeploymentSuccessfulStatusCountForTelemetry() (int, error)
func (InstalledAppRepositoryImpl) GetGitOpsInstalledAppsWhereArgoAppDeletedIsTrue ¶ added in v0.6.13
func (impl InstalledAppRepositoryImpl) GetGitOpsInstalledAppsWhereArgoAppDeletedIsTrue(installedAppId int, envId int) (InstalledApps, error)
func (InstalledAppRepositoryImpl) GetInstalledApp ¶
func (impl InstalledAppRepositoryImpl) GetInstalledApp(id int) (*InstalledApps, error)
func (InstalledAppRepositoryImpl) GetInstalledAppByAppId ¶ added in v0.6.17
func (impl InstalledAppRepositoryImpl) GetInstalledAppByAppId(appId int) (InstalledApps, error)
func (InstalledAppRepositoryImpl) GetInstalledAppByGitHash ¶ added in v0.6.13
func (impl InstalledAppRepositoryImpl) GetInstalledAppByGitHash(gitHash string) (InstallAppDeleteRequest, error)
func (InstalledAppRepositoryImpl) GetInstalledAppByInstalledAppVersionId ¶ added in v0.6.17
func (impl InstalledAppRepositoryImpl) GetInstalledAppByInstalledAppVersionId(installedAppVersionId int) (InstalledApps, error)
func (InstalledAppRepositoryImpl) GetInstalledAppVersion ¶
func (impl InstalledAppRepositoryImpl) GetInstalledAppVersion(id int) (*InstalledAppVersions, error)
func (InstalledAppRepositoryImpl) GetInstalledAppVersionAny ¶
func (impl InstalledAppRepositoryImpl) GetInstalledAppVersionAny(id int) (*InstalledAppVersions, error)
it returns enable and disabled both version
func (InstalledAppRepositoryImpl) GetInstalledAppVersionByAppIdAndEnvId ¶
func (impl InstalledAppRepositoryImpl) GetInstalledAppVersionByAppIdAndEnvId(appId int, envId int) (*InstalledAppVersions, error)
func (InstalledAppRepositoryImpl) GetInstalledAppVersionByAppStoreId ¶
func (impl InstalledAppRepositoryImpl) GetInstalledAppVersionByAppStoreId(appStoreId int) ([]*InstalledAppVersions, error)
func (InstalledAppRepositoryImpl) GetInstalledAppVersionByClusterIds ¶
func (impl InstalledAppRepositoryImpl) GetInstalledAppVersionByClusterIds(clusterIds []int) ([]*InstalledAppVersions, error)
func (InstalledAppRepositoryImpl) GetInstalledAppVersionByClusterIdsV2 ¶
func (impl InstalledAppRepositoryImpl) GetInstalledAppVersionByClusterIdsV2(clusterIds []int) ([]*InstalledAppVersions, error)
func (InstalledAppRepositoryImpl) GetInstalledAppVersionByInstalledAppId ¶
func (impl InstalledAppRepositoryImpl) GetInstalledAppVersionByInstalledAppId(installedAppId int) ([]*InstalledAppVersions, error)
func (InstalledAppRepositoryImpl) GetInstalledAppVersionByInstalledAppIdAndEnvId ¶
func (impl InstalledAppRepositoryImpl) GetInstalledAppVersionByInstalledAppIdAndEnvId(installedAppId int, envId int) (*InstalledAppVersions, error)
func (InstalledAppRepositoryImpl) GetInstalledAppVersionByInstalledAppIdMeta ¶
func (impl InstalledAppRepositoryImpl) GetInstalledAppVersionByInstalledAppIdMeta(installedAppId int) ([]*InstalledAppVersions, error)
func (InstalledAppRepositoryImpl) GetInstalledApplicationByClusterIdAndNamespaceAndAppName ¶
func (impl InstalledAppRepositoryImpl) GetInstalledApplicationByClusterIdAndNamespaceAndAppName(clusterId int, namespace string, appName string) (*InstalledApps, error)
func (InstalledAppRepositoryImpl) GetLatestInstalledAppVersionByGitHash ¶
func (impl InstalledAppRepositoryImpl) GetLatestInstalledAppVersionByGitHash(gitHash string) (*InstalledAppVersions, error)
func (InstalledAppRepositoryImpl) UpdateInstalledApp ¶
func (impl InstalledAppRepositoryImpl) UpdateInstalledApp(model *InstalledApps, tx *pg.Tx) (*InstalledApps, error)
func (InstalledAppRepositoryImpl) UpdateInstalledAppVersion ¶
func (impl InstalledAppRepositoryImpl) UpdateInstalledAppVersion(model *InstalledAppVersions, tx *pg.Tx) (*InstalledAppVersions, error)
type InstalledAppVersionHistory ¶
type InstalledAppVersionHistory struct {
TableName struct{} `sql:"installed_app_version_history" pg:",discard_unknown_columns"`
Id int `sql:"id,pk"`
InstalledAppVersionId int `sql:"installed_app_version_id,notnull"`
ValuesYamlRaw string `sql:"values_yaml_raw"`
Status string `sql:"status"`
GitHash string `sql:"git_hash"`
StartedOn time.Time `sql:"started_on,type:timestamptz"`
FinishedOn time.Time `sql:"finished_on,type:timestamptz"`
sql.AuditLog
}
type InstalledAppVersionHistoryRepository ¶
type InstalledAppVersionHistoryRepository interface {
CreateInstalledAppVersionHistory(model *InstalledAppVersionHistory, tx *pg.Tx) (*InstalledAppVersionHistory, error)
UpdateInstalledAppVersionHistory(model *InstalledAppVersionHistory, tx *pg.Tx) (*InstalledAppVersionHistory, error)
GetInstalledAppVersionHistory(id int) (*InstalledAppVersionHistory, error)
GetInstalledAppVersionHistoryByVersionId(installAppVersionId int) ([]*InstalledAppVersionHistory, error)
GetLatestInstalledAppVersionHistory(installAppVersionId int) (*InstalledAppVersionHistory, error)
GetLatestInstalledAppVersionHistoryByGitHash(gitHash string) (*InstalledAppVersionHistory, error)
GetAppIdAndEnvIdWithInstalledAppVersionId(id int) (int, int, error)
GetLatestInstalledAppVersionHistoryByInstalledAppId(installedAppId int) (*InstalledAppVersionHistory, error)
FindPreviousInstalledAppVersionHistoryByStatus(installedAppVersionId int, installedAppVersionHistoryId int, status []string) ([]*InstalledAppVersionHistory, error)
UpdateInstalledAppVersionHistoryWithTxn(models []*InstalledAppVersionHistory, tx *pg.Tx) error
GetAppStoreApplicationVersionIdByInstalledAppVersionHistoryId(installedAppVersionHistoryId int) (int, error)
GetConnection() *pg.DB
}
type InstalledAppVersionHistoryRepositoryImpl ¶
type InstalledAppVersionHistoryRepositoryImpl struct {
Logger *zap.SugaredLogger
// contains filtered or unexported fields
}
func NewInstalledAppVersionHistoryRepositoryImpl ¶
func NewInstalledAppVersionHistoryRepositoryImpl(Logger *zap.SugaredLogger, dbConnection *pg.DB) *InstalledAppVersionHistoryRepositoryImpl
func (InstalledAppVersionHistoryRepositoryImpl) CreateInstalledAppVersionHistory ¶
func (impl InstalledAppVersionHistoryRepositoryImpl) CreateInstalledAppVersionHistory(model *InstalledAppVersionHistory, tx *pg.Tx) (*InstalledAppVersionHistory, error)
func (InstalledAppVersionHistoryRepositoryImpl) FindPreviousInstalledAppVersionHistoryByStatus ¶ added in v0.6.17
func (impl InstalledAppVersionHistoryRepositoryImpl) FindPreviousInstalledAppVersionHistoryByStatus(installedAppVersionId int, installedAppVersionHistoryId int, status []string) ([]*InstalledAppVersionHistory, error)
func (InstalledAppVersionHistoryRepositoryImpl) GetAppIdAndEnvIdWithInstalledAppVersionId ¶ added in v0.6.13
func (impl InstalledAppVersionHistoryRepositoryImpl) GetAppIdAndEnvIdWithInstalledAppVersionId(id int) (int, int, error)
func (InstalledAppVersionHistoryRepositoryImpl) GetAppStoreApplicationVersionIdByInstalledAppVersionHistoryId ¶ added in v0.6.21
func (impl InstalledAppVersionHistoryRepositoryImpl) GetAppStoreApplicationVersionIdByInstalledAppVersionHistoryId(installedAppVersionHistoryId int) (int, error)
func (InstalledAppVersionHistoryRepositoryImpl) GetConnection ¶ added in v0.6.17
func (impl InstalledAppVersionHistoryRepositoryImpl) GetConnection() *pg.DB
func (InstalledAppVersionHistoryRepositoryImpl) GetInstalledAppVersionHistory ¶
func (impl InstalledAppVersionHistoryRepositoryImpl) GetInstalledAppVersionHistory(id int) (*InstalledAppVersionHistory, error)
func (InstalledAppVersionHistoryRepositoryImpl) GetInstalledAppVersionHistoryByVersionId ¶
func (impl InstalledAppVersionHistoryRepositoryImpl) GetInstalledAppVersionHistoryByVersionId(installAppVersionId int) ([]*InstalledAppVersionHistory, error)
func (InstalledAppVersionHistoryRepositoryImpl) GetLatestInstalledAppVersionHistory ¶
func (impl InstalledAppVersionHistoryRepositoryImpl) GetLatestInstalledAppVersionHistory(installAppVersionId int) (*InstalledAppVersionHistory, error)
func (InstalledAppVersionHistoryRepositoryImpl) GetLatestInstalledAppVersionHistoryByGitHash ¶
func (impl InstalledAppVersionHistoryRepositoryImpl) GetLatestInstalledAppVersionHistoryByGitHash(gitHash string) (*InstalledAppVersionHistory, error)
func (InstalledAppVersionHistoryRepositoryImpl) GetLatestInstalledAppVersionHistoryByInstalledAppId ¶ added in v0.6.17
func (impl InstalledAppVersionHistoryRepositoryImpl) GetLatestInstalledAppVersionHistoryByInstalledAppId(installedAppId int) (*InstalledAppVersionHistory, error)
func (InstalledAppVersionHistoryRepositoryImpl) UpdateInstalledAppVersionHistory ¶
func (impl InstalledAppVersionHistoryRepositoryImpl) UpdateInstalledAppVersionHistory(model *InstalledAppVersionHistory, tx *pg.Tx) (*InstalledAppVersionHistory, error)
func (InstalledAppVersionHistoryRepositoryImpl) UpdateInstalledAppVersionHistoryWithTxn ¶ added in v0.6.17
func (impl InstalledAppVersionHistoryRepositoryImpl) UpdateInstalledAppVersionHistoryWithTxn(models []*InstalledAppVersionHistory, tx *pg.Tx) error
type InstalledAppVersions ¶
type InstalledAppVersions struct {
TableName struct{} `sql:"installed_app_versions" pg:",discard_unknown_columns"`
Id int `sql:"id,pk"`
InstalledAppId int `sql:"installed_app_id,notnull"`
AppStoreApplicationVersionId int `sql:"app_store_application_version_id,notnull"`
ValuesYaml string `sql:"values_yaml_raw"`
Active bool `sql:"active, notnull"`
ReferenceValueId int `sql:"reference_value_id"`
ReferenceValueKind string `sql:"reference_value_kind"`
sql.AuditLog
InstalledApp InstalledApps
AppStoreApplicationVersion appStoreDiscoverRepository.AppStoreApplicationVersion
}
type InstalledApps ¶
type InstalledApps struct {
TableName struct{} `sql:"installed_apps" pg:",discard_unknown_columns"`
Id int `sql:"id,pk"`
AppId int `sql:"app_id,notnull"`
EnvironmentId int `sql:"environment_id,notnull"`
Active bool `sql:"active, notnull"`
GitOpsRepoName string `sql:"git_ops_repo_name"`
DeploymentAppType string `sql:"deployment_app_type"`
Status appStoreBean.AppstoreDeploymentStatus `sql:"status"`
DeploymentAppDeleteRequest bool `sql:"deployment_app_delete_request"`
Notes string `json:"notes"`
App app.App
Environment repository.Environment
sql.AuditLog
}
type InstalledAppsWithChartDetails ¶
type InstalledAppsWithChartDetails struct {
AppStoreApplicationName string `json:"app_store_application_name"`
ChartRepoName string `json:"chart_repo_name"`
DockerArtifactStoreId string `json:"docker_artifact_store_id"`
AppName string `json:"app_name"`
EnvironmentName string `json:"environment_name"`
InstalledAppVersionId int `json:"installed_app_version_id"`
AppStoreApplicationVersionId int `json:"app_store_application_version_id"`
Icon string `json:"icon"`
Readme string `json:"readme"`
CreatedOn time.Time `json:"created_on"`
UpdatedOn time.Time `json:"updated_on"`
Id int `json:"id"`
EnvironmentId int `json:"environment_id"`
Deprecated bool `json:"deprecated"`
ClusterName string `json:"clusterName"`
Namespace string `json:"namespace"`
TeamId int `json:"teamId"`
ClusterId int `json:"clusterId"`
AppOfferingMode string `json:"app_offering_mode"`
AppStatus string `json:"app_status"`
DeploymentAppDeleteRequest bool `json:"deploymentAppDeleteRequest"`
}
Click to show internal directories.
Click to hide internal directories.