restHandler

package
v0.0.0-...-9ac71f1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 10, 2025 License: Apache-2.0 Imports: 106 Imported by: 0

Documentation

Index

Constants

View Source 
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."
)
View Source 
const (
	REG_DELETE_SUCCESS_RESP = "Container Registry deleted successfully."
	OCIScheme               = "oci://"
)
View Source 
const (
	ObjectTypeApp   = "app"
	ObjectTypeChart = "chart"
	ObjectTypePod   = "pod"
)
View Source 
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."
)
View Source 
const GIT_ACCOUNT_DELETE_SUCCESS_RESP = "Git account deleted successfully."

Variables

This section is empty.

Functions

func ValidateDockerArtifactStoreRequestBean 

func ValidateDockerArtifactStoreRequestBean(bean types.DockerArtifactStoreBean) error

Types

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, asyncRunnable *async.Runnable) *BatchOperationRestHandlerImpl

func (BatchOperationRestHandlerImpl) Operate 

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

type BulkEditRestHandler 

type BulkEditRestHandler interface {
	BulkEditV1Beta1RestHandler
	// BulkEditV1Beta2RestHandlerEnt interface that defines the methods for bulk edit v1beta2.
	// v1beta2 is an Ent only version, so it does not have a separate interface.
	BulkEditV1Beta2RestHandlerEnt
}

type BulkEditV1Beta1RestHandler 

type BulkEditV1Beta1RestHandler interface {
	GetBulkEditConfig(w http.ResponseWriter, r *http.Request)
	DryRunBulkEdit(w http.ResponseWriter, r *http.Request)
	BulkEdit(w http.ResponseWriter, r *http.Request)
}

type BulkEditV1Beta2RestHandlerEnt 

type BulkEditV1Beta2RestHandlerEnt interface {
}

type BulkUpdateRestHandler 

type BulkUpdateRestHandler interface {
	//deprecated
	BulkHibernate(w http.ResponseWriter, r *http.Request)
	BulkHibernateV1(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)
	BulkEditRestHandler
}

type BulkUpdateRestHandlerImpl 

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

func NewBulkUpdateRestHandlerImpl 

func NewBulkUpdateRestHandlerImpl(pipelineBuilder pipeline.PipelineBuilder, logger *zap.SugaredLogger,
	bulkUpdateService service.BulkUpdateService,
	chartService chart.ChartService,
	propertiesConfigService pipeline.PropertiesConfigService,
	userAuthService user.UserService,
	enforcer casbin.Enforcer,
	ciHandler pipeline.CiHandler,
	validator *validator.Validate,
	gitSensorClient gitSensor.Client,
	ciPipelineRepository pipelineConfig.CiPipelineRepository, pipelineRepository pipelineConfig.PipelineRepository,
	enforcerUtil rbac.EnforcerUtil, envService environment.EnvironmentService,
	gitRegistryConfig gitProvider.GitRegistryConfig, dockerRegistryConfig pipeline.DockerRegistryConfig,
	cdHandler pipeline.CdHandler,
	appCloneService appClone.AppCloneService,
	appWorkflowService appWorkflow.AppWorkflowService,
	materialRepository repository.MaterialRepository,
) *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) BulkEdit 

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

func (BulkUpdateRestHandlerImpl) BulkHibernate 

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

func (BulkUpdateRestHandlerImpl) BulkHibernateV1 

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

func (BulkUpdateRestHandlerImpl) BulkUnHibernate 

func (handler BulkUpdateRestHandlerImpl) BulkUnHibernate(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) DryRunBulkEdit 

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

func (BulkUpdateRestHandlerImpl) GetBulkEditConfig 

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

func (BulkUpdateRestHandlerImpl) HandleCdPipelineBulkAction 

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

type ChannelDto 

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

type ChannelResponseDTO 

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

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(logger *zap.SugaredLogger, chartRefService chartRef.ChartRefService,
	chartService chartService.ChartService) *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 CommonRestHandler 

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

type CommonRestHandlerImpl 

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

func NewCommonRestHandlerImpl 

func NewCommonRestHandlerImpl(
	logger *zap.SugaredLogger,
	userAuthService user.UserService,
	commonService commonService.CommonService) *CommonRestHandlerImpl

func (CommonRestHandlerImpl) EnvironmentVariableList 

func (impl CommonRestHandlerImpl) EnvironmentVariableList(w http.ResponseWriter, r *http.Request)

func (CommonRestHandlerImpl) GlobalChecklist 

func (impl CommonRestHandlerImpl) 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,
	draftAwareResourceService draftAwareConfigService.DraftAwareConfigService,
) *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 gitProvider.GitRegistryConfig,
	chartService chart.ChartService, configMapService pipeline.ConfigMapService, appListingService app.AppListingService,
	propertiesConfigService pipeline.PropertiesConfigService, appWorkflowService appWorkflow.AppWorkflowService,
	appWorkflowRepository appWorkflow2.AppWorkflowRepository, environmentRepository repository.EnvironmentRepository, configMapRepository chartConfig.ConfigMapRepository,
	chartRepo chartRepoRepository.ChartRepository, teamService team.TeamService,
	pipelineStageService pipeline.PipelineStageService, ciPipelineRepository pipelineConfig.CiPipelineRepository,
	gitProviderReadService read.GitProviderReadService,
	gitMaterialReadService read2.GitMaterialReadService,
	teamReadService read3.TeamReadService,
	chartReadService read5.ChartReadService) *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) TriggerChartSync 

func (impl DockerRegRestHandlerImpl) TriggerChartSync(bean types.DockerArtifactStoreBean) error

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, validator *validator.Validate,
	userService user.UserService, enforcer casbin.Enforcer,
	workflowDagExecutor dag.WorkflowDagExecutor) *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 gitHost.GitHostConfig, userAuthService user.UserService,
	validator *validator.Validate, enforcer casbin.Enforcer, gitSensorClient gitSensor.Client,
	gitProviderReadService read.GitProviderReadService,
	gitHostReadService read2.GitHostReadService) *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,
	moduleReadService moduleRead.ModuleReadService,
	gitOpsConfigService gitops.GitOpsConfigService, userAuthService user.UserService,
	validator *validator.Validate, enforcer casbin.Enforcer, teamService team.TeamService) *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 gitProvider.GitRegistryConfig,
	userAuthService user.UserService,
	validator *validator.Validate, enforcer casbin.Enforcer, teamService team.TeamService,
	deleteServiceFullMode delete2.DeleteServiceFullMode,
	gitProviderReadService read.GitProviderReadService) *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 gitWebhook.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 {
	CreatePlugin(w http.ResponseWriter, r *http.Request)

	GetAllGlobalVariables(w http.ResponseWriter, r *http.Request)
	ListAllPlugins(w http.ResponseWriter, r *http.Request)
	GetPluginDetailById(w http.ResponseWriter, r *http.Request)
	GetDetailedPluginInfoByPluginId(w http.ResponseWriter, r *http.Request)
	GetAllDetailedPluginInfo(w http.ResponseWriter, r *http.Request)

	ListAllPluginsV2(w http.ResponseWriter, r *http.Request)
	GetPluginDetailByIds(w http.ResponseWriter, r *http.Request)
	GetAllUniqueTags(w http.ResponseWriter, r *http.Request)
	MigratePluginData(w http.ResponseWriter, r *http.Request)
	GetAllPluginMinData(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,
	userService user.UserService) *GlobalPluginRestHandlerImpl

func (*GlobalPluginRestHandlerImpl) CreatePlugin 

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

func (*GlobalPluginRestHandlerImpl) GetAllDetailedPluginInfo 

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

func (*GlobalPluginRestHandlerImpl) GetAllGlobalVariables 

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

func (*GlobalPluginRestHandlerImpl) GetAllPluginMinData 

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

func (*GlobalPluginRestHandlerImpl) GetAllUniqueTags 

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

func (*GlobalPluginRestHandlerImpl) GetDetailedPluginInfoByPluginId 

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

func (*GlobalPluginRestHandlerImpl) GetPluginDetailById 

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

func (*GlobalPluginRestHandlerImpl) GetPluginDetailByIds 

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

func (*GlobalPluginRestHandlerImpl) IsUserAuthorisedForThisApp 

func (handler *GlobalPluginRestHandlerImpl) IsUserAuthorisedForThisApp(token string, appId int) (bool, error)

func (*GlobalPluginRestHandlerImpl) IsUserAuthorized 

func (handler *GlobalPluginRestHandlerImpl) IsUserAuthorized(token string, appId int) (bool, error)

func (*GlobalPluginRestHandlerImpl) ListAllPlugins 

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

func (*GlobalPluginRestHandlerImpl) ListAllPluginsV2 

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

func (*GlobalPluginRestHandlerImpl) MigratePluginData 

func (handler *GlobalPluginRestHandlerImpl) MigratePluginData(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 imageScanning.ImageScanService, userService user.UserService, enforcer casbin.Enforcer,
	enforcerUtil rbac.EnforcerUtil, environmentService environment.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 MetricsRequest 

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

type NotificationRestHandler 

type NotificationRestHandler interface {
	SaveNotificationSettingsV2(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 gitProvider.GitRegistryConfig,
	userAuthService user.UserService,
	validator *validator.Validate, notificationService notifier.NotificationConfigService,
	slackService notifier.SlackNotificationService, webhookService notifier.WebhookNotificationService, sesService notifier.SESNotificationService, smtpService notifier.SMTPNotificationService,
	enforcer casbin.Enforcer, environmentService environment.EnvironmentService, pipelineBuilder pipeline.PipelineBuilder,
	enforcerUtil rbac.EnforcerUtil,
	teamReadService read.TeamReadService) *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) SaveNotificationSettingsV2 

func (impl NotificationRestHandlerImpl) SaveNotificationSettingsV2(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,
	enforcer casbin.Enforcer) *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 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 imageScanning.PolicyService,
	userService user2.UserService, userAuthService user2.UserAuthService,
	enforcer casbin.Enforcer,
	enforcerUtil rbac.EnforcerUtil, environmentService environment.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 *types.CiCdConfig) *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 ResourceGroupRestHandler 

type ResourceGroupRestHandler interface {
	GetActiveResourceGroupList(w http.ResponseWriter, r *http.Request)
	//GetApplicationsForResourceGroup(w http.ResponseWriter, r *http.Request)
	CreateResourceGroup(w http.ResponseWriter, r *http.Request)
	UpdateResourceGroup(w http.ResponseWriter, r *http.Request)
	DeleteResourceGroup(w http.ResponseWriter, r *http.Request)
	CheckResourceGroupPermissions(w http.ResponseWriter, r *http.Request)
}

type ResourceGroupRestHandlerImpl 

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

func NewResourceGroupRestHandlerImpl 

func NewResourceGroupRestHandlerImpl(logger *zap.SugaredLogger, enforcer casbin.Enforcer,
	userService user.UserService, resourceGroupService resourceGroup.ResourceGroupService,
	validator *validator.Validate) *ResourceGroupRestHandlerImpl

func (ResourceGroupRestHandlerImpl) CheckResourceGroupPermissions 

func (handler ResourceGroupRestHandlerImpl) CheckResourceGroupPermissions(w http.ResponseWriter, r *http.Request)

func (ResourceGroupRestHandlerImpl) CreateResourceGroup 

func (handler ResourceGroupRestHandlerImpl) CreateResourceGroup(w http.ResponseWriter, r *http.Request)
func (handler ResourceGroupRestHandlerImpl) GetApplicationsForResourceGroup(w http.ResponseWriter, r *http.Request) {
	userId, err := handler.userService.GetLoggedInUser(r)
	if userId == 0 || err != nil {
		common.WriteJsonResp(w, err, "Unauthorized User", http.StatusUnauthorized)
		return
	}
	token := r.Header.Get("token")
	if ok := handler.enforcer.Enforce(token, casbin.ResourceGlobal, casbin.ActionGet, "*"); !ok {
		common.WriteJsonResp(w, errors.New("unauthorized"), nil, http.StatusForbidden)
		return
	}
	vars := mux.Vars(r)
	id, err := strconv.Atoi(vars["appGroupId"])
	if err != nil {
		common.WriteJsonResp(w, err, "", http.StatusBadRequest)
		return
	}
	//res, err := handler.resourceGroupService.GetApplicationsForResourceGroup(id)
	if err != nil {
		handler.logger.Errorw("service err, GetApplicationsForResourceGroup", "err", err)
		common.WriteJsonResp(w, err, nil, http.StatusInternalServerError)
		return
	}
	common.WriteJsonResp(w, nil, res, http.StatusOK)
}

func (ResourceGroupRestHandlerImpl) DeleteResourceGroup 

func (handler ResourceGroupRestHandlerImpl) DeleteResourceGroup(w http.ResponseWriter, r *http.Request)

func (ResourceGroupRestHandlerImpl) GetActiveResourceGroupList 

func (handler ResourceGroupRestHandlerImpl) GetActiveResourceGroupList(w http.ResponseWriter, r *http.Request)

func (ResourceGroupRestHandlerImpl) UpdateResourceGroup 

func (handler ResourceGroupRestHandlerImpl) UpdateResourceGroup(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 UserAttributesRestHandler 

type UserAttributesRestHandler interface {
	AddUserAttributes(w http.ResponseWriter, r *http.Request)
	UpdateUserAttributes(w http.ResponseWriter, r *http.Request)
	PatchUserAttributes(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) PatchUserAttributes 

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

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       *bean2.GitHostRequest           `json:"gitHost"`
	WebhookEvents []*gitSensor.WebhookEventConfig `json:"webhookEvents"`
}

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, eventClient client.EventClient,
	webhookSecretValidator gitWebhook.WebhookSecretValidator, webhookEventDataConfig pipeline.WebhookEventDataConfig,
	ciPipelineEventPublishService out.CIPipelineEventPublishService,
	gitHostReadService read.GitHostReadService) *WebhookEventHandlerImpl

func (WebhookEventHandlerImpl) OnWebhookEvent 

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

Source Files

View all Source files

Directories

Path Synopsis
app
appInfo
appList
configDiff
pipeline
pipeline/configure
pipeline/configure/bean
pipeline/history
pipeline/status
pipeline/trigger
pipeline/webhook
workflow

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.