restHandler

Documentation

Index

• Constants
• func ExtractErrorType(err error) int
• func ValidateDockerArtifactStoreRequestBean(bean pipeline.DockerArtifactStoreBean) bool
• type AppAutocomplete
• type AppGroupRestHandler
• type AppGroupRestHandlerImpl
  • func NewAppGroupRestHandlerImpl(logger *zap.SugaredLogger, enforcer casbin.Enforcer, ...) *AppGroupRestHandlerImpl
  • func (handler AppGroupRestHandlerImpl) CheckAppGroupPermissions(w http.ResponseWriter, r *http.Request)
  • func (handler AppGroupRestHandlerImpl) CreateAppGroup(w http.ResponseWriter, r *http.Request)
  • func (handler AppGroupRestHandlerImpl) DeleteAppGroup(w http.ResponseWriter, r *http.Request)
  • func (handler AppGroupRestHandlerImpl) GetActiveAppGroupList(w http.ResponseWriter, r *http.Request)
  • func (handler AppGroupRestHandlerImpl) GetApplicationsForAppGroup(w http.ResponseWriter, r *http.Request)
  • func (handler AppGroupRestHandlerImpl) UpdateAppGroup(w http.ResponseWriter, r *http.Request)
• type AppListingRestHandler
• type AppListingRestHandlerImpl
  • func NewAppListingRestHandlerImpl(application application.ServiceClient, appListingService app.AppListingService, ...) *AppListingRestHandlerImpl
  • func (handler AppListingRestHandlerImpl) FetchAllDevtronManagedApps(w http.ResponseWriter, r *http.Request)
  • func (handler AppListingRestHandlerImpl) FetchAppDetails(w http.ResponseWriter, r *http.Request)
  • func (handler AppListingRestHandlerImpl) FetchAppDetailsV2(w http.ResponseWriter, r *http.Request)
  • func (handler AppListingRestHandlerImpl) FetchAppStageStatus(w http.ResponseWriter, r *http.Request)
  • func (handler AppListingRestHandlerImpl) FetchAppTriggerView(w http.ResponseWriter, r *http.Request)
  • func (handler AppListingRestHandlerImpl) FetchAppsByEnvironment(w http.ResponseWriter, r *http.Request)
  • func (handler AppListingRestHandlerImpl) FetchAppsByEnvironmentV1(w http.ResponseWriter, r *http.Request)
  • func (handler AppListingRestHandlerImpl) FetchAppsByEnvironmentV2(w http.ResponseWriter, r *http.Request)
  • func (handler AppListingRestHandlerImpl) FetchAppsByEnvironmentVersioned(w http.ResponseWriter, r *http.Request)
  • func (handler AppListingRestHandlerImpl) FetchJobOverviewCiPipelines(w http.ResponseWriter, r *http.Request)
  • func (handler AppListingRestHandlerImpl) FetchJobs(w http.ResponseWriter, r *http.Request)
  • func (handler AppListingRestHandlerImpl) FetchMinDetailOtherEnvironment(w http.ResponseWriter, r *http.Request)
  • func (handler AppListingRestHandlerImpl) FetchOtherEnvironment(w http.ResponseWriter, r *http.Request)
  • func (handler AppListingRestHandlerImpl) FetchOverviewAppsByEnvironment(w http.ResponseWriter, r *http.Request)
  • func (handler AppListingRestHandlerImpl) FetchResourceTree(w http.ResponseWriter, r *http.Request)
  • func (handler AppListingRestHandlerImpl) GetClusterTeamAndEnvListForAutocomplete(w http.ResponseWriter, r *http.Request)
  • func (handler AppListingRestHandlerImpl) GetHostUrlsByBatch(w http.ResponseWriter, r *http.Request)
  • func (handler AppListingRestHandlerImpl) ManualSyncAcdPipelineDeploymentStatus(w http.ResponseWriter, r *http.Request)
  • func (handler AppListingRestHandlerImpl) RedirectToLinkouts(w http.ResponseWriter, r *http.Request)
• type AppRestHandler
• type AppRestHandlerImpl
  • func NewAppRestHandlerImpl(logger *zap.SugaredLogger, appService app.AppCrudOperationService, ...) *AppRestHandlerImpl
  • func (handler AppRestHandlerImpl) GetAllLabels(w http.ResponseWriter, r *http.Request)
  • func (handler AppRestHandlerImpl) GetAppListByTeamIds(w http.ResponseWriter, r *http.Request)
  • func (handler AppRestHandlerImpl) GetAppMetaInfo(w http.ResponseWriter, r *http.Request)
  • func (handler AppRestHandlerImpl) GetHelmAppMetaInfo(w http.ResponseWriter, r *http.Request)
  • func (handler AppRestHandlerImpl) UpdateApp(w http.ResponseWriter, r *http.Request)
  • func (handler AppRestHandlerImpl) UpdateAppDescription(w http.ResponseWriter, r *http.Request)
  • func (handler AppRestHandlerImpl) UpdateProjectForApps(w http.ResponseWriter, r *http.Request)
• type AppStatus
• type AppWorkflowRestHandler
• type AppWorkflowRestHandlerImpl
  • func NewAppWorkflowRestHandlerImpl(Logger *zap.SugaredLogger, userAuthService user.UserService, ...) *AppWorkflowRestHandlerImpl
  • func (handler AppWorkflowRestHandlerImpl) CreateAppWorkflow(w http.ResponseWriter, r *http.Request)
  • func (handler AppWorkflowRestHandlerImpl) DeleteAppWorkflow(w http.ResponseWriter, r *http.Request)
  • func (impl AppWorkflowRestHandlerImpl) FindAllWorkflows(w http.ResponseWriter, r *http.Request)
  • func (impl AppWorkflowRestHandlerImpl) FindAppWorkflow(w http.ResponseWriter, r *http.Request)
  • func (impl AppWorkflowRestHandlerImpl) FindAppWorkflowByEnvironment(w http.ResponseWriter, r *http.Request)
  • func (handler *AppWorkflowRestHandlerImpl) GetWorkflowsViewData(w http.ResponseWriter, r *http.Request)
• type ArgoApplicationRestHandler
• type ArgoApplicationRestHandlerImpl
  • func NewArgoApplicationRestHandlerImpl(client application.ServiceClient, pump connector.Pump, ...) *ArgoApplicationRestHandlerImpl
  • func (impl ArgoApplicationRestHandlerImpl) DeleteResource(w http.ResponseWriter, r *http.Request)
  • func (impl ArgoApplicationRestHandlerImpl) Get(w http.ResponseWriter, r *http.Request)
  • func (impl ArgoApplicationRestHandlerImpl) GetManifests(w http.ResponseWriter, r *http.Request)
  • func (impl ArgoApplicationRestHandlerImpl) GetPodLogs(w http.ResponseWriter, r *http.Request)
  • func (impl ArgoApplicationRestHandlerImpl) GetResource(w http.ResponseWriter, r *http.Request)
  • func (impl ArgoApplicationRestHandlerImpl) GetResourceTree(w http.ResponseWriter, r *http.Request)
  • func (impl ArgoApplicationRestHandlerImpl) GetServiceLink(w http.ResponseWriter, r *http.Request)
  • func (impl ArgoApplicationRestHandlerImpl) GetTerminalSession(w http.ResponseWriter, r *http.Request)
  • func (impl ArgoApplicationRestHandlerImpl) List(w http.ResponseWriter, r *http.Request)
  • func (impl ArgoApplicationRestHandlerImpl) ListResourceEvents(w http.ResponseWriter, r *http.Request)
  • func (impl ArgoApplicationRestHandlerImpl) ManagedResources(w http.ResponseWriter, r *http.Request)
  • func (impl ArgoApplicationRestHandlerImpl) PatchResource(w http.ResponseWriter, r *http.Request)
  • func (impl ArgoApplicationRestHandlerImpl) Rollback(w http.ResponseWriter, r *http.Request)
  • func (impl ArgoApplicationRestHandlerImpl) TerminateOperation(w http.ResponseWriter, r *http.Request)
  • func (impl ArgoApplicationRestHandlerImpl) Watch(w http.ResponseWriter, r *http.Request)
• type AttributesRestHandler
• type AttributesRestHandlerImpl
  • func NewAttributesRestHandlerImpl(logger *zap.SugaredLogger, enforcer casbin.Enforcer, ...) *AttributesRestHandlerImpl
  • func (handler AttributesRestHandlerImpl) AddAttributes(w http.ResponseWriter, r *http.Request)
  • func (handler AttributesRestHandlerImpl) AddDeploymentEnforcementConfig(w http.ResponseWriter, r *http.Request)
  • func (handler AttributesRestHandlerImpl) GetAttributesActiveList(w http.ResponseWriter, r *http.Request)
  • func (handler AttributesRestHandlerImpl) GetAttributesById(w http.ResponseWriter, r *http.Request)
  • func (handler AttributesRestHandlerImpl) GetAttributesByKey(w http.ResponseWriter, r *http.Request)
  • func (handler AttributesRestHandlerImpl) UpdateAttributes(w http.ResponseWriter, r *http.Request)
• type BatchOperationRestHandler
• type BatchOperationRestHandlerImpl
  • func NewBatchOperationRestHandlerImpl(userAuthService user.UserService, enforcer casbin.Enforcer, ...) *BatchOperationRestHandlerImpl
  • func (handler BatchOperationRestHandlerImpl) Operate(w http.ResponseWriter, r *http.Request)
• type BulkUpdateRestHandler
• type BulkUpdateRestHandlerImpl
  • func NewBulkUpdateRestHandlerImpl(pipelineBuilder pipeline.PipelineBuilder, logger *zap.SugaredLogger, ...) *BulkUpdateRestHandlerImpl
  • func (handler BulkUpdateRestHandlerImpl) BulkBuildTrigger(w http.ResponseWriter, r *http.Request)
  • func (handler BulkUpdateRestHandlerImpl) BulkDeploy(w http.ResponseWriter, r *http.Request)
  • func (handler BulkUpdateRestHandlerImpl) BulkHibernate(w http.ResponseWriter, r *http.Request)
  • func (handler BulkUpdateRestHandlerImpl) BulkUnHibernate(w http.ResponseWriter, r *http.Request)
  • func (handler BulkUpdateRestHandlerImpl) BulkUpdate(w http.ResponseWriter, r *http.Request)
  • func (handler BulkUpdateRestHandlerImpl) CheckAuthForBulkUpdate(AppId int, EnvId int, AppName string, rbacObjects map[int]string, token string) bool
  • func (handler BulkUpdateRestHandlerImpl) CheckAuthForImpactedObjects(AppId int, EnvId int, appResourceObjects map[int]string, ...) bool
  • func (handler BulkUpdateRestHandlerImpl) FindBulkUpdateReadme(w http.ResponseWriter, r *http.Request)
  • func (handler BulkUpdateRestHandlerImpl) GetImpactedAppsName(w http.ResponseWriter, r *http.Request)
  • func (handler BulkUpdateRestHandlerImpl) HandleCdPipelineBulkAction(w http.ResponseWriter, r *http.Request)
• type CDRestHandler
• type CDRestHandlerImpl
  • func NewCDRestHandlerImpl(logger *zap.SugaredLogger, resourceService ArgoUtil.ResourceService) *CDRestHandlerImpl
  • func (handler CDRestHandlerImpl) FetchPodContainerLogs(w http.ResponseWriter, r *http.Request)
  • func (handler CDRestHandlerImpl) FetchResourceTree(w http.ResponseWriter, r *http.Request)
• type ChannelDto
• type ChannelResponseDTO
• type ChartGroupRestHandler
• type ChartGroupRestHandlerImpl
  • func NewChartGroupRestHandlerImpl(ChartGroupService service.ChartGroupService, Logger *zap.SugaredLogger, ...) *ChartGroupRestHandlerImpl
  • func (impl *ChartGroupRestHandlerImpl) CreateChartGroup(w http.ResponseWriter, r *http.Request)
  • func (impl *ChartGroupRestHandlerImpl) DeleteChartGroup(w http.ResponseWriter, r *http.Request)
  • func (impl *ChartGroupRestHandlerImpl) GetChartGroupInstallationDetail(w http.ResponseWriter, r *http.Request)
  • func (impl *ChartGroupRestHandlerImpl) GetChartGroupList(w http.ResponseWriter, r *http.Request)
  • func (impl *ChartGroupRestHandlerImpl) GetChartGroupListMin(w http.ResponseWriter, r *http.Request)
  • func (impl *ChartGroupRestHandlerImpl) GetChartGroupWithChartMetaData(w http.ResponseWriter, r *http.Request)
  • func (impl *ChartGroupRestHandlerImpl) SaveChartGroupEntries(w http.ResponseWriter, r *http.Request)
  • func (impl *ChartGroupRestHandlerImpl) UpdateChartGroup(w http.ResponseWriter, r *http.Request)
• type ChartRefRestHandler
• type ChartRefRestHandlerImpl
  • func NewChartRefRestHandlerImpl(chartService chart.ChartService, logger *zap.SugaredLogger) *ChartRefRestHandlerImpl
  • func (handler ChartRefRestHandlerImpl) ChartRefAutocomplete(w http.ResponseWriter, r *http.Request)
  • func (handler ChartRefRestHandlerImpl) ChartRefAutocompleteForApp(w http.ResponseWriter, r *http.Request)
  • func (handler ChartRefRestHandlerImpl) ChartRefAutocompleteForEnv(w http.ResponseWriter, r *http.Request)
• type CommonRestHanlder
• type CommonRestHanlderImpl
  • func NewCommonRestHanlderImpl(logger *zap.SugaredLogger, gitOpsConfigService gitops.GitOpsConfigService, ...) *CommonRestHanlderImpl
  • func (impl CommonRestHanlderImpl) GlobalChecklist(w http.ResponseWriter, r *http.Request)
• type ConfigMapRestHandler
• type ConfigMapRestHandlerImpl
  • func NewConfigMapRestHandlerImpl(pipelineBuilder pipeline.PipelineBuilder, Logger *zap.SugaredLogger, ...) *ConfigMapRestHandlerImpl
  • func (handler ConfigMapRestHandlerImpl) AddEnvironmentToJob(w http.ResponseWriter, r *http.Request)
  • func (handler ConfigMapRestHandlerImpl) CMEnvironmentAddUpdate(w http.ResponseWriter, r *http.Request)
  • func (handler ConfigMapRestHandlerImpl) CMEnvironmentDelete(w http.ResponseWriter, r *http.Request)
  • func (handler ConfigMapRestHandlerImpl) CMEnvironmentFetch(w http.ResponseWriter, r *http.Request)
  • func (handler ConfigMapRestHandlerImpl) CMEnvironmentFetchForEdit(w http.ResponseWriter, r *http.Request)
  • func (handler ConfigMapRestHandlerImpl) CMGlobalAddUpdate(w http.ResponseWriter, r *http.Request)
  • func (handler ConfigMapRestHandlerImpl) CMGlobalDelete(w http.ResponseWriter, r *http.Request)
  • func (handler ConfigMapRestHandlerImpl) CMGlobalFetch(w http.ResponseWriter, r *http.Request)
  • func (handler ConfigMapRestHandlerImpl) CMGlobalFetchForEdit(w http.ResponseWriter, r *http.Request)
  • func (handler ConfigMapRestHandlerImpl) CSEnvironmentAddUpdate(w http.ResponseWriter, r *http.Request)
  • func (handler ConfigMapRestHandlerImpl) CSEnvironmentDelete(w http.ResponseWriter, r *http.Request)
  • func (handler ConfigMapRestHandlerImpl) CSEnvironmentFetch(w http.ResponseWriter, r *http.Request)
  • func (handler ConfigMapRestHandlerImpl) CSEnvironmentFetchForEdit(w http.ResponseWriter, r *http.Request)
  • func (handler ConfigMapRestHandlerImpl) CSGlobalAddUpdate(w http.ResponseWriter, r *http.Request)
  • func (handler ConfigMapRestHandlerImpl) CSGlobalDelete(w http.ResponseWriter, r *http.Request)
  • func (handler ConfigMapRestHandlerImpl) CSGlobalFetch(w http.ResponseWriter, r *http.Request)
  • func (handler ConfigMapRestHandlerImpl) CSGlobalFetchForEdit(w http.ResponseWriter, r *http.Request)
  • func (handler ConfigMapRestHandlerImpl) ConfigSecretBulkPatch(w http.ResponseWriter, r *http.Request)
  • func (handler ConfigMapRestHandlerImpl) GetEnvironmentsForJob(w http.ResponseWriter, r *http.Request)
  • func (handler ConfigMapRestHandlerImpl) RemoveEnvironmentFromJob(w http.ResponseWriter, r *http.Request)
• type CoreAppRestHandler
• type CoreAppRestHandlerImpl
  • func NewCoreAppRestHandlerImpl(logger *zap.SugaredLogger, userAuthService user.UserService, ...) *CoreAppRestHandlerImpl
  • func (handler CoreAppRestHandlerImpl) CreateApp(w http.ResponseWriter, r *http.Request)
  • func (handler CoreAppRestHandlerImpl) CreateAppWorkflow(w http.ResponseWriter, r *http.Request)
  • func (handler CoreAppRestHandlerImpl) GetAppAllDetail(w http.ResponseWriter, r *http.Request)
  • func (handler CoreAppRestHandlerImpl) GetAppWorkflow(w http.ResponseWriter, r *http.Request)
  • func (handler CoreAppRestHandlerImpl) GetAppWorkflowAndOverridesSample(w http.ResponseWriter, r *http.Request)
  • func (handler CoreAppRestHandlerImpl) ValidateAppWorkflowRequest(createAppWorkflowRequest *appBean.AppWorkflowCloneDto, token string) (error, int)
• type DeploymentGroupRestHandler
• type DeploymentGroupRestHandlerImpl
  • func NewDeploymentGroupRestHandlerImpl(deploymentGroupService deploymentGroup.DeploymentGroupService, ...) *DeploymentGroupRestHandlerImpl
  • func (impl *DeploymentGroupRestHandlerImpl) CreateDeploymentGroup(w http.ResponseWriter, r *http.Request)
  • func (impl *DeploymentGroupRestHandlerImpl) DeleteDeploymentGroup(w http.ResponseWriter, r *http.Request)
  • func (impl *DeploymentGroupRestHandlerImpl) FetchAllDeploymentGroups(w http.ResponseWriter, r *http.Request)
  • func (impl *DeploymentGroupRestHandlerImpl) FetchEnvApplicationsForDG(w http.ResponseWriter, r *http.Request)
  • func (impl *DeploymentGroupRestHandlerImpl) FetchParentCiForDG(w http.ResponseWriter, r *http.Request)
  • func (impl *DeploymentGroupRestHandlerImpl) GetArtifactsByCiPipeline(w http.ResponseWriter, r *http.Request)
  • func (impl *DeploymentGroupRestHandlerImpl) GetDeploymentGroupById(w http.ResponseWriter, r *http.Request)
  • func (impl *DeploymentGroupRestHandlerImpl) TriggerReleaseForDeploymentGroup(w http.ResponseWriter, r *http.Request)
  • func (impl *DeploymentGroupRestHandlerImpl) UpdateDeploymentGroup(w http.ResponseWriter, r *http.Request)
• type DockerRegRestHandler
• type DockerRegRestHandlerExtendedImpl
  • func NewDockerRegRestHandlerExtendedImpl(dockerRegistryConfig pipeline.DockerRegistryConfig, logger *zap.SugaredLogger, ...) *DockerRegRestHandlerExtendedImpl
  • func (impl DockerRegRestHandlerExtendedImpl) DeleteDockerRegistryConfig(w http.ResponseWriter, r *http.Request)
  • func (impl DockerRegRestHandlerExtendedImpl) FetchAllDockerAccounts(w http.ResponseWriter, r *http.Request)
  • func (impl DockerRegRestHandlerExtendedImpl) FetchOneDockerAccounts(w http.ResponseWriter, r *http.Request)
• type DockerRegRestHandlerImpl
  • func NewDockerRegRestHandlerImpl(dockerRegistryConfig pipeline.DockerRegistryConfig, logger *zap.SugaredLogger, ...) *DockerRegRestHandlerImpl
  • func (impl DockerRegRestHandlerImpl) DeleteDockerRegistryConfig(w http.ResponseWriter, r *http.Request)
  • func (impl DockerRegRestHandlerImpl) FetchAllDockerAccounts(w http.ResponseWriter, r *http.Request)
  • func (impl DockerRegRestHandlerImpl) FetchAllDockerRegistryForAutocomplete(w http.ResponseWriter, r *http.Request)
  • func (impl DockerRegRestHandlerImpl) FetchOneDockerAccounts(w http.ResponseWriter, r *http.Request)
  • func (impl DockerRegRestHandlerImpl) GetDockerArtifactStore(w http.ResponseWriter, r *http.Request)
  • func (impl DockerRegRestHandlerImpl) IsDockerRegConfigured(w http.ResponseWriter, r *http.Request)
  • func (impl DockerRegRestHandlerImpl) SaveDockerRegistryConfig(w http.ResponseWriter, r *http.Request)
  • func (impl DockerRegRestHandlerImpl) UpdateDockerRegistryConfig(w http.ResponseWriter, r *http.Request)
  • func (impl DockerRegRestHandlerImpl) ValidateDockerRegistryConfig(w http.ResponseWriter, r *http.Request)
• type ExternalCiRestHandler
• type ExternalCiRestHandlerImpl
  • func NewExternalCiRestHandlerImpl(logger *zap.SugaredLogger, webhookService pipeline.WebhookService, ...) *ExternalCiRestHandlerImpl
  • func (impl ExternalCiRestHandlerImpl) HandleExternalCiWebhook(w http.ResponseWriter, r *http.Request)
• type GitHostRestHandler
• type GitHostRestHandlerImpl
  • func NewGitHostRestHandlerImpl(logger *zap.SugaredLogger, gitHostConfig pipeline.GitHostConfig, ...) *GitHostRestHandlerImpl
  • func (impl GitHostRestHandlerImpl) CreateGitHost(w http.ResponseWriter, r *http.Request)
  • func (impl GitHostRestHandlerImpl) GetAllWebhookEventConfig(w http.ResponseWriter, r *http.Request)
  • func (impl GitHostRestHandlerImpl) GetGitHostById(w http.ResponseWriter, r *http.Request)
  • func (impl GitHostRestHandlerImpl) GetGitHosts(w http.ResponseWriter, r *http.Request)
  • func (impl GitHostRestHandlerImpl) GetWebhookDataMetaConfig(w http.ResponseWriter, r *http.Request)
  • func (impl GitHostRestHandlerImpl) GetWebhookEventConfig(w http.ResponseWriter, r *http.Request)
• type GitOpsConfigRestHandler
• type GitOpsConfigRestHandlerImpl
  • func NewGitOpsConfigRestHandlerImpl(logger *zap.SugaredLogger, gitOpsConfigService gitops.GitOpsConfigService, ...) *GitOpsConfigRestHandlerImpl
  • func (impl GitOpsConfigRestHandlerImpl) CreateGitOpsConfig(w http.ResponseWriter, r *http.Request)
  • func (impl GitOpsConfigRestHandlerImpl) GetAllGitOpsConfig(w http.ResponseWriter, r *http.Request)
  • func (impl GitOpsConfigRestHandlerImpl) GetGitOpsConfigById(w http.ResponseWriter, r *http.Request)
  • func (impl GitOpsConfigRestHandlerImpl) GetGitOpsConfigByProvider(w http.ResponseWriter, r *http.Request)
  • func (impl GitOpsConfigRestHandlerImpl) GitOpsConfigured(w http.ResponseWriter, r *http.Request)
  • func (impl GitOpsConfigRestHandlerImpl) GitOpsValidator(w http.ResponseWriter, r *http.Request)
  • func (impl GitOpsConfigRestHandlerImpl) UpdateGitOpsConfig(w http.ResponseWriter, r *http.Request)
• type GitProviderRestHandler
• type GitProviderRestHandlerImpl
  • func NewGitProviderRestHandlerImpl(dockerRegistryConfig pipeline.DockerRegistryConfig, logger *zap.SugaredLogger, ...) *GitProviderRestHandlerImpl
  • func (impl GitProviderRestHandlerImpl) DeleteGitRepoConfig(w http.ResponseWriter, r *http.Request)
  • func (impl GitProviderRestHandlerImpl) FetchAllGitProviders(w http.ResponseWriter, r *http.Request)
  • func (impl GitProviderRestHandlerImpl) FetchOneGitProviders(w http.ResponseWriter, r *http.Request)
  • func (impl GitProviderRestHandlerImpl) GetGitProviders(w http.ResponseWriter, r *http.Request)
  • func (impl GitProviderRestHandlerImpl) SaveGitRepoConfig(w http.ResponseWriter, r *http.Request)
  • func (impl GitProviderRestHandlerImpl) UpdateGitRepoConfig(w http.ResponseWriter, r *http.Request)
• type GitWebhookRestHandler
• type GitWebhookRestHandlerImpl
  • func NewGitWebhookRestHandlerImpl(logger *zap.SugaredLogger, gitWebhookService git.GitWebhookService) *GitWebhookRestHandlerImpl
  • func (impl GitWebhookRestHandlerImpl) HandleGitWebhook(w http.ResponseWriter, r *http.Request)
• type GlobalCMCSRestHandler
• type GlobalCMCSRestHandlerImpl
  • func NewGlobalCMCSRestHandlerImpl(logger *zap.SugaredLogger, userAuthService user.UserService, ...) *GlobalCMCSRestHandlerImpl
  • func (handler *GlobalCMCSRestHandlerImpl) CreateGlobalCMCSConfig(w http.ResponseWriter, r *http.Request)
  • func (handler *GlobalCMCSRestHandlerImpl) DeleteByID(w http.ResponseWriter, r *http.Request)
  • func (handler *GlobalCMCSRestHandlerImpl) GetAllGlobalCMCSData(w http.ResponseWriter, r *http.Request)
  • func (handler *GlobalCMCSRestHandlerImpl) GetGlobalCMCSDataByConfigTypeAndName(w http.ResponseWriter, r *http.Request)
  • func (handler *GlobalCMCSRestHandlerImpl) UpdateGlobalCMCSDataById(w http.ResponseWriter, r *http.Request)
• type GlobalPluginRestHandler
• type GlobalPluginRestHandlerImpl
  • func NewGlobalPluginRestHandler(logger *zap.SugaredLogger, globalPluginService plugin.GlobalPluginService, ...) *GlobalPluginRestHandlerImpl
  • func (handler *GlobalPluginRestHandlerImpl) GetAllGlobalVariables(w http.ResponseWriter, r *http.Request)
  • func (handler *GlobalPluginRestHandlerImpl) GetPluginDetailById(w http.ResponseWriter, r *http.Request)
  • func (handler *GlobalPluginRestHandlerImpl) ListAllPlugins(w http.ResponseWriter, r *http.Request)
• type ImageScanRestHandler
• type ImageScanRestHandlerImpl
  • func NewImageScanRestHandlerImpl(logger *zap.SugaredLogger, imageScanService security.ImageScanService, ...) *ImageScanRestHandlerImpl
  • func (impl ImageScanRestHandlerImpl) FetchExecutionDetail(w http.ResponseWriter, r *http.Request)
  • func (impl ImageScanRestHandlerImpl) FetchMinScanResultByAppIdAndEnvId(w http.ResponseWriter, r *http.Request)
  • func (impl ImageScanRestHandlerImpl) ScanExecutionList(w http.ResponseWriter, r *http.Request)
  • func (impl ImageScanRestHandlerImpl) VulnerabilityExposure(w http.ResponseWriter, r *http.Request)
• type JiraRestHandler
• type JiraRestHandlerImpl
  • func NewJiraRestHandlerImpl(jiraService jira.ProjectManagementService, logger *zap.SugaredLogger, ...) *JiraRestHandlerImpl
  • func (impl JiraRestHandlerImpl) SaveAccountConfig(w http.ResponseWriter, r *http.Request)
  • func (impl JiraRestHandlerImpl) UpdateIssueStatus(w http.ResponseWriter, r *http.Request)
• type MetricsRequest
• type MigrateDbRestHandler
• type MigrateDbRestHandlerImpl
  • func NewMigrateDbRestHandlerImpl(dockerRegistryConfig pipeline.DockerRegistryConfig, logger *zap.SugaredLogger, ...) *MigrateDbRestHandlerImpl
  • func (impl MigrateDbRestHandlerImpl) FetchAllDbConfig(w http.ResponseWriter, r *http.Request)
  • func (impl MigrateDbRestHandlerImpl) FetchDbConfigForAutoComp(w http.ResponseWriter, r *http.Request)
  • func (impl MigrateDbRestHandlerImpl) FetchOneDbConfig(w http.ResponseWriter, r *http.Request)
  • func (impl MigrateDbRestHandlerImpl) SaveDbConfig(w http.ResponseWriter, r *http.Request)
  • func (impl MigrateDbRestHandlerImpl) UpdateDbConfig(w http.ResponseWriter, r *http.Request)
• type NotificationRestHandler
• type NotificationRestHandlerImpl
  • func NewNotificationRestHandlerImpl(dockerRegistryConfig pipeline.DockerRegistryConfig, logger *zap.SugaredLogger, ...) *NotificationRestHandlerImpl
  • func (impl NotificationRestHandlerImpl) DeleteNotificationChannelConfig(w http.ResponseWriter, r *http.Request)
  • func (impl NotificationRestHandlerImpl) DeleteNotificationSettings(w http.ResponseWriter, r *http.Request)
  • func (impl NotificationRestHandlerImpl) FindAllNotificationConfig(w http.ResponseWriter, r *http.Request)
  • func (impl NotificationRestHandlerImpl) FindAllNotificationConfigAutocomplete(w http.ResponseWriter, r *http.Request)
  • func (impl NotificationRestHandlerImpl) FindSESConfig(w http.ResponseWriter, r *http.Request)
  • func (impl NotificationRestHandlerImpl) FindSMTPConfig(w http.ResponseWriter, r *http.Request)
  • func (impl NotificationRestHandlerImpl) FindSlackConfig(w http.ResponseWriter, r *http.Request)
  • func (impl NotificationRestHandlerImpl) FindWebhookConfig(w http.ResponseWriter, r *http.Request)
  • func (impl NotificationRestHandlerImpl) GetAllNotificationSettings(w http.ResponseWriter, r *http.Request)
  • func (impl NotificationRestHandlerImpl) GetOptionsForNotificationSettings(w http.ResponseWriter, r *http.Request)
  • func (impl NotificationRestHandlerImpl) GetWebhookVariables(w http.ResponseWriter, r *http.Request)
  • func (impl NotificationRestHandlerImpl) RecipientListingSuggestion(w http.ResponseWriter, r *http.Request)
  • func (impl NotificationRestHandlerImpl) SaveNotificationChannelConfig(w http.ResponseWriter, r *http.Request)
  • func (impl NotificationRestHandlerImpl) SaveNotificationSettings(w http.ResponseWriter, r *http.Request)
  • func (impl NotificationRestHandlerImpl) UpdateNotificationSettings(w http.ResponseWriter, r *http.Request)
• type PProfRestHandler
• type PProfRestHandlerImpl
  • func NewPProfRestHandler(userService user.UserService) *PProfRestHandlerImpl
  • func (p PProfRestHandlerImpl) Allocs(w http.ResponseWriter, r *http.Request)
  • func (p PProfRestHandlerImpl) Block(w http.ResponseWriter, r *http.Request)
  • func (p PProfRestHandlerImpl) Cmdline(w http.ResponseWriter, r *http.Request)
  • func (p PProfRestHandlerImpl) Goroutine(w http.ResponseWriter, r *http.Request)
  • func (p PProfRestHandlerImpl) Heap(w http.ResponseWriter, r *http.Request)
  • func (p PProfRestHandlerImpl) Index(w http.ResponseWriter, r *http.Request)
  • func (p PProfRestHandlerImpl) Mutex(w http.ResponseWriter, r *http.Request)
  • func (p PProfRestHandlerImpl) Profile(w http.ResponseWriter, r *http.Request)
  • func (p PProfRestHandlerImpl) Symbol(w http.ResponseWriter, r *http.Request)
  • func (p PProfRestHandlerImpl) Threadcreate(w http.ResponseWriter, r *http.Request)
  • func (p PProfRestHandlerImpl) Trace(w http.ResponseWriter, r *http.Request)
• type PipelineHistoryRestHandler
• type PipelineHistoryRestHandlerImpl
  • func NewPipelineHistoryRestHandlerImpl(logger *zap.SugaredLogger, userAuthService user.UserService, ...) *PipelineHistoryRestHandlerImpl
  • func (handler *PipelineHistoryRestHandlerImpl) FetchDeployedConfigurationsForWorkflow(w http.ResponseWriter, r *http.Request)
  • func (handler *PipelineHistoryRestHandlerImpl) FetchDeployedHistoryComponentDetail(w http.ResponseWriter, r *http.Request)
  • func (handler *PipelineHistoryRestHandlerImpl) FetchDeployedHistoryComponentList(w http.ResponseWriter, r *http.Request)
  • func (handler *PipelineHistoryRestHandlerImpl) GetAllDeployedConfigurationHistoryForLatestWfrIdForPipeline(w http.ResponseWriter, r *http.Request)
  • func (handler *PipelineHistoryRestHandlerImpl) GetAllDeployedConfigurationHistoryForSpecificWfrIdForPipeline(w http.ResponseWriter, r *http.Request)
• type PipelineStatusTimelineRestHandler
• type PipelineStatusTimelineRestHandlerImpl
  • func NewPipelineStatusTimelineRestHandlerImpl(logger *zap.SugaredLogger, ...) *PipelineStatusTimelineRestHandlerImpl
  • func (handler *PipelineStatusTimelineRestHandlerImpl) FetchTimelines(w http.ResponseWriter, r *http.Request)
• type PipelineTriggerRestHandler
• type PipelineTriggerRestHandlerImpl
  • func NewPipelineRestHandler(appService app.AppService, userAuthService user.UserService, ...) *PipelineTriggerRestHandlerImpl
  • func (handler PipelineTriggerRestHandlerImpl) GetAllLatestDeploymentConfiguration(w http.ResponseWriter, r *http.Request)
  • func (handler PipelineTriggerRestHandlerImpl) OverrideConfig(w http.ResponseWriter, r *http.Request)
  • func (handler PipelineTriggerRestHandlerImpl) ReleaseStatusUpdate(w http.ResponseWriter, r *http.Request)
  • func (handler PipelineTriggerRestHandlerImpl) RotatePods(w http.ResponseWriter, r *http.Request)
  • func (handler PipelineTriggerRestHandlerImpl) StartStopApp(w http.ResponseWriter, r *http.Request)
  • func (handler PipelineTriggerRestHandlerImpl) StartStopDeploymentGroup(w http.ResponseWriter, r *http.Request)
• type PolicyRestHandler
• type PolicyRestHandlerImpl
  • func NewPolicyRestHandlerImpl(logger *zap.SugaredLogger, policyService security.PolicyService, ...) *PolicyRestHandlerImpl
  • func (impl PolicyRestHandlerImpl) GetPolicy(w http.ResponseWriter, r *http.Request)
  • func (impl PolicyRestHandlerImpl) SavePolicy(w http.ResponseWriter, r *http.Request)
  • func (impl PolicyRestHandlerImpl) UpdatePolicy(w http.ResponseWriter, r *http.Request)
  • func (impl PolicyRestHandlerImpl) VerifyImage(w http.ResponseWriter, r *http.Request)
• type PubSubClientRestHandler
• type PubSubClientRestHandlerImpl
  • func NewPubSubClientRestHandlerImpl(pubsubClient *pubsub.PubSubClientServiceImpl, logger *zap.SugaredLogger, ...) *PubSubClientRestHandlerImpl
  • func (impl *PubSubClientRestHandlerImpl) PublishEventsToNats(w http.ResponseWriter, r *http.Request)
• type PublishRequest
• type ReleaseMetricsRestHandler
• type ReleaseMetricsRestHandlerImpl
  • func NewReleaseMetricsRestHandlerImpl(logger *zap.SugaredLogger, enforcer casbin.Enforcer, ...) *ReleaseMetricsRestHandlerImpl
  • func (impl *ReleaseMetricsRestHandlerImpl) GetDeploymentMetrics(w http.ResponseWriter, r *http.Request)
  • func (impl *ReleaseMetricsRestHandlerImpl) ResetDataForAllAppEnvironment(w http.ResponseWriter, r *http.Request)
  • func (impl *ReleaseMetricsRestHandlerImpl) ResetDataForAppEnvironment(w http.ResponseWriter, r *http.Request)
• type TelemetryGenericEvent
• type TelemetryRestHandler
• type TelemetryRestHandlerImpl
  • func NewTelemetryRestHandlerImpl(logger *zap.SugaredLogger, telemetryEventClient telemetry.TelemetryEventClient, ...) *TelemetryRestHandlerImpl
  • func (handler TelemetryRestHandlerImpl) GetTelemetryMetaInfo(w http.ResponseWriter, r *http.Request)
  • func (handler TelemetryRestHandlerImpl) SendSummaryEvent(w http.ResponseWriter, r *http.Request)
  • func (handler TelemetryRestHandlerImpl) SendTelemetryData(w http.ResponseWriter, r *http.Request)
• type TestSuitRestHandler
• type TestSuitRestHandlerImpl
  • func NewTestSuitRestHandlerImpl(logger *zap.SugaredLogger, userService user.UserService, ...) *TestSuitRestHandlerImpl
  • func (impl TestSuitRestHandlerImpl) DetailedTestSuites(w http.ResponseWriter, r *http.Request)
  • func (impl TestSuitRestHandlerImpl) GetAllSuitByID(w http.ResponseWriter, r *http.Request)
  • func (impl TestSuitRestHandlerImpl) GetAllTestCases(w http.ResponseWriter, r *http.Request)
  • func (impl TestSuitRestHandlerImpl) GetTestCaseByID(w http.ResponseWriter, r *http.Request)
  • func (impl TestSuitRestHandlerImpl) GetTestSuites(w http.ResponseWriter, r *http.Request)
  • func (impl TestSuitRestHandlerImpl) HttpGet(url string) (map[string]interface{}, error)
  • func (impl TestSuitRestHandlerImpl) RedirectTriggerForApp(w http.ResponseWriter, r *http.Request)
  • func (impl TestSuitRestHandlerImpl) RedirectTriggerForEnv(w http.ResponseWriter, r *http.Request)
  • func (impl TestSuitRestHandlerImpl) SuitesProxy(w http.ResponseWriter, r *http.Request)
• type TestSuiteBean
• type UserAttributesRestHandler
• type UserAttributesRestHandlerImpl
  • func NewUserAttributesRestHandlerImpl(logger *zap.SugaredLogger, enforcer casbin.Enforcer, ...) *UserAttributesRestHandlerImpl
  • func (handler *UserAttributesRestHandlerImpl) AddUserAttributes(w http.ResponseWriter, r *http.Request)
  • func (handler *UserAttributesRestHandlerImpl) GetUserAttribute(w http.ResponseWriter, r *http.Request)
  • func (handler *UserAttributesRestHandlerImpl) UpdateUserAttributes(w http.ResponseWriter, r *http.Request)
• type WebhookDataMetaConfigResponse
• type WebhookDataRestHandler
• type WebhookDataRestHandlerImpl
  • func NewWebhookDataRestHandlerImpl(logger *zap.SugaredLogger, userAuthService user.UserService, ...) *WebhookDataRestHandlerImpl
  • func (impl WebhookDataRestHandlerImpl) GetWebhookPayloadDataForPipelineMaterialId(w http.ResponseWriter, r *http.Request)
  • func (impl WebhookDataRestHandlerImpl) GetWebhookPayloadFilterDataForPipelineMaterialId(w http.ResponseWriter, r *http.Request)
• type WebhookEventHandler
• type WebhookEventHandlerImpl
  • func NewWebhookEventHandlerImpl(logger *zap.SugaredLogger, gitHostConfig pipeline.GitHostConfig, ...) *WebhookEventHandlerImpl
  • func (impl WebhookEventHandlerImpl) OnWebhookEvent(w http.ResponseWriter, r *http.Request)

Constants

const (
	APP_DELETE_FAILED_RESP              = "App deletion failed, please try deleting from Devtron UI"
	APP_CREATE_SUCCESSFUL_RESP          = "App created successfully."
	APP_WORKFLOW_CREATE_SUCCESSFUL_RESP = "App workflow created successfully."
	WORKFLOW_NAME_EMPTY                 = ""
)

const (
	REG_DELETE_SUCCESS_RESP = "Container Registry deleted successfully."
	OCIScheme               = "oci://"
)

const (
	SLACK_CONFIG_DELETE_SUCCESS_RESP   = "Slack config deleted successfully."
	WEBHOOK_CONFIG_DELETE_SUCCESS_RESP = "Webhook config deleted successfully."
	SES_CONFIG_DELETE_SUCCESS_RESP     = "SES config deleted successfully."
	SMTP_CONFIG_DELETE_SUCCESS_RESP    = "SMTP config deleted successfully."
)

const CHART_GROUP_DELETE_SUCCESS_RESP = "Chart group deleted successfully."

const GIT_ACCOUNT_DELETE_SUCCESS_RESP = "Git account deleted successfully."

Functions

func ExtractErrorType

func ExtractErrorType(err error) int

func ValidateDockerArtifactStoreRequestBean

func ValidateDockerArtifactStoreRequestBean(bean pipeline.DockerArtifactStoreBean) bool

Types

type AppAutocomplete

type AppAutocomplete struct {
	Teams        []team.TeamRequest
	Environments []cluster.EnvironmentBean
	Clusters     []cluster.ClusterBean
}

type AppGroupRestHandler

type AppGroupRestHandler interface {
	GetActiveAppGroupList(w http.ResponseWriter, r *http.Request)
	GetApplicationsForAppGroup(w http.ResponseWriter, r *http.Request)
	CreateAppGroup(w http.ResponseWriter, r *http.Request)
	UpdateAppGroup(w http.ResponseWriter, r *http.Request)
	DeleteAppGroup(w http.ResponseWriter, r *http.Request)
	CheckAppGroupPermissions(w http.ResponseWriter, r *http.Request)
}

type AppGroupRestHandlerImpl

type AppGroupRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewAppGroupRestHandlerImpl

func NewAppGroupRestHandlerImpl(logger *zap.SugaredLogger, enforcer casbin.Enforcer,
	userService user.UserService, appGroupService appGroup.AppGroupService,
	validator *validator.Validate) *AppGroupRestHandlerImpl

func (AppGroupRestHandlerImpl) CheckAppGroupPermissions

func (handler AppGroupRestHandlerImpl) CheckAppGroupPermissions(w http.ResponseWriter, r *http.Request)

func (AppGroupRestHandlerImpl) CreateAppGroup

func (handler AppGroupRestHandlerImpl) CreateAppGroup(w http.ResponseWriter, r *http.Request)

func (AppGroupRestHandlerImpl) DeleteAppGroup

func (handler AppGroupRestHandlerImpl) DeleteAppGroup(w http.ResponseWriter, r *http.Request)

func (AppGroupRestHandlerImpl) GetActiveAppGroupList

func (handler AppGroupRestHandlerImpl) GetActiveAppGroupList(w http.ResponseWriter, r *http.Request)

func (AppGroupRestHandlerImpl) GetApplicationsForAppGroup

func (handler AppGroupRestHandlerImpl) GetApplicationsForAppGroup(w http.ResponseWriter, r *http.Request)

func (AppGroupRestHandlerImpl) UpdateAppGroup

func (handler AppGroupRestHandlerImpl) UpdateAppGroup(w http.ResponseWriter, r *http.Request)

type AppListingRestHandler

type AppListingRestHandler interface {
	FetchAppsByEnvironment(w http.ResponseWriter, r *http.Request)
	FetchAppDetails(w http.ResponseWriter, r *http.Request)
	FetchJobs(w http.ResponseWriter, r *http.Request)
	FetchJobOverviewCiPipelines(w http.ResponseWriter, r *http.Request)
	FetchAppDetailsV2(w http.ResponseWriter, r *http.Request)
	FetchResourceTree(w http.ResponseWriter, r *http.Request)
	FetchAllDevtronManagedApps(w http.ResponseWriter, r *http.Request)
	FetchAppTriggerView(w http.ResponseWriter, r *http.Request)
	FetchAppStageStatus(w http.ResponseWriter, r *http.Request)

	FetchOtherEnvironment(w http.ResponseWriter, r *http.Request)
	FetchMinDetailOtherEnvironment(w http.ResponseWriter, r *http.Request)
	RedirectToLinkouts(w http.ResponseWriter, r *http.Request)
	GetHostUrlsByBatch(w http.ResponseWriter, r *http.Request)

	ManualSyncAcdPipelineDeploymentStatus(w http.ResponseWriter, r *http.Request)
	GetClusterTeamAndEnvListForAutocomplete(w http.ResponseWriter, r *http.Request)
	FetchAppsByEnvironmentV2(w http.ResponseWriter, r *http.Request)
	FetchAppsByEnvironmentV1(w http.ResponseWriter, r *http.Request)
	FetchAppsByEnvironmentVersioned(w http.ResponseWriter, r *http.Request)
	FetchOverviewAppsByEnvironment(w http.ResponseWriter, r *http.Request)
}

type AppListingRestHandlerImpl

type AppListingRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewAppListingRestHandlerImpl

func NewAppListingRestHandlerImpl(application application.ServiceClient,
	appListingService app.AppListingService,
	teamService team.TeamService,
	enforcer casbin.Enforcer,
	pipeline pipeline.PipelineBuilder,
	logger *zap.SugaredLogger, enforcerUtil rbac.EnforcerUtil,
	deploymentGroupService deploymentGroup.DeploymentGroupService, userService user.UserService,
	helmAppClient client.HelmAppClient, clusterService cluster.ClusterService, helmAppService client.HelmAppService,
	argoUserService argo.ArgoUserService, k8sCommonService k8s.K8sCommonService, installedAppService service1.InstalledAppService,
	cdApplicationStatusUpdateHandler cron.CdApplicationStatusUpdateHandler,
	pipelineRepository pipelineConfig.PipelineRepository,
	appStatusService appStatus.AppStatusService, installedAppRepository repository.InstalledAppRepository,
	environmentClusterMappingsService cluster.EnvironmentService,
	genericNoteService genericNotes.GenericNoteService,
	k8sApplicationService application3.K8sApplicationService,
) *AppListingRestHandlerImpl

func (AppListingRestHandlerImpl) FetchAllDevtronManagedApps

func (handler AppListingRestHandlerImpl) FetchAllDevtronManagedApps(w http.ResponseWriter, r *http.Request)

func (AppListingRestHandlerImpl) FetchAppDetails

func (handler AppListingRestHandlerImpl) FetchAppDetails(w http.ResponseWriter, r *http.Request)

func (AppListingRestHandlerImpl) FetchAppDetailsV2

func (handler AppListingRestHandlerImpl) FetchAppDetailsV2(w http.ResponseWriter, r *http.Request)

func (AppListingRestHandlerImpl) FetchAppStageStatus

func (handler AppListingRestHandlerImpl) FetchAppStageStatus(w http.ResponseWriter, r *http.Request)

func (AppListingRestHandlerImpl) FetchAppTriggerView

func (handler AppListingRestHandlerImpl) FetchAppTriggerView(w http.ResponseWriter, r *http.Request)

func (AppListingRestHandlerImpl) FetchAppsByEnvironment

func (handler AppListingRestHandlerImpl) FetchAppsByEnvironment(w http.ResponseWriter, r *http.Request)

func (AppListingRestHandlerImpl) FetchAppsByEnvironmentV1

func (handler AppListingRestHandlerImpl) FetchAppsByEnvironmentV1(w http.ResponseWriter, r *http.Request)

func (AppListingRestHandlerImpl) FetchAppsByEnvironmentV2

func (handler AppListingRestHandlerImpl) FetchAppsByEnvironmentV2(w http.ResponseWriter, r *http.Request)

func (AppListingRestHandlerImpl) FetchAppsByEnvironmentVersioned

func (handler AppListingRestHandlerImpl) FetchAppsByEnvironmentVersioned(w http.ResponseWriter, r *http.Request)

func (AppListingRestHandlerImpl) FetchJobOverviewCiPipelines

func (handler AppListingRestHandlerImpl) FetchJobOverviewCiPipelines(w http.ResponseWriter, r *http.Request)

func (AppListingRestHandlerImpl) FetchJobs

func (handler AppListingRestHandlerImpl) FetchJobs(w http.ResponseWriter, r *http.Request)

func (AppListingRestHandlerImpl) FetchMinDetailOtherEnvironment

func (handler AppListingRestHandlerImpl) FetchMinDetailOtherEnvironment(w http.ResponseWriter, r *http.Request)

func (AppListingRestHandlerImpl) FetchOtherEnvironment

func (handler AppListingRestHandlerImpl) FetchOtherEnvironment(w http.ResponseWriter, r *http.Request)

func (AppListingRestHandlerImpl) FetchOverviewAppsByEnvironment

func (handler AppListingRestHandlerImpl) FetchOverviewAppsByEnvironment(w http.ResponseWriter, r *http.Request)

func (AppListingRestHandlerImpl) FetchResourceTree

func (handler AppListingRestHandlerImpl) FetchResourceTree(w http.ResponseWriter, r *http.Request)

func (AppListingRestHandlerImpl) GetClusterTeamAndEnvListForAutocomplete

func (handler AppListingRestHandlerImpl) GetClusterTeamAndEnvListForAutocomplete(w http.ResponseWriter, r *http.Request)

func (AppListingRestHandlerImpl) GetHostUrlsByBatch

func (handler AppListingRestHandlerImpl) GetHostUrlsByBatch(w http.ResponseWriter, r *http.Request)

func (AppListingRestHandlerImpl) ManualSyncAcdPipelineDeploymentStatus

func (handler AppListingRestHandlerImpl) ManualSyncAcdPipelineDeploymentStatus(w http.ResponseWriter, r *http.Request)

func (AppListingRestHandlerImpl) RedirectToLinkouts

func (handler AppListingRestHandlerImpl) RedirectToLinkouts(w http.ResponseWriter, r *http.Request)

type AppRestHandler

type AppRestHandler interface {
	GetAllLabels(w http.ResponseWriter, r *http.Request)
	GetAppMetaInfo(w http.ResponseWriter, r *http.Request)
	GetHelmAppMetaInfo(w http.ResponseWriter, r *http.Request)
	UpdateApp(w http.ResponseWriter, r *http.Request)
	UpdateProjectForApps(w http.ResponseWriter, r *http.Request)
	GetAppListByTeamIds(w http.ResponseWriter, r *http.Request)
	UpdateAppDescription(w http.ResponseWriter, r *http.Request)
}

type AppRestHandlerImpl

type AppRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewAppRestHandlerImpl

func NewAppRestHandlerImpl(logger *zap.SugaredLogger, appService app.AppCrudOperationService,
	userAuthService user.UserService, validator *validator.Validate, enforcerUtil rbac.EnforcerUtil,
	enforcer casbin.Enforcer, helmAppService client.HelmAppService, enforcerUtilHelm rbac.EnforcerUtilHelm,
	genericNoteService genericNotes.GenericNoteService) *AppRestHandlerImpl

func (AppRestHandlerImpl) GetAllLabels

func (handler AppRestHandlerImpl) GetAllLabels(w http.ResponseWriter, r *http.Request)

func (AppRestHandlerImpl) GetAppListByTeamIds

func (handler AppRestHandlerImpl) GetAppListByTeamIds(w http.ResponseWriter, r *http.Request)

func (AppRestHandlerImpl) GetAppMetaInfo

func (handler AppRestHandlerImpl) GetAppMetaInfo(w http.ResponseWriter, r *http.Request)

func (AppRestHandlerImpl) GetHelmAppMetaInfo

func (handler AppRestHandlerImpl) GetHelmAppMetaInfo(w http.ResponseWriter, r *http.Request)

func (AppRestHandlerImpl) UpdateApp

func (handler AppRestHandlerImpl) UpdateApp(w http.ResponseWriter, r *http.Request)

func (AppRestHandlerImpl) UpdateAppDescription

func (handler AppRestHandlerImpl) UpdateAppDescription(w http.ResponseWriter, r *http.Request)

func (AppRestHandlerImpl) UpdateProjectForApps

func (handler AppRestHandlerImpl) UpdateProjectForApps(w http.ResponseWriter, r *http.Request)

type AppStatus

type AppStatus struct {
	// contains filtered or unexported fields
}

type AppWorkflowRestHandler

type AppWorkflowRestHandler interface {
	CreateAppWorkflow(w http.ResponseWriter, r *http.Request)
	FindAppWorkflow(w http.ResponseWriter, r *http.Request)
	DeleteAppWorkflow(w http.ResponseWriter, r *http.Request)
	FindAllWorkflows(w http.ResponseWriter, r *http.Request)
	FindAppWorkflowByEnvironment(w http.ResponseWriter, r *http.Request)
	GetWorkflowsViewData(w http.ResponseWriter, r *http.Request)
}

type AppWorkflowRestHandlerImpl

type AppWorkflowRestHandlerImpl struct {
	Logger *zap.SugaredLogger
	// contains filtered or unexported fields
}

func NewAppWorkflowRestHandlerImpl

func NewAppWorkflowRestHandlerImpl(Logger *zap.SugaredLogger, userAuthService user.UserService, appWorkflowService appWorkflow.AppWorkflowService,
	teamService team.TeamService, enforcer casbin.Enforcer, pipelineBuilder pipeline.PipelineBuilder,
	appRepository app.AppRepository, enforcerUtil rbac.EnforcerUtil) *AppWorkflowRestHandlerImpl

func (AppWorkflowRestHandlerImpl) CreateAppWorkflow

func (handler AppWorkflowRestHandlerImpl) CreateAppWorkflow(w http.ResponseWriter, r *http.Request)

func (AppWorkflowRestHandlerImpl) DeleteAppWorkflow

func (handler AppWorkflowRestHandlerImpl) DeleteAppWorkflow(w http.ResponseWriter, r *http.Request)

func (AppWorkflowRestHandlerImpl) FindAllWorkflows

func (impl AppWorkflowRestHandlerImpl) FindAllWorkflows(w http.ResponseWriter, r *http.Request)

func (AppWorkflowRestHandlerImpl) FindAppWorkflow

func (impl AppWorkflowRestHandlerImpl) FindAppWorkflow(w http.ResponseWriter, r *http.Request)

func (AppWorkflowRestHandlerImpl) FindAppWorkflowByEnvironment

func (impl AppWorkflowRestHandlerImpl) FindAppWorkflowByEnvironment(w http.ResponseWriter, r *http.Request)

func (*AppWorkflowRestHandlerImpl) GetWorkflowsViewData

func (handler *AppWorkflowRestHandlerImpl) GetWorkflowsViewData(w http.ResponseWriter, r *http.Request)

type ArgoApplicationRestHandler

type ArgoApplicationRestHandler interface {
	GetPodLogs(w http.ResponseWriter, r *http.Request)
	GetResourceTree(w http.ResponseWriter, r *http.Request)
	ListResourceEvents(w http.ResponseWriter, r *http.Request)
	GetResource(w http.ResponseWriter, r *http.Request)
	List(w http.ResponseWriter, r *http.Request)
	Watch(w http.ResponseWriter, r *http.Request)
	ManagedResources(w http.ResponseWriter, r *http.Request)
	Rollback(w http.ResponseWriter, r *http.Request)
	GetManifests(w http.ResponseWriter, r *http.Request)
	Get(w http.ResponseWriter, r *http.Request)

	TerminateOperation(w http.ResponseWriter, r *http.Request)
	PatchResource(w http.ResponseWriter, r *http.Request)
	DeleteResource(w http.ResponseWriter, r *http.Request)

	GetServiceLink(w http.ResponseWriter, r *http.Request)
	GetTerminalSession(w http.ResponseWriter, r *http.Request)
}

type ArgoApplicationRestHandlerImpl

type ArgoApplicationRestHandlerImpl struct {
	K8sResourceHistoryService kubernetesResourceAuditLogs.K8sResourceHistoryService
	// contains filtered or unexported fields
}

func NewArgoApplicationRestHandlerImpl

func NewArgoApplicationRestHandlerImpl(client application.ServiceClient,
	pump connector.Pump,
	enforcer casbin.Enforcer,
	teamService team.TeamService,
	environmentService cluster.EnvironmentService,
	logger *zap.SugaredLogger,
	enforcerUtil rbac.EnforcerUtil,
	terminalSessionHandler terminal.TerminalSessionHandler,
	argoUserService argo.ArgoUserService,
	K8sResourceHistoryService kubernetesResourceAuditLogs.K8sResourceHistoryService,
	userService user.UserService) *ArgoApplicationRestHandlerImpl

func (ArgoApplicationRestHandlerImpl) DeleteResource

func (impl ArgoApplicationRestHandlerImpl) DeleteResource(w http.ResponseWriter, r *http.Request)

func (ArgoApplicationRestHandlerImpl) Get

func (impl ArgoApplicationRestHandlerImpl) Get(w http.ResponseWriter, r *http.Request)

func (ArgoApplicationRestHandlerImpl) GetManifests

func (impl ArgoApplicationRestHandlerImpl) GetManifests(w http.ResponseWriter, r *http.Request)

func (ArgoApplicationRestHandlerImpl) GetPodLogs

func (impl ArgoApplicationRestHandlerImpl) GetPodLogs(w http.ResponseWriter, r *http.Request)

func (ArgoApplicationRestHandlerImpl) GetResource

func (impl ArgoApplicationRestHandlerImpl) GetResource(w http.ResponseWriter, r *http.Request)

func (ArgoApplicationRestHandlerImpl) GetResourceTree

func (impl ArgoApplicationRestHandlerImpl) GetResourceTree(w http.ResponseWriter, r *http.Request)

func (ArgoApplicationRestHandlerImpl) GetServiceLink

func (impl ArgoApplicationRestHandlerImpl) GetServiceLink(w http.ResponseWriter, r *http.Request)

func (ArgoApplicationRestHandlerImpl) GetTerminalSession

func (impl ArgoApplicationRestHandlerImpl) GetTerminalSession(w http.ResponseWriter, r *http.Request)

func (ArgoApplicationRestHandlerImpl) List

func (impl ArgoApplicationRestHandlerImpl) List(w http.ResponseWriter, r *http.Request)

func (ArgoApplicationRestHandlerImpl) ListResourceEvents

func (impl ArgoApplicationRestHandlerImpl) ListResourceEvents(w http.ResponseWriter, r *http.Request)

func (ArgoApplicationRestHandlerImpl) ManagedResources

func (impl ArgoApplicationRestHandlerImpl) ManagedResources(w http.ResponseWriter, r *http.Request)

func (ArgoApplicationRestHandlerImpl) PatchResource

func (impl ArgoApplicationRestHandlerImpl) PatchResource(w http.ResponseWriter, r *http.Request)

func (ArgoApplicationRestHandlerImpl) Rollback

func (impl ArgoApplicationRestHandlerImpl) Rollback(w http.ResponseWriter, r *http.Request)

func (ArgoApplicationRestHandlerImpl) TerminateOperation

func (impl ArgoApplicationRestHandlerImpl) TerminateOperation(w http.ResponseWriter, r *http.Request)

func (ArgoApplicationRestHandlerImpl) Watch

func (impl ArgoApplicationRestHandlerImpl) Watch(w http.ResponseWriter, r *http.Request)

type AttributesRestHandler

type AttributesRestHandler interface {
	AddAttributes(w http.ResponseWriter, r *http.Request)
	UpdateAttributes(w http.ResponseWriter, r *http.Request)
	GetAttributesById(w http.ResponseWriter, r *http.Request)
	GetAttributesActiveList(w http.ResponseWriter, r *http.Request)
	GetAttributesByKey(w http.ResponseWriter, r *http.Request)
	AddDeploymentEnforcementConfig(w http.ResponseWriter, r *http.Request)
}

type AttributesRestHandlerImpl

type AttributesRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewAttributesRestHandlerImpl

func NewAttributesRestHandlerImpl(logger *zap.SugaredLogger, enforcer casbin.Enforcer,
	userService user.UserService, attributesService attributes.AttributesService) *AttributesRestHandlerImpl

func (AttributesRestHandlerImpl) AddAttributes

func (handler AttributesRestHandlerImpl) AddAttributes(w http.ResponseWriter, r *http.Request)

func (AttributesRestHandlerImpl) AddDeploymentEnforcementConfig

func (handler AttributesRestHandlerImpl) AddDeploymentEnforcementConfig(w http.ResponseWriter, r *http.Request)

func (AttributesRestHandlerImpl) GetAttributesActiveList

func (handler AttributesRestHandlerImpl) GetAttributesActiveList(w http.ResponseWriter, r *http.Request)

func (AttributesRestHandlerImpl) GetAttributesById

func (handler AttributesRestHandlerImpl) GetAttributesById(w http.ResponseWriter, r *http.Request)

func (AttributesRestHandlerImpl) GetAttributesByKey

func (handler AttributesRestHandlerImpl) GetAttributesByKey(w http.ResponseWriter, r *http.Request)

func (AttributesRestHandlerImpl) UpdateAttributes

func (handler AttributesRestHandlerImpl) UpdateAttributes(w http.ResponseWriter, r *http.Request)

type BatchOperationRestHandler

type BatchOperationRestHandler interface {
	Operate(w http.ResponseWriter, r *http.Request)
}

type BatchOperationRestHandlerImpl

type BatchOperationRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewBatchOperationRestHandlerImpl

func NewBatchOperationRestHandlerImpl(userAuthService user.UserService, enforcer casbin.Enforcer, workflowAction batch.WorkflowAction,
	teamService team.TeamService, logger *zap.SugaredLogger, enforcerUtil rbac.EnforcerUtil,
	argoUserService argo.ArgoUserService) *BatchOperationRestHandlerImpl

func (BatchOperationRestHandlerImpl) Operate

func (handler BatchOperationRestHandlerImpl) Operate(w http.ResponseWriter, r *http.Request)

type BulkUpdateRestHandler

type BulkUpdateRestHandler interface {
	FindBulkUpdateReadme(w http.ResponseWriter, r *http.Request)
	GetImpactedAppsName(w http.ResponseWriter, r *http.Request)
	BulkUpdate(w http.ResponseWriter, r *http.Request)

	BulkHibernate(w http.ResponseWriter, r *http.Request)
	BulkUnHibernate(w http.ResponseWriter, r *http.Request)
	BulkDeploy(w http.ResponseWriter, r *http.Request)
	BulkBuildTrigger(w http.ResponseWriter, r *http.Request)

	HandleCdPipelineBulkAction(w http.ResponseWriter, r *http.Request)
}

type BulkUpdateRestHandlerImpl

type BulkUpdateRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewBulkUpdateRestHandlerImpl

func NewBulkUpdateRestHandlerImpl(pipelineBuilder pipeline.PipelineBuilder, logger *zap.SugaredLogger,
	bulkUpdateService bulkAction.BulkUpdateService,
	chartService chart.ChartService,
	propertiesConfigService pipeline.PropertiesConfigService,
	dbMigrationService pipeline.DbMigrationService,
	application application.ServiceClient,
	userAuthService user.UserService,
	teamService team.TeamService,
	enforcer casbin.Enforcer,
	ciHandler pipeline.CiHandler,
	validator *validator.Validate,
	gitSensorClient gitSensor.Client,
	ciPipelineRepository pipelineConfig.CiPipelineRepository, pipelineRepository pipelineConfig.PipelineRepository,
	enforcerUtil rbac.EnforcerUtil, envService request.EnvironmentService,
	gitRegistryConfig pipeline.GitRegistryConfig, dockerRegistryConfig pipeline.DockerRegistryConfig,
	cdHandelr pipeline.CdHandler,
	appCloneService appClone.AppCloneService,
	appWorkflowService appWorkflow.AppWorkflowService,
	materialRepository pipelineConfig.MaterialRepository, policyService security2.PolicyService,
	scanResultRepository security.ImageScanResultRepository,
	argoUserService argo.ArgoUserService) *BulkUpdateRestHandlerImpl

func (BulkUpdateRestHandlerImpl) BulkBuildTrigger

func (handler BulkUpdateRestHandlerImpl) BulkBuildTrigger(w http.ResponseWriter, r *http.Request)

func (BulkUpdateRestHandlerImpl) BulkDeploy

func (handler BulkUpdateRestHandlerImpl) BulkDeploy(w http.ResponseWriter, r *http.Request)

func (BulkUpdateRestHandlerImpl) BulkHibernate

func (handler BulkUpdateRestHandlerImpl) BulkHibernate(w http.ResponseWriter, r *http.Request)

func (BulkUpdateRestHandlerImpl) BulkUnHibernate

func (handler BulkUpdateRestHandlerImpl) BulkUnHibernate(w http.ResponseWriter, r *http.Request)

func (BulkUpdateRestHandlerImpl) BulkUpdate

func (handler BulkUpdateRestHandlerImpl) BulkUpdate(w http.ResponseWriter, r *http.Request)

func (BulkUpdateRestHandlerImpl) CheckAuthForBulkUpdate

func (handler BulkUpdateRestHandlerImpl) CheckAuthForBulkUpdate(AppId int, EnvId int, AppName string, rbacObjects map[int]string, token string) bool

func (BulkUpdateRestHandlerImpl) CheckAuthForImpactedObjects

func (handler BulkUpdateRestHandlerImpl) CheckAuthForImpactedObjects(AppId int, EnvId int, appResourceObjects map[int]string, envResourceObjects map[string]string, token string) bool

func (BulkUpdateRestHandlerImpl) FindBulkUpdateReadme

func (handler BulkUpdateRestHandlerImpl) FindBulkUpdateReadme(w http.ResponseWriter, r *http.Request)

func (BulkUpdateRestHandlerImpl) GetImpactedAppsName

func (handler BulkUpdateRestHandlerImpl) GetImpactedAppsName(w http.ResponseWriter, r *http.Request)

func (BulkUpdateRestHandlerImpl) HandleCdPipelineBulkAction

func (handler BulkUpdateRestHandlerImpl) HandleCdPipelineBulkAction(w http.ResponseWriter, r *http.Request)

type CDRestHandler

type CDRestHandler interface {
	FetchResourceTree(w http.ResponseWriter, r *http.Request)

	FetchPodContainerLogs(w http.ResponseWriter, r *http.Request)
}

type CDRestHandlerImpl

type CDRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewCDRestHandlerImpl

func NewCDRestHandlerImpl(logger *zap.SugaredLogger, resourceService ArgoUtil.ResourceService) *CDRestHandlerImpl

func (CDRestHandlerImpl) FetchPodContainerLogs

func (handler CDRestHandlerImpl) FetchPodContainerLogs(w http.ResponseWriter, r *http.Request)

func (CDRestHandlerImpl) FetchResourceTree

func (handler CDRestHandlerImpl) FetchResourceTree(w http.ResponseWriter, r *http.Request)

type ChannelDto

type ChannelDto struct {
	Channel util.Channel `json:"channel" validate:"required"`
}

type ChannelResponseDTO

type ChannelResponseDTO struct {
	SlackConfigs   []*notifier.SlackConfigDto   `json:"slackConfigs"`
	WebhookConfigs []*notifier.WebhookConfigDto `json:"webhookConfigs"`
	SESConfigs     []*notifier.SESConfigDto     `json:"sesConfigs"`
	SMTPConfigs    []*notifier.SMTPConfigDto    `json:"smtpConfigs"`
}

type ChartGroupRestHandler

type ChartGroupRestHandler interface {
	CreateChartGroup(w http.ResponseWriter, r *http.Request)
	UpdateChartGroup(w http.ResponseWriter, r *http.Request)
	SaveChartGroupEntries(w http.ResponseWriter, r *http.Request)
	GetChartGroupWithChartMetaData(w http.ResponseWriter, r *http.Request)
	GetChartGroupList(w http.ResponseWriter, r *http.Request)
	GetChartGroupInstallationDetail(w http.ResponseWriter, r *http.Request)
	GetChartGroupListMin(w http.ResponseWriter, r *http.Request)
	DeleteChartGroup(w http.ResponseWriter, r *http.Request)
}

type ChartGroupRestHandlerImpl

type ChartGroupRestHandlerImpl struct {
	ChartGroupService service.ChartGroupService
	Logger            *zap.SugaredLogger
	// contains filtered or unexported fields
}

func NewChartGroupRestHandlerImpl

func NewChartGroupRestHandlerImpl(ChartGroupService service.ChartGroupService,
	Logger *zap.SugaredLogger, userAuthService user.UserService,
	enforcer casbin.Enforcer, validator *validator.Validate) *ChartGroupRestHandlerImpl

func (*ChartGroupRestHandlerImpl) CreateChartGroup

func (impl *ChartGroupRestHandlerImpl) CreateChartGroup(w http.ResponseWriter, r *http.Request)

func (*ChartGroupRestHandlerImpl) DeleteChartGroup

func (impl *ChartGroupRestHandlerImpl) DeleteChartGroup(w http.ResponseWriter, r *http.Request)

func (*ChartGroupRestHandlerImpl) GetChartGroupInstallationDetail

func (impl *ChartGroupRestHandlerImpl) GetChartGroupInstallationDetail(w http.ResponseWriter, r *http.Request)

func (*ChartGroupRestHandlerImpl) GetChartGroupList

func (impl *ChartGroupRestHandlerImpl) GetChartGroupList(w http.ResponseWriter, r *http.Request)

func (*ChartGroupRestHandlerImpl) GetChartGroupListMin

func (impl *ChartGroupRestHandlerImpl) GetChartGroupListMin(w http.ResponseWriter, r *http.Request)

func (*ChartGroupRestHandlerImpl) GetChartGroupWithChartMetaData

func (impl *ChartGroupRestHandlerImpl) GetChartGroupWithChartMetaData(w http.ResponseWriter, r *http.Request)

func (*ChartGroupRestHandlerImpl) SaveChartGroupEntries

func (impl *ChartGroupRestHandlerImpl) SaveChartGroupEntries(w http.ResponseWriter, r *http.Request)

func (*ChartGroupRestHandlerImpl) UpdateChartGroup

func (impl *ChartGroupRestHandlerImpl) UpdateChartGroup(w http.ResponseWriter, r *http.Request)

type ChartRefRestHandler

type ChartRefRestHandler interface {
	ChartRefAutocomplete(w http.ResponseWriter, r *http.Request)
	ChartRefAutocompleteForApp(w http.ResponseWriter, r *http.Request)
	ChartRefAutocompleteForEnv(w http.ResponseWriter, r *http.Request)
}

type ChartRefRestHandlerImpl

type ChartRefRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewChartRefRestHandlerImpl

func NewChartRefRestHandlerImpl(chartService chart.ChartService, logger *zap.SugaredLogger) *ChartRefRestHandlerImpl

func (ChartRefRestHandlerImpl) ChartRefAutocomplete

func (handler ChartRefRestHandlerImpl) ChartRefAutocomplete(w http.ResponseWriter, r *http.Request)

func (ChartRefRestHandlerImpl) ChartRefAutocompleteForApp

func (handler ChartRefRestHandlerImpl) ChartRefAutocompleteForApp(w http.ResponseWriter, r *http.Request)

func (ChartRefRestHandlerImpl) ChartRefAutocompleteForEnv

func (handler ChartRefRestHandlerImpl) ChartRefAutocompleteForEnv(w http.ResponseWriter, r *http.Request)

type CommonRestHanlder

type CommonRestHanlder interface {
	GlobalChecklist(w http.ResponseWriter, r *http.Request)
}

type CommonRestHanlderImpl

type CommonRestHanlderImpl struct {
	// contains filtered or unexported fields
}

func NewCommonRestHanlderImpl

func NewCommonRestHanlderImpl(
	logger *zap.SugaredLogger,
	gitOpsConfigService gitops.GitOpsConfigService, userAuthService user.UserService,
	validator *validator.Validate, enforcer casbin.Enforcer, commonService commonService.CommonService) *CommonRestHanlderImpl

func (CommonRestHanlderImpl) GlobalChecklist

func (impl CommonRestHanlderImpl) GlobalChecklist(w http.ResponseWriter, r *http.Request)

type ConfigMapRestHandler

type ConfigMapRestHandler interface {
	CMGlobalAddUpdate(w http.ResponseWriter, r *http.Request)
	CMEnvironmentAddUpdate(w http.ResponseWriter, r *http.Request)
	CMGlobalFetch(w http.ResponseWriter, r *http.Request)
	CMEnvironmentFetch(w http.ResponseWriter, r *http.Request)
	CMGlobalFetchForEdit(w http.ResponseWriter, r *http.Request)
	CMEnvironmentFetchForEdit(w http.ResponseWriter, r *http.Request)

	CSGlobalAddUpdate(w http.ResponseWriter, r *http.Request)
	CSEnvironmentAddUpdate(w http.ResponseWriter, r *http.Request)
	CSGlobalFetch(w http.ResponseWriter, r *http.Request)
	CSEnvironmentFetch(w http.ResponseWriter, r *http.Request)

	CMGlobalDelete(w http.ResponseWriter, r *http.Request)
	CMEnvironmentDelete(w http.ResponseWriter, r *http.Request)
	CSGlobalDelete(w http.ResponseWriter, r *http.Request)
	CSEnvironmentDelete(w http.ResponseWriter, r *http.Request)

	CSGlobalFetchForEdit(w http.ResponseWriter, r *http.Request)
	CSEnvironmentFetchForEdit(w http.ResponseWriter, r *http.Request)
	ConfigSecretBulkPatch(w http.ResponseWriter, r *http.Request)

	AddEnvironmentToJob(w http.ResponseWriter, r *http.Request)
	RemoveEnvironmentFromJob(w http.ResponseWriter, r *http.Request)
	GetEnvironmentsForJob(w http.ResponseWriter, r *http.Request)
}

type ConfigMapRestHandlerImpl

type ConfigMapRestHandlerImpl struct {
	Logger *zap.SugaredLogger
	// contains filtered or unexported fields
}

func NewConfigMapRestHandlerImpl

func NewConfigMapRestHandlerImpl(pipelineBuilder pipeline.PipelineBuilder, Logger *zap.SugaredLogger,
	chartService chart.ChartService, userAuthService user.UserService, teamService team.TeamService,
	enforcer casbin.Enforcer, pipelineRepository pipelineConfig.PipelineRepository,
	enforcerUtil rbac.EnforcerUtil, configMapService pipeline.ConfigMapService) *ConfigMapRestHandlerImpl

func (ConfigMapRestHandlerImpl) AddEnvironmentToJob

func (handler ConfigMapRestHandlerImpl) AddEnvironmentToJob(w http.ResponseWriter, r *http.Request)

func (ConfigMapRestHandlerImpl) CMEnvironmentAddUpdate

func (handler ConfigMapRestHandlerImpl) CMEnvironmentAddUpdate(w http.ResponseWriter, r *http.Request)

func (ConfigMapRestHandlerImpl) CMEnvironmentDelete

func (handler ConfigMapRestHandlerImpl) CMEnvironmentDelete(w http.ResponseWriter, r *http.Request)

func (ConfigMapRestHandlerImpl) CMEnvironmentFetch

func (handler ConfigMapRestHandlerImpl) CMEnvironmentFetch(w http.ResponseWriter, r *http.Request)

func (ConfigMapRestHandlerImpl) CMEnvironmentFetchForEdit

func (handler ConfigMapRestHandlerImpl) CMEnvironmentFetchForEdit(w http.ResponseWriter, r *http.Request)

func (ConfigMapRestHandlerImpl) CMGlobalAddUpdate

func (handler ConfigMapRestHandlerImpl) CMGlobalAddUpdate(w http.ResponseWriter, r *http.Request)

func (ConfigMapRestHandlerImpl) CMGlobalDelete

func (handler ConfigMapRestHandlerImpl) CMGlobalDelete(w http.ResponseWriter, r *http.Request)

func (ConfigMapRestHandlerImpl) CMGlobalFetch

func (handler ConfigMapRestHandlerImpl) CMGlobalFetch(w http.ResponseWriter, r *http.Request)

func (ConfigMapRestHandlerImpl) CMGlobalFetchForEdit

func (handler ConfigMapRestHandlerImpl) CMGlobalFetchForEdit(w http.ResponseWriter, r *http.Request)

func (ConfigMapRestHandlerImpl) CSEnvironmentAddUpdate

func (handler ConfigMapRestHandlerImpl) CSEnvironmentAddUpdate(w http.ResponseWriter, r *http.Request)

func (ConfigMapRestHandlerImpl) CSEnvironmentDelete

func (handler ConfigMapRestHandlerImpl) CSEnvironmentDelete(w http.ResponseWriter, r *http.Request)

func (ConfigMapRestHandlerImpl) CSEnvironmentFetch

func (handler ConfigMapRestHandlerImpl) CSEnvironmentFetch(w http.ResponseWriter, r *http.Request)

func (ConfigMapRestHandlerImpl) CSEnvironmentFetchForEdit

func (handler ConfigMapRestHandlerImpl) CSEnvironmentFetchForEdit(w http.ResponseWriter, r *http.Request)

func (ConfigMapRestHandlerImpl) CSGlobalAddUpdate

func (handler ConfigMapRestHandlerImpl) CSGlobalAddUpdate(w http.ResponseWriter, r *http.Request)

func (ConfigMapRestHandlerImpl) CSGlobalDelete

func (handler ConfigMapRestHandlerImpl) CSGlobalDelete(w http.ResponseWriter, r *http.Request)

func (ConfigMapRestHandlerImpl) CSGlobalFetch

func (handler ConfigMapRestHandlerImpl) CSGlobalFetch(w http.ResponseWriter, r *http.Request)

func (ConfigMapRestHandlerImpl) CSGlobalFetchForEdit

func (handler ConfigMapRestHandlerImpl) CSGlobalFetchForEdit(w http.ResponseWriter, r *http.Request)

func (ConfigMapRestHandlerImpl) ConfigSecretBulkPatch

func (handler ConfigMapRestHandlerImpl) ConfigSecretBulkPatch(w http.ResponseWriter, r *http.Request)

func (ConfigMapRestHandlerImpl) GetEnvironmentsForJob

func (handler ConfigMapRestHandlerImpl) GetEnvironmentsForJob(w http.ResponseWriter, r *http.Request)

func (ConfigMapRestHandlerImpl) RemoveEnvironmentFromJob

func (handler ConfigMapRestHandlerImpl) RemoveEnvironmentFromJob(w http.ResponseWriter, r *http.Request)

type CoreAppRestHandler

type CoreAppRestHandler interface {
	GetAppAllDetail(w http.ResponseWriter, r *http.Request)
	CreateApp(w http.ResponseWriter, r *http.Request)
	CreateAppWorkflow(w http.ResponseWriter, r *http.Request)
	GetAppWorkflow(w http.ResponseWriter, r *http.Request)
	GetAppWorkflowAndOverridesSample(w http.ResponseWriter, r *http.Request)
}

type CoreAppRestHandlerImpl

type CoreAppRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewCoreAppRestHandlerImpl

func NewCoreAppRestHandlerImpl(logger *zap.SugaredLogger, userAuthService user.UserService, validator *validator.Validate, enforcerUtil rbac.EnforcerUtil,
	enforcer casbin.Enforcer, appCrudOperationService app.AppCrudOperationService, pipelineBuilder pipeline.PipelineBuilder, gitRegistryService pipeline.GitRegistryConfig,
	chartService chart.ChartService, configMapService pipeline.ConfigMapService, appListingService app.AppListingService,
	propertiesConfigService pipeline.PropertiesConfigService, appWorkflowService appWorkflow.AppWorkflowService,
	materialRepository pipelineConfig.MaterialRepository, gitProviderRepo repository.GitProviderRepository,
	appWorkflowRepository appWorkflow2.AppWorkflowRepository, environmentRepository repository2.EnvironmentRepository, configMapRepository chartConfig.ConfigMapRepository,
	envConfigRepo chartConfig.EnvConfigOverrideRepository, chartRepo chartRepoRepository.ChartRepository, teamService team.TeamService,
	argoUserService argo.ArgoUserService, pipelineStageService pipeline.PipelineStageService, ciPipelineRepository pipelineConfig.CiPipelineRepository) *CoreAppRestHandlerImpl

func (CoreAppRestHandlerImpl) CreateApp

func (handler CoreAppRestHandlerImpl) CreateApp(w http.ResponseWriter, r *http.Request)

func (CoreAppRestHandlerImpl) CreateAppWorkflow

func (handler CoreAppRestHandlerImpl) CreateAppWorkflow(w http.ResponseWriter, r *http.Request)

func (CoreAppRestHandlerImpl) GetAppAllDetail

func (handler CoreAppRestHandlerImpl) GetAppAllDetail(w http.ResponseWriter, r *http.Request)

func (CoreAppRestHandlerImpl) GetAppWorkflow

func (handler CoreAppRestHandlerImpl) GetAppWorkflow(w http.ResponseWriter, r *http.Request)

func (CoreAppRestHandlerImpl) GetAppWorkflowAndOverridesSample

func (handler CoreAppRestHandlerImpl) GetAppWorkflowAndOverridesSample(w http.ResponseWriter, r *http.Request)

func (CoreAppRestHandlerImpl) ValidateAppWorkflowRequest

func (handler CoreAppRestHandlerImpl) ValidateAppWorkflowRequest(createAppWorkflowRequest *appBean.AppWorkflowCloneDto, token string) (error, int)

type DeploymentGroupRestHandler

type DeploymentGroupRestHandler interface {
	CreateDeploymentGroup(w http.ResponseWriter, r *http.Request)
	FetchParentCiForDG(w http.ResponseWriter, r *http.Request)
	FetchEnvApplicationsForDG(w http.ResponseWriter, r *http.Request)
	FetchAllDeploymentGroups(w http.ResponseWriter, r *http.Request)
	DeleteDeploymentGroup(w http.ResponseWriter, r *http.Request)
	TriggerReleaseForDeploymentGroup(w http.ResponseWriter, r *http.Request)
	UpdateDeploymentGroup(w http.ResponseWriter, r *http.Request)
	GetArtifactsByCiPipeline(w http.ResponseWriter, r *http.Request)
	GetDeploymentGroupById(w http.ResponseWriter, r *http.Request)
}

type DeploymentGroupRestHandlerImpl

type DeploymentGroupRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewDeploymentGroupRestHandlerImpl

func NewDeploymentGroupRestHandlerImpl(deploymentGroupService deploymentGroup.DeploymentGroupService, logger *zap.SugaredLogger,
	validator *validator.Validate, enforcer casbin.Enforcer, teamService team.TeamService, userAuthService user.UserService, enforcerUtil rbac.EnforcerUtil) *DeploymentGroupRestHandlerImpl

func (*DeploymentGroupRestHandlerImpl) CreateDeploymentGroup

func (impl *DeploymentGroupRestHandlerImpl) CreateDeploymentGroup(w http.ResponseWriter, r *http.Request)

func (*DeploymentGroupRestHandlerImpl) DeleteDeploymentGroup

func (impl *DeploymentGroupRestHandlerImpl) DeleteDeploymentGroup(w http.ResponseWriter, r *http.Request)

func (*DeploymentGroupRestHandlerImpl) FetchAllDeploymentGroups

func (impl *DeploymentGroupRestHandlerImpl) FetchAllDeploymentGroups(w http.ResponseWriter, r *http.Request)

func (*DeploymentGroupRestHandlerImpl) FetchEnvApplicationsForDG

func (impl *DeploymentGroupRestHandlerImpl) FetchEnvApplicationsForDG(w http.ResponseWriter, r *http.Request)

func (*DeploymentGroupRestHandlerImpl) FetchParentCiForDG

func (impl *DeploymentGroupRestHandlerImpl) FetchParentCiForDG(w http.ResponseWriter, r *http.Request)

func (*DeploymentGroupRestHandlerImpl) GetArtifactsByCiPipeline

func (impl *DeploymentGroupRestHandlerImpl) GetArtifactsByCiPipeline(w http.ResponseWriter, r *http.Request)

func (*DeploymentGroupRestHandlerImpl) GetDeploymentGroupById

func (impl *DeploymentGroupRestHandlerImpl) GetDeploymentGroupById(w http.ResponseWriter, r *http.Request)

func (*DeploymentGroupRestHandlerImpl) TriggerReleaseForDeploymentGroup

func (impl *DeploymentGroupRestHandlerImpl) TriggerReleaseForDeploymentGroup(w http.ResponseWriter, r *http.Request)

func (*DeploymentGroupRestHandlerImpl) UpdateDeploymentGroup

func (impl *DeploymentGroupRestHandlerImpl) UpdateDeploymentGroup(w http.ResponseWriter, r *http.Request)

type DockerRegRestHandler

type DockerRegRestHandler interface {
	SaveDockerRegistryConfig(w http.ResponseWriter, r *http.Request)
	ValidateDockerRegistryConfig(w http.ResponseWriter, r *http.Request)
	GetDockerArtifactStore(w http.ResponseWriter, r *http.Request)
	FetchAllDockerAccounts(w http.ResponseWriter, r *http.Request)
	FetchOneDockerAccounts(w http.ResponseWriter, r *http.Request)
	UpdateDockerRegistryConfig(w http.ResponseWriter, r *http.Request)
	FetchAllDockerRegistryForAutocomplete(w http.ResponseWriter, r *http.Request)
	IsDockerRegConfigured(w http.ResponseWriter, r *http.Request)
	DeleteDockerRegistryConfig(w http.ResponseWriter, r *http.Request)
}

type DockerRegRestHandlerExtendedImpl

type DockerRegRestHandlerExtendedImpl struct {
	*DockerRegRestHandlerImpl
	// contains filtered or unexported fields
}

func NewDockerRegRestHandlerExtendedImpl

func NewDockerRegRestHandlerExtendedImpl(
	dockerRegistryConfig pipeline.DockerRegistryConfig,
	logger *zap.SugaredLogger,
	chartProviderService chartProviderService.ChartProviderService,
	userAuthService user.UserService,
	validator *validator.Validate, enforcer casbin.Enforcer, teamService team.TeamService,
	deleteService deleteService.DeleteService,
	deleteServiceFullMode deleteService.DeleteServiceFullMode) *DockerRegRestHandlerExtendedImpl

func (DockerRegRestHandlerExtendedImpl) DeleteDockerRegistryConfig

func (impl DockerRegRestHandlerExtendedImpl) DeleteDockerRegistryConfig(w http.ResponseWriter, r *http.Request)

func (DockerRegRestHandlerExtendedImpl) FetchAllDockerAccounts

func (impl DockerRegRestHandlerExtendedImpl) FetchAllDockerAccounts(w http.ResponseWriter, r *http.Request)

func (DockerRegRestHandlerExtendedImpl) FetchOneDockerAccounts

func (impl DockerRegRestHandlerExtendedImpl) FetchOneDockerAccounts(w http.ResponseWriter, r *http.Request)

type DockerRegRestHandlerImpl

type DockerRegRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewDockerRegRestHandlerImpl

func NewDockerRegRestHandlerImpl(
	dockerRegistryConfig pipeline.DockerRegistryConfig,
	logger *zap.SugaredLogger,
	chartProviderService chartProviderService.ChartProviderService,
	userAuthService user.UserService,
	validator *validator.Validate, enforcer casbin.Enforcer, teamService team.TeamService,
	deleteService deleteService.DeleteService) *DockerRegRestHandlerImpl

func (DockerRegRestHandlerImpl) DeleteDockerRegistryConfig

func (impl DockerRegRestHandlerImpl) DeleteDockerRegistryConfig(w http.ResponseWriter, r *http.Request)

func (DockerRegRestHandlerImpl) FetchAllDockerAccounts

func (impl DockerRegRestHandlerImpl) FetchAllDockerAccounts(w http.ResponseWriter, r *http.Request)

func (DockerRegRestHandlerImpl) FetchAllDockerRegistryForAutocomplete

func (impl DockerRegRestHandlerImpl) FetchAllDockerRegistryForAutocomplete(w http.ResponseWriter, r *http.Request)

func (DockerRegRestHandlerImpl) FetchOneDockerAccounts

func (impl DockerRegRestHandlerImpl) FetchOneDockerAccounts(w http.ResponseWriter, r *http.Request)

func (DockerRegRestHandlerImpl) GetDockerArtifactStore

func (impl DockerRegRestHandlerImpl) GetDockerArtifactStore(w http.ResponseWriter, r *http.Request)

func (DockerRegRestHandlerImpl) IsDockerRegConfigured

func (impl DockerRegRestHandlerImpl) IsDockerRegConfigured(w http.ResponseWriter, r *http.Request)

func (DockerRegRestHandlerImpl) SaveDockerRegistryConfig

func (impl DockerRegRestHandlerImpl) SaveDockerRegistryConfig(w http.ResponseWriter, r *http.Request)

func (DockerRegRestHandlerImpl) UpdateDockerRegistryConfig

func (impl DockerRegRestHandlerImpl) UpdateDockerRegistryConfig(w http.ResponseWriter, r *http.Request)

func (DockerRegRestHandlerImpl) ValidateDockerRegistryConfig

func (impl DockerRegRestHandlerImpl) ValidateDockerRegistryConfig(w http.ResponseWriter, r *http.Request)

type ExternalCiRestHandler

type ExternalCiRestHandler interface {
	HandleExternalCiWebhook(w http.ResponseWriter, r *http.Request)
}

type ExternalCiRestHandlerImpl

type ExternalCiRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewExternalCiRestHandlerImpl

func NewExternalCiRestHandlerImpl(logger *zap.SugaredLogger, webhookService pipeline.WebhookService,
	ciEventHandler pubsub.CiEventHandler, validator *validator.Validate, userService user.UserService,
	enforcer casbin.Enforcer,
	enforcerUtil rbac.EnforcerUtil) *ExternalCiRestHandlerImpl

func (ExternalCiRestHandlerImpl) HandleExternalCiWebhook

func (impl ExternalCiRestHandlerImpl) HandleExternalCiWebhook(w http.ResponseWriter, r *http.Request)

type GitHostRestHandler

type GitHostRestHandler interface {
	GetGitHosts(w http.ResponseWriter, r *http.Request)
	GetGitHostById(w http.ResponseWriter, r *http.Request)
	CreateGitHost(w http.ResponseWriter, r *http.Request)
	GetAllWebhookEventConfig(w http.ResponseWriter, r *http.Request)
	GetWebhookEventConfig(w http.ResponseWriter, r *http.Request)
	GetWebhookDataMetaConfig(w http.ResponseWriter, r *http.Request)
}

type GitHostRestHandlerImpl

type GitHostRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewGitHostRestHandlerImpl

func NewGitHostRestHandlerImpl(logger *zap.SugaredLogger,
	gitHostConfig pipeline.GitHostConfig, userAuthService user.UserService,
	validator *validator.Validate, enforcer casbin.Enforcer, gitSensorClient gitSensor.Client, gitProviderConfig pipeline.GitRegistryConfig) *GitHostRestHandlerImpl

func (GitHostRestHandlerImpl) CreateGitHost

func (impl GitHostRestHandlerImpl) CreateGitHost(w http.ResponseWriter, r *http.Request)

func (GitHostRestHandlerImpl) GetAllWebhookEventConfig

func (impl GitHostRestHandlerImpl) GetAllWebhookEventConfig(w http.ResponseWriter, r *http.Request)

Need to make this call RBAC free as this API is called from the create app flow (configuring ci)

func (GitHostRestHandlerImpl) GetGitHostById

func (impl GitHostRestHandlerImpl) GetGitHostById(w http.ResponseWriter, r *http.Request)

Need to make this call RBAC free as this API is called from the create app flow (configuring ci)

func (GitHostRestHandlerImpl) GetGitHosts

func (impl GitHostRestHandlerImpl) GetGitHosts(w http.ResponseWriter, r *http.Request)

func (GitHostRestHandlerImpl) GetWebhookDataMetaConfig

func (impl GitHostRestHandlerImpl) GetWebhookDataMetaConfig(w http.ResponseWriter, r *http.Request)

Need to make this call RBAC free as this API is called from the create app flow (configuring ci)

func (GitHostRestHandlerImpl) GetWebhookEventConfig

func (impl GitHostRestHandlerImpl) GetWebhookEventConfig(w http.ResponseWriter, r *http.Request)

Need to make this call RBAC free as this API is called from the create app flow (configuring ci)

type GitOpsConfigRestHandler

type GitOpsConfigRestHandler interface {
	CreateGitOpsConfig(w http.ResponseWriter, r *http.Request)
	GetAllGitOpsConfig(w http.ResponseWriter, r *http.Request)
	GetGitOpsConfigById(w http.ResponseWriter, r *http.Request)
	UpdateGitOpsConfig(w http.ResponseWriter, r *http.Request)
	GetGitOpsConfigByProvider(w http.ResponseWriter, r *http.Request)
	GitOpsConfigured(w http.ResponseWriter, r *http.Request)
	GitOpsValidator(w http.ResponseWriter, r *http.Request)
}

type GitOpsConfigRestHandlerImpl

type GitOpsConfigRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewGitOpsConfigRestHandlerImpl

func NewGitOpsConfigRestHandlerImpl(
	logger *zap.SugaredLogger,
	gitOpsConfigService gitops.GitOpsConfigService, userAuthService user.UserService,
	validator *validator.Validate, enforcer casbin.Enforcer, teamService team.TeamService, gitOpsRepository repository.GitOpsConfigRepository) *GitOpsConfigRestHandlerImpl

func (GitOpsConfigRestHandlerImpl) CreateGitOpsConfig

func (impl GitOpsConfigRestHandlerImpl) CreateGitOpsConfig(w http.ResponseWriter, r *http.Request)

func (GitOpsConfigRestHandlerImpl) GetAllGitOpsConfig

func (impl GitOpsConfigRestHandlerImpl) GetAllGitOpsConfig(w http.ResponseWriter, r *http.Request)

func (GitOpsConfigRestHandlerImpl) GetGitOpsConfigById

func (impl GitOpsConfigRestHandlerImpl) GetGitOpsConfigById(w http.ResponseWriter, r *http.Request)

func (GitOpsConfigRestHandlerImpl) GetGitOpsConfigByProvider

func (impl GitOpsConfigRestHandlerImpl) GetGitOpsConfigByProvider(w http.ResponseWriter, r *http.Request)

func (GitOpsConfigRestHandlerImpl) GitOpsConfigured

func (impl GitOpsConfigRestHandlerImpl) GitOpsConfigured(w http.ResponseWriter, r *http.Request)

func (GitOpsConfigRestHandlerImpl) GitOpsValidator

func (impl GitOpsConfigRestHandlerImpl) GitOpsValidator(w http.ResponseWriter, r *http.Request)

func (GitOpsConfigRestHandlerImpl) UpdateGitOpsConfig

func (impl GitOpsConfigRestHandlerImpl) UpdateGitOpsConfig(w http.ResponseWriter, r *http.Request)

type GitProviderRestHandler

type GitProviderRestHandler interface {
	SaveGitRepoConfig(w http.ResponseWriter, r *http.Request)
	GetGitProviders(w http.ResponseWriter, r *http.Request)
	FetchAllGitProviders(w http.ResponseWriter, r *http.Request)
	FetchOneGitProviders(w http.ResponseWriter, r *http.Request)
	UpdateGitRepoConfig(w http.ResponseWriter, r *http.Request)
	DeleteGitRepoConfig(w http.ResponseWriter, r *http.Request)
}

type GitProviderRestHandlerImpl

type GitProviderRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewGitProviderRestHandlerImpl

func NewGitProviderRestHandlerImpl(dockerRegistryConfig pipeline.DockerRegistryConfig,
	logger *zap.SugaredLogger,
	gitRegistryConfig pipeline.GitRegistryConfig,
	dbConfigService pipeline.DbConfigService, userAuthService user.UserService,
	validator *validator.Validate, enforcer casbin.Enforcer, teamService team.TeamService,
	deleteServiceFullMode delete2.DeleteServiceFullMode) *GitProviderRestHandlerImpl

func (GitProviderRestHandlerImpl) DeleteGitRepoConfig

func (impl GitProviderRestHandlerImpl) DeleteGitRepoConfig(w http.ResponseWriter, r *http.Request)

func (GitProviderRestHandlerImpl) FetchAllGitProviders

func (impl GitProviderRestHandlerImpl) FetchAllGitProviders(w http.ResponseWriter, r *http.Request)

func (GitProviderRestHandlerImpl) FetchOneGitProviders

func (impl GitProviderRestHandlerImpl) FetchOneGitProviders(w http.ResponseWriter, r *http.Request)

func (GitProviderRestHandlerImpl) GetGitProviders

func (impl GitProviderRestHandlerImpl) GetGitProviders(w http.ResponseWriter, r *http.Request)

func (GitProviderRestHandlerImpl) SaveGitRepoConfig

func (impl GitProviderRestHandlerImpl) SaveGitRepoConfig(w http.ResponseWriter, r *http.Request)

func (GitProviderRestHandlerImpl) UpdateGitRepoConfig

func (impl GitProviderRestHandlerImpl) UpdateGitRepoConfig(w http.ResponseWriter, r *http.Request)

type GitWebhookRestHandler

type GitWebhookRestHandler interface {
	HandleGitWebhook(w http.ResponseWriter, r *http.Request)
}

type GitWebhookRestHandlerImpl

type GitWebhookRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewGitWebhookRestHandlerImpl

func NewGitWebhookRestHandlerImpl(logger *zap.SugaredLogger, gitWebhookService git.GitWebhookService) *GitWebhookRestHandlerImpl

func (GitWebhookRestHandlerImpl) HandleGitWebhook

func (impl GitWebhookRestHandlerImpl) HandleGitWebhook(w http.ResponseWriter, r *http.Request)

type GlobalCMCSRestHandler

type GlobalCMCSRestHandler interface {
	CreateGlobalCMCSConfig(w http.ResponseWriter, r *http.Request)
	UpdateGlobalCMCSDataById(w http.ResponseWriter, r *http.Request)
	GetGlobalCMCSDataByConfigTypeAndName(w http.ResponseWriter, r *http.Request)
	GetAllGlobalCMCSData(w http.ResponseWriter, r *http.Request)
	DeleteByID(w http.ResponseWriter, r *http.Request)
}

type GlobalCMCSRestHandlerImpl

type GlobalCMCSRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewGlobalCMCSRestHandlerImpl

func NewGlobalCMCSRestHandlerImpl(
	logger *zap.SugaredLogger,
	userAuthService user.UserService,
	validator *validator.Validate,
	enforcer casbin.Enforcer,
	globalCMCSService pipeline.GlobalCMCSService) *GlobalCMCSRestHandlerImpl

func (*GlobalCMCSRestHandlerImpl) CreateGlobalCMCSConfig

func (handler *GlobalCMCSRestHandlerImpl) CreateGlobalCMCSConfig(w http.ResponseWriter, r *http.Request)

func (*GlobalCMCSRestHandlerImpl) DeleteByID

func (handler *GlobalCMCSRestHandlerImpl) DeleteByID(w http.ResponseWriter, r *http.Request)

func (*GlobalCMCSRestHandlerImpl) GetAllGlobalCMCSData

func (handler *GlobalCMCSRestHandlerImpl) GetAllGlobalCMCSData(w http.ResponseWriter, r *http.Request)

func (*GlobalCMCSRestHandlerImpl) GetGlobalCMCSDataByConfigTypeAndName

func (handler *GlobalCMCSRestHandlerImpl) GetGlobalCMCSDataByConfigTypeAndName(w http.ResponseWriter, r *http.Request)

func (*GlobalCMCSRestHandlerImpl) UpdateGlobalCMCSDataById

func (handler *GlobalCMCSRestHandlerImpl) UpdateGlobalCMCSDataById(w http.ResponseWriter, r *http.Request)

type GlobalPluginRestHandler

type GlobalPluginRestHandler interface {
	GetAllGlobalVariables(w http.ResponseWriter, r *http.Request)
	ListAllPlugins(w http.ResponseWriter, r *http.Request)
	GetPluginDetailById(w http.ResponseWriter, r *http.Request)
}

type GlobalPluginRestHandlerImpl

type GlobalPluginRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewGlobalPluginRestHandler

func NewGlobalPluginRestHandler(logger *zap.SugaredLogger, globalPluginService plugin.GlobalPluginService,
	enforcerUtil rbac.EnforcerUtil, enforcer casbin.Enforcer, pipelineBuilder pipeline.PipelineBuilder) *GlobalPluginRestHandlerImpl

func (*GlobalPluginRestHandlerImpl) GetAllGlobalVariables

func (handler *GlobalPluginRestHandlerImpl) GetAllGlobalVariables(w http.ResponseWriter, r *http.Request)

func (*GlobalPluginRestHandlerImpl) GetPluginDetailById

func (handler *GlobalPluginRestHandlerImpl) GetPluginDetailById(w http.ResponseWriter, r *http.Request)

func (*GlobalPluginRestHandlerImpl) ListAllPlugins

func (handler *GlobalPluginRestHandlerImpl) ListAllPlugins(w http.ResponseWriter, r *http.Request)

type ImageScanRestHandler

type ImageScanRestHandler interface {
	ScanExecutionList(w http.ResponseWriter, r *http.Request)
	FetchExecutionDetail(w http.ResponseWriter, r *http.Request)
	FetchMinScanResultByAppIdAndEnvId(w http.ResponseWriter, r *http.Request)
	VulnerabilityExposure(w http.ResponseWriter, r *http.Request)
}

type ImageScanRestHandlerImpl

type ImageScanRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewImageScanRestHandlerImpl

func NewImageScanRestHandlerImpl(logger *zap.SugaredLogger,
	imageScanService security.ImageScanService, userService user.UserService, enforcer casbin.Enforcer,
	enforcerUtil rbac.EnforcerUtil, environmentService cluster.EnvironmentService) *ImageScanRestHandlerImpl

func (ImageScanRestHandlerImpl) FetchExecutionDetail

func (impl ImageScanRestHandlerImpl) FetchExecutionDetail(w http.ResponseWriter, r *http.Request)

func (ImageScanRestHandlerImpl) FetchMinScanResultByAppIdAndEnvId

func (impl ImageScanRestHandlerImpl) FetchMinScanResultByAppIdAndEnvId(w http.ResponseWriter, r *http.Request)

func (ImageScanRestHandlerImpl) ScanExecutionList

func (impl ImageScanRestHandlerImpl) ScanExecutionList(w http.ResponseWriter, r *http.Request)

func (ImageScanRestHandlerImpl) VulnerabilityExposure

func (impl ImageScanRestHandlerImpl) VulnerabilityExposure(w http.ResponseWriter, r *http.Request)

type JiraRestHandler

type JiraRestHandler interface {
	SaveAccountConfig(w http.ResponseWriter, r *http.Request)
	UpdateIssueStatus(w http.ResponseWriter, r *http.Request)
}

type JiraRestHandlerImpl

type JiraRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewJiraRestHandlerImpl

func NewJiraRestHandlerImpl(jiraService jira.ProjectManagementService, logger *zap.SugaredLogger, userAuthService user.UserService, validator *validator.Validate) *JiraRestHandlerImpl

func (JiraRestHandlerImpl) SaveAccountConfig

func (impl JiraRestHandlerImpl) SaveAccountConfig(w http.ResponseWriter, r *http.Request)

func (JiraRestHandlerImpl) UpdateIssueStatus

func (impl JiraRestHandlerImpl) UpdateIssueStatus(w http.ResponseWriter, r *http.Request)

type MetricsRequest

type MetricsRequest struct {
	AppId         int `json:"appId"`
	EnvironmentId int `json:"environmentId"`
}

type MigrateDbRestHandler

type MigrateDbRestHandler interface {
	SaveDbConfig(w http.ResponseWriter, r *http.Request)
	FetchAllDbConfig(w http.ResponseWriter, r *http.Request)
	FetchOneDbConfig(w http.ResponseWriter, r *http.Request)
	UpdateDbConfig(w http.ResponseWriter, r *http.Request)
	FetchDbConfigForAutoComp(w http.ResponseWriter, r *http.Request)
}

type MigrateDbRestHandlerImpl

type MigrateDbRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewMigrateDbRestHandlerImpl

func NewMigrateDbRestHandlerImpl(dockerRegistryConfig pipeline.DockerRegistryConfig,
	logger *zap.SugaredLogger, gitRegistryConfig pipeline.GitRegistryConfig,
	dbConfigService pipeline.DbConfigService, userAuthService user.UserService,
	validator *validator.Validate, dbMigrationService pipeline.DbMigrationService,
	enforcer casbin.Enforcer) *MigrateDbRestHandlerImpl

func (MigrateDbRestHandlerImpl) FetchAllDbConfig

func (impl MigrateDbRestHandlerImpl) FetchAllDbConfig(w http.ResponseWriter, r *http.Request)

func (MigrateDbRestHandlerImpl) FetchDbConfigForAutoComp

func (impl MigrateDbRestHandlerImpl) FetchDbConfigForAutoComp(w http.ResponseWriter, r *http.Request)

func (MigrateDbRestHandlerImpl) FetchOneDbConfig

func (impl MigrateDbRestHandlerImpl) FetchOneDbConfig(w http.ResponseWriter, r *http.Request)

func (MigrateDbRestHandlerImpl) SaveDbConfig

func (impl MigrateDbRestHandlerImpl) SaveDbConfig(w http.ResponseWriter, r *http.Request)

func (MigrateDbRestHandlerImpl) UpdateDbConfig

func (impl MigrateDbRestHandlerImpl) UpdateDbConfig(w http.ResponseWriter, r *http.Request)

type NotificationRestHandler

type NotificationRestHandler interface {
	SaveNotificationSettings(w http.ResponseWriter, r *http.Request)
	UpdateNotificationSettings(w http.ResponseWriter, r *http.Request)
	SaveNotificationChannelConfig(w http.ResponseWriter, r *http.Request)
	FindSESConfig(w http.ResponseWriter, r *http.Request)
	FindSlackConfig(w http.ResponseWriter, r *http.Request)
	FindSMTPConfig(w http.ResponseWriter, r *http.Request)
	FindWebhookConfig(w http.ResponseWriter, r *http.Request)
	GetWebhookVariables(w http.ResponseWriter, r *http.Request)
	FindAllNotificationConfig(w http.ResponseWriter, r *http.Request)
	GetAllNotificationSettings(w http.ResponseWriter, r *http.Request)
	DeleteNotificationSettings(w http.ResponseWriter, r *http.Request)
	DeleteNotificationChannelConfig(w http.ResponseWriter, r *http.Request)

	RecipientListingSuggestion(w http.ResponseWriter, r *http.Request)
	FindAllNotificationConfigAutocomplete(w http.ResponseWriter, r *http.Request)
	GetOptionsForNotificationSettings(w http.ResponseWriter, r *http.Request)
}

type NotificationRestHandlerImpl

type NotificationRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewNotificationRestHandlerImpl

func NewNotificationRestHandlerImpl(dockerRegistryConfig pipeline.DockerRegistryConfig,
	logger *zap.SugaredLogger, gitRegistryConfig pipeline.GitRegistryConfig,
	dbConfigService pipeline.DbConfigService, userAuthService user.UserService,
	validator *validator.Validate, notificationService notifier.NotificationConfigService,
	slackService notifier.SlackNotificationService, webhookService notifier.WebhookNotificationService, sesService notifier.SESNotificationService, smtpService notifier.SMTPNotificationService,
	enforcer casbin.Enforcer, teamService team.TeamService, environmentService cluster.EnvironmentService, pipelineBuilder pipeline.PipelineBuilder,
	enforcerUtil rbac.EnforcerUtil) *NotificationRestHandlerImpl

func (NotificationRestHandlerImpl) DeleteNotificationChannelConfig

func (impl NotificationRestHandlerImpl) DeleteNotificationChannelConfig(w http.ResponseWriter, r *http.Request)

func (NotificationRestHandlerImpl) DeleteNotificationSettings

func (impl NotificationRestHandlerImpl) DeleteNotificationSettings(w http.ResponseWriter, r *http.Request)

func (NotificationRestHandlerImpl) FindAllNotificationConfig

func (impl NotificationRestHandlerImpl) FindAllNotificationConfig(w http.ResponseWriter, r *http.Request)

func (NotificationRestHandlerImpl) FindAllNotificationConfigAutocomplete

func (impl NotificationRestHandlerImpl) FindAllNotificationConfigAutocomplete(w http.ResponseWriter, r *http.Request)

func (NotificationRestHandlerImpl) FindSESConfig

func (impl NotificationRestHandlerImpl) FindSESConfig(w http.ResponseWriter, r *http.Request)

func (NotificationRestHandlerImpl) FindSMTPConfig

func (impl NotificationRestHandlerImpl) FindSMTPConfig(w http.ResponseWriter, r *http.Request)

func (NotificationRestHandlerImpl) FindSlackConfig

func (impl NotificationRestHandlerImpl) FindSlackConfig(w http.ResponseWriter, r *http.Request)

func (NotificationRestHandlerImpl) FindWebhookConfig

func (impl NotificationRestHandlerImpl) FindWebhookConfig(w http.ResponseWriter, r *http.Request)

func (NotificationRestHandlerImpl) GetAllNotificationSettings

func (impl NotificationRestHandlerImpl) GetAllNotificationSettings(w http.ResponseWriter, r *http.Request)

func (NotificationRestHandlerImpl) GetOptionsForNotificationSettings

func (impl NotificationRestHandlerImpl) GetOptionsForNotificationSettings(w http.ResponseWriter, r *http.Request)

func (NotificationRestHandlerImpl) GetWebhookVariables

func (impl NotificationRestHandlerImpl) GetWebhookVariables(w http.ResponseWriter, r *http.Request)

func (NotificationRestHandlerImpl) RecipientListingSuggestion

func (impl NotificationRestHandlerImpl) RecipientListingSuggestion(w http.ResponseWriter, r *http.Request)

func (NotificationRestHandlerImpl) SaveNotificationChannelConfig

func (impl NotificationRestHandlerImpl) SaveNotificationChannelConfig(w http.ResponseWriter, r *http.Request)

func (NotificationRestHandlerImpl) SaveNotificationSettings

func (impl NotificationRestHandlerImpl) SaveNotificationSettings(w http.ResponseWriter, r *http.Request)

func (NotificationRestHandlerImpl) UpdateNotificationSettings

func (impl NotificationRestHandlerImpl) UpdateNotificationSettings(w http.ResponseWriter, r *http.Request)

type PProfRestHandler

type PProfRestHandler interface {
	Index(w http.ResponseWriter, r *http.Request)
	Cmdline(w http.ResponseWriter, r *http.Request)
	Profile(w http.ResponseWriter, r *http.Request)
	Symbol(w http.ResponseWriter, r *http.Request)
	Trace(w http.ResponseWriter, r *http.Request)
	Goroutine(w http.ResponseWriter, r *http.Request)
	Threadcreate(w http.ResponseWriter, r *http.Request)
	Heap(w http.ResponseWriter, r *http.Request)
	Block(w http.ResponseWriter, r *http.Request)
	Mutex(w http.ResponseWriter, r *http.Request)
	Allocs(w http.ResponseWriter, r *http.Request)
}

type PProfRestHandlerImpl

type PProfRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewPProfRestHandler

func NewPProfRestHandler(userService user.UserService) *PProfRestHandlerImpl

func (PProfRestHandlerImpl) Allocs

func (p PProfRestHandlerImpl) Allocs(w http.ResponseWriter, r *http.Request)

func (PProfRestHandlerImpl) Block

func (p PProfRestHandlerImpl) Block(w http.ResponseWriter, r *http.Request)

func (PProfRestHandlerImpl) Cmdline

func (p PProfRestHandlerImpl) Cmdline(w http.ResponseWriter, r *http.Request)

func (PProfRestHandlerImpl) Goroutine

func (p PProfRestHandlerImpl) Goroutine(w http.ResponseWriter, r *http.Request)

func (PProfRestHandlerImpl) Heap

func (p PProfRestHandlerImpl) Heap(w http.ResponseWriter, r *http.Request)

func (PProfRestHandlerImpl) Index

func (p PProfRestHandlerImpl) Index(w http.ResponseWriter, r *http.Request)

func (PProfRestHandlerImpl) Mutex

func (p PProfRestHandlerImpl) Mutex(w http.ResponseWriter, r *http.Request)

func (PProfRestHandlerImpl) Profile

func (p PProfRestHandlerImpl) Profile(w http.ResponseWriter, r *http.Request)

func (PProfRestHandlerImpl) Symbol

func (p PProfRestHandlerImpl) Symbol(w http.ResponseWriter, r *http.Request)

func (PProfRestHandlerImpl) Threadcreate

func (p PProfRestHandlerImpl) Threadcreate(w http.ResponseWriter, r *http.Request)

func (PProfRestHandlerImpl) Trace

func (p PProfRestHandlerImpl) Trace(w http.ResponseWriter, r *http.Request)

type PipelineHistoryRestHandler

type PipelineHistoryRestHandler interface {
	FetchDeployedConfigurationsForWorkflow(w http.ResponseWriter, r *http.Request)
	FetchDeployedHistoryComponentList(w http.ResponseWriter, r *http.Request)
	FetchDeployedHistoryComponentDetail(w http.ResponseWriter, r *http.Request)
	GetAllDeployedConfigurationHistoryForLatestWfrIdForPipeline(w http.ResponseWriter, r *http.Request)
	GetAllDeployedConfigurationHistoryForSpecificWfrIdForPipeline(w http.ResponseWriter, r *http.Request)
}

type PipelineHistoryRestHandlerImpl

type PipelineHistoryRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewPipelineHistoryRestHandlerImpl

func NewPipelineHistoryRestHandlerImpl(logger *zap.SugaredLogger, userAuthService user.UserService,
	enforcer casbin.Enforcer, strategyHistoryService history2.PipelineStrategyHistoryService,
	deploymentTemplateHistoryService history2.DeploymentTemplateHistoryService,
	configMapHistoryService history2.ConfigMapHistoryService,
	prePostCiScriptHistoryService history2.PrePostCiScriptHistoryService,
	prePostCdScriptHistoryService history2.PrePostCdScriptHistoryService,
	enforcerUtil rbac.EnforcerUtil,
	deployedConfigurationHistoryService history2.DeployedConfigurationHistoryService) *PipelineHistoryRestHandlerImpl

func (*PipelineHistoryRestHandlerImpl) FetchDeployedConfigurationsForWorkflow

func (handler *PipelineHistoryRestHandlerImpl) FetchDeployedConfigurationsForWorkflow(w http.ResponseWriter, r *http.Request)

func (*PipelineHistoryRestHandlerImpl) FetchDeployedHistoryComponentDetail

func (handler *PipelineHistoryRestHandlerImpl) FetchDeployedHistoryComponentDetail(w http.ResponseWriter, r *http.Request)

func (*PipelineHistoryRestHandlerImpl) FetchDeployedHistoryComponentList

func (handler *PipelineHistoryRestHandlerImpl) FetchDeployedHistoryComponentList(w http.ResponseWriter, r *http.Request)

func (*PipelineHistoryRestHandlerImpl) GetAllDeployedConfigurationHistoryForLatestWfrIdForPipeline

func (handler *PipelineHistoryRestHandlerImpl) GetAllDeployedConfigurationHistoryForLatestWfrIdForPipeline(w http.ResponseWriter, r *http.Request)

func (*PipelineHistoryRestHandlerImpl) GetAllDeployedConfigurationHistoryForSpecificWfrIdForPipeline

func (handler *PipelineHistoryRestHandlerImpl) GetAllDeployedConfigurationHistoryForSpecificWfrIdForPipeline(w http.ResponseWriter, r *http.Request)

type PipelineStatusTimelineRestHandler

type PipelineStatusTimelineRestHandler interface {
	FetchTimelines(w http.ResponseWriter, r *http.Request)
}

type PipelineStatusTimelineRestHandlerImpl

type PipelineStatusTimelineRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewPipelineStatusTimelineRestHandlerImpl

func NewPipelineStatusTimelineRestHandlerImpl(logger *zap.SugaredLogger,
	pipelineStatusTimelineService status.PipelineStatusTimelineService, enforcerUtil rbac.EnforcerUtil,
	enforcer casbin.Enforcer) *PipelineStatusTimelineRestHandlerImpl

func (*PipelineStatusTimelineRestHandlerImpl) FetchTimelines

func (handler *PipelineStatusTimelineRestHandlerImpl) FetchTimelines(w http.ResponseWriter, r *http.Request)

type PipelineTriggerRestHandler

type PipelineTriggerRestHandler interface {
	OverrideConfig(w http.ResponseWriter, r *http.Request)
	ReleaseStatusUpdate(w http.ResponseWriter, r *http.Request)
	StartStopApp(w http.ResponseWriter, r *http.Request)
	StartStopDeploymentGroup(w http.ResponseWriter, r *http.Request)
	GetAllLatestDeploymentConfiguration(w http.ResponseWriter, r *http.Request)
	RotatePods(w http.ResponseWriter, r *http.Request)
}

type PipelineTriggerRestHandlerImpl

type PipelineTriggerRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewPipelineRestHandler

func NewPipelineRestHandler(appService app.AppService, userAuthService user.UserService, validator *validator.Validate,
	enforcer casbin.Enforcer, teamService team.TeamService, logger *zap.SugaredLogger, enforcerUtil rbac.EnforcerUtil,
	workflowDagExecutor pipeline.WorkflowDagExecutor, deploymentGroupService deploymentGroup.DeploymentGroupService,
	argoUserService argo.ArgoUserService, deploymentConfigService pipeline.DeploymentConfigService) *PipelineTriggerRestHandlerImpl

func (PipelineTriggerRestHandlerImpl) GetAllLatestDeploymentConfiguration

func (handler PipelineTriggerRestHandlerImpl) GetAllLatestDeploymentConfiguration(w http.ResponseWriter, r *http.Request)

func (PipelineTriggerRestHandlerImpl) OverrideConfig

func (handler PipelineTriggerRestHandlerImpl) OverrideConfig(w http.ResponseWriter, r *http.Request)

func (PipelineTriggerRestHandlerImpl) ReleaseStatusUpdate

func (handler PipelineTriggerRestHandlerImpl) ReleaseStatusUpdate(w http.ResponseWriter, r *http.Request)

func (PipelineTriggerRestHandlerImpl) RotatePods

func (handler PipelineTriggerRestHandlerImpl) RotatePods(w http.ResponseWriter, r *http.Request)

func (PipelineTriggerRestHandlerImpl) StartStopApp

func (handler PipelineTriggerRestHandlerImpl) StartStopApp(w http.ResponseWriter, r *http.Request)

func (PipelineTriggerRestHandlerImpl) StartStopDeploymentGroup

func (handler PipelineTriggerRestHandlerImpl) StartStopDeploymentGroup(w http.ResponseWriter, r *http.Request)

type PolicyRestHandler

type PolicyRestHandler interface {
	SavePolicy(w http.ResponseWriter, r *http.Request)
	UpdatePolicy(w http.ResponseWriter, r *http.Request)
	GetPolicy(w http.ResponseWriter, r *http.Request)
	VerifyImage(w http.ResponseWriter, r *http.Request)
}

type PolicyRestHandlerImpl

type PolicyRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewPolicyRestHandlerImpl

func NewPolicyRestHandlerImpl(logger *zap.SugaredLogger,
	policyService security.PolicyService,
	userService user.UserService, userAuthService user.UserAuthService,
	enforcer casbin.Enforcer,
	enforcerUtil rbac.EnforcerUtil, environmentService cluster.EnvironmentService) *PolicyRestHandlerImpl

func (PolicyRestHandlerImpl) GetPolicy

func (impl PolicyRestHandlerImpl) GetPolicy(w http.ResponseWriter, r *http.Request)

func (PolicyRestHandlerImpl) SavePolicy

func (impl PolicyRestHandlerImpl) SavePolicy(w http.ResponseWriter, r *http.Request)

func (PolicyRestHandlerImpl) UpdatePolicy

func (impl PolicyRestHandlerImpl) UpdatePolicy(w http.ResponseWriter, r *http.Request)

func (PolicyRestHandlerImpl) VerifyImage

func (impl PolicyRestHandlerImpl) VerifyImage(w http.ResponseWriter, r *http.Request)

TODO - move to image-scanner

type PubSubClientRestHandler

type PubSubClientRestHandler interface {
	PublishEventsToNats(w http.ResponseWriter, r *http.Request)
}

type PubSubClientRestHandlerImpl

type PubSubClientRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewPubSubClientRestHandlerImpl

func NewPubSubClientRestHandlerImpl(pubsubClient *pubsub.PubSubClientServiceImpl, logger *zap.SugaredLogger, cdConfig *pipeline.CdConfig) *PubSubClientRestHandlerImpl

func (*PubSubClientRestHandlerImpl) PublishEventsToNats

func (impl *PubSubClientRestHandlerImpl) PublishEventsToNats(w http.ResponseWriter, r *http.Request)

type PublishRequest

type PublishRequest struct {
	Topic   string          `json:"topic"`
	Payload json.RawMessage `json:"payload"`
}

type ReleaseMetricsRestHandler

type ReleaseMetricsRestHandler interface {
	ResetDataForAppEnvironment(w http.ResponseWriter, r *http.Request)
	ResetDataForAllAppEnvironment(w http.ResponseWriter, r *http.Request)
	GetDeploymentMetrics(w http.ResponseWriter, r *http.Request)
}

type ReleaseMetricsRestHandlerImpl

type ReleaseMetricsRestHandlerImpl struct {
	ReleaseDataService app.ReleaseDataService
	// contains filtered or unexported fields
}

func NewReleaseMetricsRestHandlerImpl

func NewReleaseMetricsRestHandlerImpl(
	logger *zap.SugaredLogger,
	enforcer casbin.Enforcer,
	ReleaseDataService app.ReleaseDataService,
	userAuthService user.UserService,
	teamService team.TeamService,
	pipelineRepository pipelineConfig.PipelineRepository, enforcerUtil rbac.EnforcerUtil) *ReleaseMetricsRestHandlerImpl

func (*ReleaseMetricsRestHandlerImpl) GetDeploymentMetrics

func (impl *ReleaseMetricsRestHandlerImpl) GetDeploymentMetrics(w http.ResponseWriter, r *http.Request)

func (*ReleaseMetricsRestHandlerImpl) ResetDataForAllAppEnvironment

func (impl *ReleaseMetricsRestHandlerImpl) ResetDataForAllAppEnvironment(w http.ResponseWriter, r *http.Request)

func (*ReleaseMetricsRestHandlerImpl) ResetDataForAppEnvironment

func (impl *ReleaseMetricsRestHandlerImpl) ResetDataForAppEnvironment(w http.ResponseWriter, r *http.Request)

type TelemetryGenericEvent

type TelemetryGenericEvent struct {
	// contains filtered or unexported fields
}

type TelemetryRestHandler

type TelemetryRestHandler interface {
	GetTelemetryMetaInfo(w http.ResponseWriter, r *http.Request)
	SendTelemetryData(w http.ResponseWriter, r *http.Request)
	SendSummaryEvent(w http.ResponseWriter, r *http.Request)
}

type TelemetryRestHandlerImpl

type TelemetryRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewTelemetryRestHandlerImpl

func NewTelemetryRestHandlerImpl(logger *zap.SugaredLogger,
	telemetryEventClient telemetry.TelemetryEventClient, enforcer casbin.Enforcer, userService user.UserService) *TelemetryRestHandlerImpl

func (TelemetryRestHandlerImpl) GetTelemetryMetaInfo

func (handler TelemetryRestHandlerImpl) GetTelemetryMetaInfo(w http.ResponseWriter, r *http.Request)

func (TelemetryRestHandlerImpl) SendSummaryEvent

func (handler TelemetryRestHandlerImpl) SendSummaryEvent(w http.ResponseWriter, r *http.Request)

func (TelemetryRestHandlerImpl) SendTelemetryData

func (handler TelemetryRestHandlerImpl) SendTelemetryData(w http.ResponseWriter, r *http.Request)

type TestSuitRestHandler

type TestSuitRestHandler interface {
	SuitesProxy(w http.ResponseWriter, r *http.Request)
	GetTestSuites(w http.ResponseWriter, r *http.Request)
	DetailedTestSuites(w http.ResponseWriter, r *http.Request)
	GetAllSuitByID(w http.ResponseWriter, r *http.Request)
	GetAllTestCases(w http.ResponseWriter, r *http.Request)
	GetTestCaseByID(w http.ResponseWriter, r *http.Request)
	RedirectTriggerForApp(w http.ResponseWriter, r *http.Request)
	RedirectTriggerForEnv(w http.ResponseWriter, r *http.Request)
}

type TestSuitRestHandlerImpl

type TestSuitRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewTestSuitRestHandlerImpl

func NewTestSuitRestHandlerImpl(logger *zap.SugaredLogger, userService user.UserService,
	validator *validator.Validate, enforcer casbin.Enforcer, enforcerUtil rbac.EnforcerUtil,
	config *client.EventClientConfig, client *http.Client) *TestSuitRestHandlerImpl

func (TestSuitRestHandlerImpl) DetailedTestSuites

func (impl TestSuitRestHandlerImpl) DetailedTestSuites(w http.ResponseWriter, r *http.Request)

func (TestSuitRestHandlerImpl) GetAllSuitByID

func (impl TestSuitRestHandlerImpl) GetAllSuitByID(w http.ResponseWriter, r *http.Request)

func (TestSuitRestHandlerImpl) GetAllTestCases

func (impl TestSuitRestHandlerImpl) GetAllTestCases(w http.ResponseWriter, r *http.Request)

func (TestSuitRestHandlerImpl) GetTestCaseByID

func (impl TestSuitRestHandlerImpl) GetTestCaseByID(w http.ResponseWriter, r *http.Request)

func (TestSuitRestHandlerImpl) GetTestSuites

func (impl TestSuitRestHandlerImpl) GetTestSuites(w http.ResponseWriter, r *http.Request)

func (TestSuitRestHandlerImpl) HttpGet

func (impl TestSuitRestHandlerImpl) HttpGet(url string) (map[string]interface{}, error)

func (TestSuitRestHandlerImpl) RedirectTriggerForApp

func (impl TestSuitRestHandlerImpl) RedirectTriggerForApp(w http.ResponseWriter, r *http.Request)

func (TestSuitRestHandlerImpl) RedirectTriggerForEnv

func (impl TestSuitRestHandlerImpl) RedirectTriggerForEnv(w http.ResponseWriter, r *http.Request)

func (TestSuitRestHandlerImpl) SuitesProxy

func (impl TestSuitRestHandlerImpl) SuitesProxy(w http.ResponseWriter, r *http.Request)

type TestSuiteBean

type TestSuiteBean struct {
	Link       string `json:"link,omitempty"`
	PipelineId int    `json:"PipelineId"`
	TriggerId  int    `json:"triggerId"`
}

type UserAttributesRestHandler

type UserAttributesRestHandler interface {
	AddUserAttributes(w http.ResponseWriter, r *http.Request)
	UpdateUserAttributes(w http.ResponseWriter, r *http.Request)
	GetUserAttribute(w http.ResponseWriter, r *http.Request)
}

type UserAttributesRestHandlerImpl

type UserAttributesRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewUserAttributesRestHandlerImpl

func NewUserAttributesRestHandlerImpl(logger *zap.SugaredLogger, enforcer casbin.Enforcer,
	userService user.UserService, userAttributesService attributes.UserAttributesService) *UserAttributesRestHandlerImpl

func (*UserAttributesRestHandlerImpl) AddUserAttributes

func (handler *UserAttributesRestHandlerImpl) AddUserAttributes(w http.ResponseWriter, r *http.Request)

func (*UserAttributesRestHandlerImpl) GetUserAttribute

func (handler *UserAttributesRestHandlerImpl) GetUserAttribute(w http.ResponseWriter, r *http.Request)

@Summary get user attributes @version 1.0 @produce application/json @Param name query string true "Input key" @Success 200 {object} attributes.UserAttributesDto @Router /orchestrator/attributes/user/get [GET]

func (*UserAttributesRestHandlerImpl) UpdateUserAttributes

func (handler *UserAttributesRestHandlerImpl) UpdateUserAttributes(w http.ResponseWriter, r *http.Request)

@Summary update user attributes @version 1.0 @produce application/json @Param payload body attributes.UserAttributesDto true "Input key" @Success 200 {object} attributes.UserAttributesDto @Router /orchestrator/attributes/user/update [POST]

type WebhookDataMetaConfigResponse

type WebhookDataMetaConfigResponse struct {
	GitHostId     int                             `json:"gitHostId"`
	GitHost       *pipeline.GitHostRequest        `json:"gitHost"`
	WebhookEvents []*gitSensor.WebhookEventConfig `json:"webhookEvents"`
}

type WebhookDataRestHandler

type WebhookDataRestHandler interface {
	GetWebhookPayloadDataForPipelineMaterialId(w http.ResponseWriter, r *http.Request)
	GetWebhookPayloadFilterDataForPipelineMaterialId(w http.ResponseWriter, r *http.Request)
}

type WebhookDataRestHandlerImpl

type WebhookDataRestHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewWebhookDataRestHandlerImpl

func NewWebhookDataRestHandlerImpl(logger *zap.SugaredLogger, userAuthService user.UserService,
	ciPipelineMaterialRepository pipelineConfig.CiPipelineMaterialRepository, enforcerUtil rbac.EnforcerUtil, enforcer casbin.Enforcer,
	gitSensorGrpcClient gitSensor.Client, webhookEventDataConfig pipeline.WebhookEventDataConfig) *WebhookDataRestHandlerImpl

func (WebhookDataRestHandlerImpl) GetWebhookPayloadDataForPipelineMaterialId

func (impl WebhookDataRestHandlerImpl) GetWebhookPayloadDataForPipelineMaterialId(w http.ResponseWriter, r *http.Request)

func (WebhookDataRestHandlerImpl) GetWebhookPayloadFilterDataForPipelineMaterialId

func (impl WebhookDataRestHandlerImpl) GetWebhookPayloadFilterDataForPipelineMaterialId(w http.ResponseWriter, r *http.Request)

type WebhookEventHandler

type WebhookEventHandler interface {
	OnWebhookEvent(w http.ResponseWriter, r *http.Request)
}

type WebhookEventHandlerImpl

type WebhookEventHandlerImpl struct {
	// contains filtered or unexported fields
}

func NewWebhookEventHandlerImpl

func NewWebhookEventHandlerImpl(logger *zap.SugaredLogger, gitHostConfig pipeline.GitHostConfig, eventClient client.EventClient,
	webhookSecretValidator git.WebhookSecretValidator, webhookEventDataConfig pipeline.WebhookEventDataConfig) *WebhookEventHandlerImpl

func (WebhookEventHandlerImpl) OnWebhookEvent

func (impl WebhookEventHandlerImpl) OnWebhookEvent(w http.ResponseWriter, r *http.Request)