restHandler

package
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: Jun 7, 2024 License: Apache-2.0 Imports: 80 Imported by: 6

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 (
	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 added in v0.6.19 

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 added in v0.6.19 

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 added in v0.6.6 

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 added in v0.6.6 

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

func NewBulkUpdateRestHandlerImpl added in v0.6.6 

func NewBulkUpdateRestHandlerImpl(pipelineBuilder pipeline.PipelineBuilder, logger *zap.SugaredLogger,
	bulkUpdateService bulkAction.BulkUpdateService,
	chartService chart.ChartService,
	propertiesConfigService pipeline.PropertiesConfigService,
	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 added in v0.6.6 

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

func (BulkUpdateRestHandlerImpl) BulkDeploy added in v0.6.6 

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

func (BulkUpdateRestHandlerImpl) BulkHibernate added in v0.6.6 

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

func (BulkUpdateRestHandlerImpl) BulkUnHibernate added in v0.6.6 

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

func (BulkUpdateRestHandlerImpl) BulkUpdate added in v0.6.6 

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

func (BulkUpdateRestHandlerImpl) CheckAuthForBulkUpdate added in v0.6.6 

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

func (BulkUpdateRestHandlerImpl) CheckAuthForImpactedObjects added in v0.6.6 

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

func (BulkUpdateRestHandlerImpl) FindBulkUpdateReadme added in v0.6.6 

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

func (BulkUpdateRestHandlerImpl) GetImpactedAppsName added in v0.6.6 

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

func (BulkUpdateRestHandlerImpl) HandleCdPipelineBulkAction added in v0.6.6 

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   []*notifier.SlackConfigDto   `json:"slackConfigs"`
	WebhookConfigs []*notifier.WebhookConfigDto `json:"webhookConfigs"`
	SESConfigs     []*notifier.SESConfigDto     `json:"sesConfigs"`
	SMTPConfigs    []*notifier.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 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,
	userAuthService user.UserService,
	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 added in v0.6.21 

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 added in v0.6.22 

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 added in v0.6.22 

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 added in v0.6.21 

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

func (ConfigMapRestHandlerImpl) RemoveEnvironmentFromJob added in v0.6.21 

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

type CoreAppRestHandler added in v0.6.6 

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 added in v0.6.6 

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

func NewCoreAppRestHandlerImpl added in v0.6.6 

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,
	chartRepo chartRepoRepository.ChartRepository, teamService team.TeamService,
	argoUserService argo.ArgoUserService, pipelineStageService pipeline.PipelineStageService, ciPipelineRepository pipelineConfig.CiPipelineRepository) *CoreAppRestHandlerImpl

func (CoreAppRestHandlerImpl) CreateApp added in v0.6.6 

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

func (CoreAppRestHandlerImpl) CreateAppWorkflow added in v0.6.6 

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

func (CoreAppRestHandlerImpl) GetAppAllDetail added in v0.6.6 

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

func (CoreAppRestHandlerImpl) GetAppWorkflow added in v0.6.6 

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

func (CoreAppRestHandlerImpl) GetAppWorkflowAndOverridesSample added in v0.6.6 

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

func (CoreAppRestHandlerImpl) ValidateAppWorkflowRequest added in v0.6.23 

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 added in v0.6.23 

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

func NewDockerRegRestHandlerExtendedImpl added in v0.6.23 

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 added in v0.6.23 

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

func (DockerRegRestHandlerExtendedImpl) FetchAllDockerAccounts added in v0.6.23 

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

func (DockerRegRestHandlerExtendedImpl) FetchOneDockerAccounts added in v0.6.23 

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 added in v0.6.6 

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 added in v0.6.27 

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

func (DockerRegRestHandlerImpl) UpdateDockerRegistryConfig 

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

func (DockerRegRestHandlerImpl) ValidateDockerRegistryConfig added in v0.6.23 

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 added in v0.6.6 

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 added in v0.6.6 

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

func NewGitHostRestHandlerImpl added in v0.6.6 

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 added in v0.6.6 

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

func (GitHostRestHandlerImpl) GetAllWebhookEventConfig added in v0.6.6 

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 added in v0.6.6 

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 added in v0.6.6 

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

func (GitHostRestHandlerImpl) GetWebhookDataMetaConfig added in v0.6.6 

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 added in v0.6.6 

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) *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 added in v0.6.6 

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,
	userAuthService user.UserService,
	validator *validator.Validate, enforcer casbin.Enforcer, teamService team.TeamService,
	deleteServiceFullMode delete2.DeleteServiceFullMode) *GitProviderRestHandlerImpl

func (GitProviderRestHandlerImpl) DeleteGitRepoConfig added in v0.6.6 

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 added in v0.6.6 

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 added in v0.6.6 

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

func NewGlobalCMCSRestHandlerImpl added in v0.6.6 

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

func (*GlobalCMCSRestHandlerImpl) CreateGlobalCMCSConfig added in v0.6.6 

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

func (*GlobalCMCSRestHandlerImpl) DeleteByID added in v0.6.15 

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

func (*GlobalCMCSRestHandlerImpl) GetAllGlobalCMCSData added in v0.6.15 

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

func (*GlobalCMCSRestHandlerImpl) GetGlobalCMCSDataByConfigTypeAndName added in v0.6.15 

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

func (*GlobalCMCSRestHandlerImpl) UpdateGlobalCMCSDataById added in v0.6.15 

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

type GlobalPluginRestHandler added in v0.6.6 

type GlobalPluginRestHandler interface {
	PatchPlugin(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)
}

type GlobalPluginRestHandlerImpl added in v0.6.6 

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

func NewGlobalPluginRestHandler added in v0.6.6 

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

func (*GlobalPluginRestHandlerImpl) GetAllDetailedPluginInfo added in v0.6.26 

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

func (*GlobalPluginRestHandlerImpl) GetAllGlobalVariables added in v0.6.6 

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

func (*GlobalPluginRestHandlerImpl) GetDetailedPluginInfoByPluginId added in v0.6.26 

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

func (*GlobalPluginRestHandlerImpl) GetPluginDetailById added in v0.6.6 

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

func (*GlobalPluginRestHandlerImpl) ListAllPlugins added in v0.6.6 

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

func (*GlobalPluginRestHandlerImpl) PatchPlugin added in v0.6.26 

func (handler *GlobalPluginRestHandlerImpl) PatchPlugin(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 MetricsRequest 

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

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,
	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 added in v0.6.6 

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 added in v0.6.6 

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 added in v0.6.18 

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 added in v0.6.18 

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 added in v0.6.6 

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 added in v0.6.6 

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

func NewPProfRestHandler added in v0.6.6 

func NewPProfRestHandler(userService user.UserService,
	enforcer casbin.Enforcer) *PProfRestHandlerImpl

func (PProfRestHandlerImpl) Allocs added in v0.6.6 

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

func (PProfRestHandlerImpl) Block added in v0.6.6 

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

func (PProfRestHandlerImpl) Cmdline added in v0.6.6 

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

func (PProfRestHandlerImpl) Goroutine added in v0.6.6 

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

func (PProfRestHandlerImpl) Heap added in v0.6.6 

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

func (PProfRestHandlerImpl) Index added in v0.6.6 

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

func (PProfRestHandlerImpl) Mutex added in v0.6.6 

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

func (PProfRestHandlerImpl) Profile added in v0.6.6 

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

func (PProfRestHandlerImpl) Symbol added in v0.6.6 

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

func (PProfRestHandlerImpl) Threadcreate added in v0.6.6 

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

func (PProfRestHandlerImpl) Trace added in v0.6.6 

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 security.PolicyService,
	userService user2.UserService, userAuthService user2.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 *types.CiCdConfig) *PubSubClientRestHandlerImpl

func (*PubSubClientRestHandlerImpl) PublishEventsToNats 

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

type PublishRequest added in v0.6.12 

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 added in v0.6.24 

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 added in v0.6.24 

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

func NewResourceGroupRestHandlerImpl added in v0.6.24 

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

func (ResourceGroupRestHandlerImpl) CheckResourceGroupPermissions added in v0.6.24 

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

func (ResourceGroupRestHandlerImpl) CreateResourceGroup added in v0.6.24 

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 added in v0.6.24 

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

func (ResourceGroupRestHandlerImpl) GetActiveResourceGroupList added in v0.6.24 

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

func (ResourceGroupRestHandlerImpl) UpdateResourceGroup added in v0.6.24 

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

type TelemetryGenericEvent added in v0.6.6 

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

type TelemetryRestHandler added in v0.2.14 

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 added in v0.2.14 

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

func NewTelemetryRestHandlerImpl added in v0.2.14 

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

func (TelemetryRestHandlerImpl) GetTelemetryMetaInfo added in v0.2.15 

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

func (TelemetryRestHandlerImpl) SendSummaryEvent added in v0.6.6 

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

func (TelemetryRestHandlerImpl) SendTelemetryData added in v0.6.6 

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

type UserAttributesRestHandler added in v0.6.6 

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 added in v0.6.6 

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

func NewUserAttributesRestHandlerImpl added in v0.6.6 

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

func (*UserAttributesRestHandlerImpl) AddUserAttributes added in v0.6.6 

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

func (*UserAttributesRestHandlerImpl) GetUserAttribute added in v0.6.6 

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 added in v0.6.6 

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 added in v0.6.6 

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

type WebhookEventHandler added in v0.6.6 

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

type WebhookEventHandlerImpl added in v0.6.6 

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

func NewWebhookEventHandlerImpl added in v0.6.6 

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

func (WebhookEventHandlerImpl) OnWebhookEvent added in v0.6.6 

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

Source Files

View all Source files

Directories

Path Synopsis
app
appInfo
appList
pipeline
pipeline/configure
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.