restHandler

package
v0.6.18-rc.4 Latest Latest
Warning

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

 Go to latest Published: Jun 28, 2023 License: Apache-2.0 Imports: 94 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."
	WORKFLOW_NAME_EMPTY                 = ""
)
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 CHART_GROUP_DELETE_SUCCESS_RESP = "Chart group deleted successfully."
View Source 
const GIT_ACCOUNT_DELETE_SUCCESS_RESP = "Git account deleted successfully."
View Source 
const REG_DELETE_SUCCESS_RESP = "Container Registry deleted successfully."

Variables

This section is empty.

Functions

func ExtractErrorType added in v0.6.6 

func ExtractErrorType(err error) int

Types

type AppAutocomplete added in v0.6.17 

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

type AppGroupRestHandler added in v0.6.17 

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

type AppGroupRestHandlerImpl added in v0.6.17 

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

func NewAppGroupRestHandlerImpl added in v0.6.17 

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

func (AppGroupRestHandlerImpl) CreateAppGroup added in v0.6.17 

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

func (AppGroupRestHandlerImpl) DeleteAppGroup added in v0.6.17 

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

func (AppGroupRestHandlerImpl) GetActiveAppGroupList added in v0.6.17 

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

func (AppGroupRestHandlerImpl) GetApplicationsForAppGroup added in v0.6.17 

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

func (AppGroupRestHandlerImpl) UpdateAppGroup added in v0.6.17 

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

type AppListingRestHandler 

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

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

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

type AppListingRestHandlerImpl 

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

func NewAppListingRestHandlerImpl 

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

func (AppListingRestHandlerImpl) FetchAllDevtronManagedApps added in v0.6.9 

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

func (AppListingRestHandlerImpl) FetchAppDetails 

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

func (AppListingRestHandlerImpl) FetchAppDetailsV2 added in v0.6.17 

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

func (AppListingRestHandlerImpl) FetchAppStageStatus 

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

func (AppListingRestHandlerImpl) FetchAppTriggerView 

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

func (AppListingRestHandlerImpl) FetchAppsByEnvironment 

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

func (AppListingRestHandlerImpl) FetchAppsByEnvironmentV1 added in v0.6.17 

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

func (AppListingRestHandlerImpl) FetchAppsByEnvironmentV2 added in v0.6.17 

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

func (AppListingRestHandlerImpl) FetchAppsByEnvironmentVersioned added in v0.6.17 

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

func (AppListingRestHandlerImpl) FetchJobOverviewCiPipelines added in v0.6.15 

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

func (AppListingRestHandlerImpl) FetchJobs added in v0.6.15 

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

func (AppListingRestHandlerImpl) FetchMinDetailOtherEnvironment added in v0.6.17 

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

func (AppListingRestHandlerImpl) FetchOtherEnvironment 

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

func (AppListingRestHandlerImpl) FetchOverviewAppsByEnvironment added in v0.6.17 

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

func (AppListingRestHandlerImpl) FetchResourceTree added in v0.6.17 

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

func (AppListingRestHandlerImpl) GetClusterTeamAndEnvListForAutocomplete added in v0.6.17 

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

func (AppListingRestHandlerImpl) GetHostUrlsByBatch added in v0.6.6 

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

func (AppListingRestHandlerImpl) ManualSyncAcdPipelineDeploymentStatus added in v0.6.11 

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

func (AppListingRestHandlerImpl) RedirectToLinkouts 

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

type AppRestHandler added in v0.6.11 

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

type AppRestHandlerImpl added in v0.6.6 

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

func NewAppRestHandlerImpl added in v0.6.6 

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

func (AppRestHandlerImpl) GetAllLabels added in v0.6.6 

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

func (AppRestHandlerImpl) GetAppListByTeamIds added in v0.6.11 

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

func (AppRestHandlerImpl) GetAppMetaInfo added in v0.6.6 

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

func (AppRestHandlerImpl) GetHelmAppMetaInfo added in v0.6.11 

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

func (AppRestHandlerImpl) UpdateApp added in v0.6.6 

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

func (AppRestHandlerImpl) UpdateProjectForApps added in v0.6.6 

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

type AppStatus 

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

type AppWorkflowRestHandler 

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

type AppWorkflowRestHandlerImpl 

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

func NewAppWorkflowRestHandlerImpl 

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

func (AppWorkflowRestHandlerImpl) CreateAppWorkflow 

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

func (AppWorkflowRestHandlerImpl) DeleteAppWorkflow 

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

func (AppWorkflowRestHandlerImpl) FindAllWorkflows added in v0.6.6 

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

func (AppWorkflowRestHandlerImpl) FindAppWorkflow 

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

func (AppWorkflowRestHandlerImpl) FindAppWorkflowByEnvironment added in v0.6.13 

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

func (*AppWorkflowRestHandlerImpl) GetWorkflowsViewData added in v0.6.17 

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

type ArgoApplicationRestHandler added in v0.6.6 

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

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

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

type ArgoApplicationRestHandlerImpl added in v0.6.6 

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

func NewArgoApplicationRestHandlerImpl added in v0.6.6 

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

func (ArgoApplicationRestHandlerImpl) DeleteResource added in v0.6.6 

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

func (ArgoApplicationRestHandlerImpl) Get added in v0.6.6 

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

func (ArgoApplicationRestHandlerImpl) GetManifests added in v0.6.6 

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

func (ArgoApplicationRestHandlerImpl) GetPodLogs added in v0.6.6 

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

func (ArgoApplicationRestHandlerImpl) GetResource added in v0.6.6 

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

func (ArgoApplicationRestHandlerImpl) GetResourceTree added in v0.6.6 

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

func (ArgoApplicationRestHandlerImpl) GetTerminalSession added in v0.6.6 

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

func (ArgoApplicationRestHandlerImpl) List added in v0.6.6 

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

func (ArgoApplicationRestHandlerImpl) ListResourceEvents added in v0.6.6 

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

func (ArgoApplicationRestHandlerImpl) ManagedResources added in v0.6.6 

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

func (ArgoApplicationRestHandlerImpl) PatchResource added in v0.6.6 

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

func (ArgoApplicationRestHandlerImpl) Rollback added in v0.6.6 

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

func (ArgoApplicationRestHandlerImpl) TerminateOperation added in v0.6.6 

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

func (ArgoApplicationRestHandlerImpl) Watch added in v0.6.6 

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

type AttributesRestHandler 

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

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) 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,
	dbMigrationService pipeline.DbMigrationService,
	application application.ServiceClient,
	userAuthService user.UserService,
	teamService team.TeamService,
	enforcer casbin.Enforcer,
	ciHandler pipeline.CiHandler,
	validator *validator.Validate,
	gitSensorClient gitSensor.Client,
	ciPipelineRepository pipelineConfig.CiPipelineRepository, pipelineRepository pipelineConfig.PipelineRepository,
	enforcerUtil rbac.EnforcerUtil, envService request.EnvironmentService,
	gitRegistryConfig pipeline.GitRegistryConfig, dockerRegistryConfig pipeline.DockerRegistryConfig,
	cdHandelr pipeline.CdHandler,
	appCloneService appClone.AppCloneService,
	appWorkflowService appWorkflow.AppWorkflowService,
	materialRepository pipelineConfig.MaterialRepository, policyService security2.PolicyService,
	scanResultRepository security.ImageScanResultRepository,
	argoUserService argo.ArgoUserService) *BulkUpdateRestHandlerImpl

func (BulkUpdateRestHandlerImpl) BulkBuildTrigger 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 CDRestHandler 

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

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

type CDRestHandlerImpl 

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

func NewCDRestHandlerImpl 

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

func (CDRestHandlerImpl) FetchPodContainerLogs 

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

func (CDRestHandlerImpl) FetchResourceTree 

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

type ChannelDto 

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

type ChannelResponseDTO 

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

type ChartGroupRestHandler 

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

type ChartGroupRestHandlerImpl 

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

func NewChartGroupRestHandlerImpl 

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

func (*ChartGroupRestHandlerImpl) CreateChartGroup 

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

func (*ChartGroupRestHandlerImpl) DeleteChartGroup added in v0.6.6 

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

func (*ChartGroupRestHandlerImpl) GetChartGroupInstallationDetail 

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

func (*ChartGroupRestHandlerImpl) GetChartGroupList 

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

func (*ChartGroupRestHandlerImpl) GetChartGroupListMin 

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

func (*ChartGroupRestHandlerImpl) GetChartGroupWithChartMetaData 

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

func (*ChartGroupRestHandlerImpl) SaveChartGroupEntries 

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

func (*ChartGroupRestHandlerImpl) UpdateChartGroup 

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

type ChartRefRestHandler 

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

type ChartRefRestHandlerImpl 

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

func NewChartRefRestHandlerImpl 

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

func (ChartRefRestHandlerImpl) ChartRefAutocomplete 

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

func (ChartRefRestHandlerImpl) ChartRefAutocompleteForApp 

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

func (ChartRefRestHandlerImpl) ChartRefAutocompleteForEnv 

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

type CommonRestHanlder 

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

type CommonRestHanlderImpl 

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

func NewCommonRestHanlderImpl 

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

func (CommonRestHanlderImpl) GlobalChecklist 

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

type ConfigMapRestHandler 

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

	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)
}

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) 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) 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) 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)

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,
	envConfigRepo chartConfig.EnvConfigOverrideRepository, chartRepo chartRepoRepository.ChartRepository, teamService team.TeamService,
	argoUserService argo.ArgoUserService, pipelineStageService pipeline.PipelineStageService) *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)

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)
	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 DockerRegRestHandlerImpl 

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

func NewDockerRegRestHandlerImpl 

func NewDockerRegRestHandlerImpl(dockerRegistryConfig pipeline.DockerRegistryConfig,
	logger *zap.SugaredLogger,
	gitRegistryConfig pipeline.GitRegistryConfig,
	dbConfigService pipeline.DbConfigService, userAuthService user.UserService,
	validator *validator.Validate, enforcer casbin.Enforcer, teamService team.TeamService,
	deleteServiceFullMode delete2.DeleteServiceFullMode) *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) UpdateDockerRegistryConfig 

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

type ExternalCiRestHandler 

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

type ExternalCiRestHandlerImpl 

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

func NewExternalCiRestHandlerImpl 

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

func (ExternalCiRestHandlerImpl) HandleExternalCiWebhook 

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

type GitHostRestHandler 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, gitOpsRepository repository.GitOpsConfigRepository) *GitOpsConfigRestHandlerImpl

func (GitOpsConfigRestHandlerImpl) CreateGitOpsConfig 

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

func (GitOpsConfigRestHandlerImpl) GetAllGitOpsConfig 

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

func (GitOpsConfigRestHandlerImpl) GetGitOpsConfigById 

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

func (GitOpsConfigRestHandlerImpl) GetGitOpsConfigByProvider 

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

func (GitOpsConfigRestHandlerImpl) GitOpsConfigured 

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

func (GitOpsConfigRestHandlerImpl) GitOpsValidator 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,
	dbConfigService pipeline.DbConfigService, 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 {
	GetAllGlobalVariables(w http.ResponseWriter, r *http.Request)
	ListAllPlugins(w http.ResponseWriter, r *http.Request)
	GetPluginDetailById(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) *GlobalPluginRestHandlerImpl

func (*GlobalPluginRestHandlerImpl) GetAllGlobalVariables added in v0.6.6 

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

type ImageScanRestHandler 

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

type ImageScanRestHandlerImpl 

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

func NewImageScanRestHandlerImpl 

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

func (ImageScanRestHandlerImpl) FetchExecutionDetail 

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

func (ImageScanRestHandlerImpl) FetchMinScanResultByAppIdAndEnvId 

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

func (ImageScanRestHandlerImpl) ScanExecutionList 

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

func (ImageScanRestHandlerImpl) VulnerabilityExposure 

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

type JiraRestHandler 

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

type JiraRestHandlerImpl 

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

func NewJiraRestHandlerImpl 

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

func (JiraRestHandlerImpl) SaveAccountConfig 

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

func (JiraRestHandlerImpl) UpdateIssueStatus 

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

type MetricsRequest 

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

type MigrateDbRestHandler 

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

type MigrateDbRestHandlerImpl 

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

func NewMigrateDbRestHandlerImpl 

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

func (MigrateDbRestHandlerImpl) FetchAllDbConfig 

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

func (MigrateDbRestHandlerImpl) FetchDbConfigForAutoComp 

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

func (MigrateDbRestHandlerImpl) FetchOneDbConfig 

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

func (MigrateDbRestHandlerImpl) SaveDbConfig 

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

func (MigrateDbRestHandlerImpl) UpdateDbConfig 

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

type NotificationRestHandler 

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

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

type NotificationRestHandlerImpl 

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

func NewNotificationRestHandlerImpl 

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

func (NotificationRestHandlerImpl) DeleteNotificationChannelConfig 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) *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 PipelineHistoryRestHandler added in v0.6.6 

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

type PipelineHistoryRestHandlerImpl added in v0.6.6 

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

func NewPipelineHistoryRestHandlerImpl added in v0.6.6 

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

func (*PipelineHistoryRestHandlerImpl) FetchDeployedConfigurationsForWorkflow added in v0.6.6 

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

func (*PipelineHistoryRestHandlerImpl) FetchDeployedHistoryComponentDetail added in v0.6.6 

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

func (*PipelineHistoryRestHandlerImpl) FetchDeployedHistoryComponentList added in v0.6.6 

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

func (*PipelineHistoryRestHandlerImpl) GetAllDeployedConfigurationHistoryForLatestWfrIdForPipeline added in v0.6.6 

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

func (*PipelineHistoryRestHandlerImpl) GetAllDeployedConfigurationHistoryForSpecificWfrIdForPipeline added in v0.6.6 

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

type PipelineStatusTimelineRestHandler added in v0.6.6 

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

type PipelineStatusTimelineRestHandlerImpl added in v0.6.6 

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

func NewPipelineStatusTimelineRestHandlerImpl added in v0.6.6 

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

func (*PipelineStatusTimelineRestHandlerImpl) FetchTimelines added in v0.6.6 

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

type PipelineTriggerRestHandler 

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

type PipelineTriggerRestHandlerImpl 

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

func NewPipelineRestHandler 

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

func (PipelineTriggerRestHandlerImpl) GetAllLatestDeploymentConfiguration added in v0.6.6 

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

func (PipelineTriggerRestHandlerImpl) OverrideConfig 

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

func (PipelineTriggerRestHandlerImpl) ReleaseStatusUpdate 

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

func (PipelineTriggerRestHandlerImpl) RotatePods added in v0.6.17 

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

func (PipelineTriggerRestHandlerImpl) StartStopApp 

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

func (PipelineTriggerRestHandlerImpl) StartStopDeploymentGroup 

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

type PolicyRestHandler 

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

type PolicyRestHandlerImpl 

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

func NewPolicyRestHandlerImpl 

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

func (PolicyRestHandlerImpl) GetPolicy 

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

func (PolicyRestHandlerImpl) SavePolicy 

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

func (PolicyRestHandlerImpl) UpdatePolicy 

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

func (PolicyRestHandlerImpl) VerifyImage 

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

TODO - move to image-scanner

type PubSubClientRestHandler 

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

type PubSubClientRestHandlerImpl 

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

func NewPubSubClientRestHandlerImpl 

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

func (*PubSubClientRestHandlerImpl) PublishEventsToNats 

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

type PublishRequest 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 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 TestSuitRestHandler 

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

type TestSuitRestHandlerImpl 

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

func NewTestSuitRestHandlerImpl 

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

func (TestSuitRestHandlerImpl) DetailedTestSuites 

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

func (TestSuitRestHandlerImpl) GetAllSuitByID 

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

func (TestSuitRestHandlerImpl) GetAllTestCases 

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

func (TestSuitRestHandlerImpl) GetTestCaseByID 

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

func (TestSuitRestHandlerImpl) GetTestSuites 

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

func (TestSuitRestHandlerImpl) HttpGet 

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

func (TestSuitRestHandlerImpl) RedirectTriggerForApp 

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

func (TestSuitRestHandlerImpl) RedirectTriggerForEnv 

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

func (TestSuitRestHandlerImpl) SuitesProxy 

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

type TestSuiteBean 

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

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

type WebhookDataRestHandler added in v0.6.6 

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

type WebhookDataRestHandlerImpl added in v0.6.6 

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

func NewWebhookDataRestHandlerImpl added in v0.6.6 

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

func (WebhookDataRestHandlerImpl) GetWebhookPayloadDataForPipelineMaterialId added in v0.6.6 

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

func (WebhookDataRestHandlerImpl) GetWebhookPayloadFilterDataForPipelineMaterialId added in v0.6.6 

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

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) *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

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.