Documentation
¶
Index ¶
- type BulkApplicationForEnvironmentPayload
- type BulkApplicationForEnvironmentResponse
- type BulkUpdatePayload
- type BulkUpdateResponse
- type BulkUpdateScript
- type BulkUpdateSeeExampleResponse
- type BulkUpdateService
- type BulkUpdateServiceImpl
- func (impl BulkUpdateServiceImpl) ApplyJsonPatch(patch jsonpatch.Patch, target string) (string, error)
- func (impl BulkUpdateServiceImpl) BulkBuildTrigger(request *BulkApplicationForEnvironmentPayload, ctx context.Context, ...) (*BulkApplicationForEnvironmentResponse, error)
- func (impl BulkUpdateServiceImpl) BulkDeploy(request *BulkApplicationForEnvironmentPayload, emailId string, ...) (*BulkApplicationForEnvironmentResponse, error)
- func (impl BulkUpdateServiceImpl) BulkHibernate(request *BulkApplicationForEnvironmentPayload, ctx context.Context, ...) (*BulkApplicationForEnvironmentResponse, error)
- func (impl BulkUpdateServiceImpl) BulkUnHibernate(request *BulkApplicationForEnvironmentPayload, ctx context.Context, ...) (*BulkApplicationForEnvironmentResponse, error)
- func (impl BulkUpdateServiceImpl) BulkUpdate(bulkUpdatePayload *BulkUpdatePayload) *BulkUpdateResponse
- func (impl BulkUpdateServiceImpl) BulkUpdateConfigMap(bulkUpdatePayload *BulkUpdatePayload) *CmAndSecretBulkUpdateResponse
- func (impl BulkUpdateServiceImpl) BulkUpdateDeploymentTemplate(bulkUpdatePayload *BulkUpdatePayload) *DeploymentTemplateBulkUpdateResponse
- func (impl BulkUpdateServiceImpl) BulkUpdateSecret(bulkUpdatePayload *BulkUpdatePayload) *CmAndSecretBulkUpdateResponse
- func (impl BulkUpdateServiceImpl) FindBulkUpdateReadme(operation string) (*BulkUpdateSeeExampleResponse, error)
- func (impl BulkUpdateServiceImpl) GetBulkActionImpactedPipelinesAndWfs(dto *CdBulkActionRequestDto) ([]*pipelineConfig.Pipeline, []int, []int, error)
- func (impl BulkUpdateServiceImpl) GetBulkAppName(bulkUpdatePayload *BulkUpdatePayload) (*ImpactedObjectsResponse, error)
- func (impl BulkUpdateServiceImpl) PerformBulkActionOnCdPipelines(dto *CdBulkActionRequestDto, impactedPipelines []*pipelineConfig.Pipeline, ...) (*PipelineAndWfBulkActionResponseDto, error)
- func (impl BulkUpdateServiceImpl) PerformBulkDeleteActionOnCdPipelines(impactedPipelines []*pipelineConfig.Pipeline, ctx context.Context, ...) (*PipelineAndWfBulkActionResponseDto, error)
- func (impl BulkUpdateServiceImpl) SubscribeToCdBulkTriggerTopic() error
- type CdBulkAction
- type CdBulkActionRequestDto
- type CdBulkActionResponseDto
- type CiBulkActionResponseDto
- type CmAndSecretBulkUpdateResponse
- type CmAndSecretBulkUpdateResponseForOneApp
- type CmAndSecretImpactedObjectsResponseForOneApp
- type CmAndSecretSpec
- type CmAndSecretTask
- type DeploymentTemplateBulkUpdateResponse
- type DeploymentTemplateBulkUpdateResponseForOneApp
- type DeploymentTemplateImpactedObjectsResponseForOneApp
- type DeploymentTemplateSpec
- type DeploymentTemplateTask
- type ImpactedObjectsResponse
- type NameIncludesExcludes
- type PipelineAndWfBulkActionResponseDto
- type WfBulkActionResponseDto
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BulkApplicationForEnvironmentResponse ¶
type BulkApplicationForEnvironmentResponse struct { BulkApplicationForEnvironmentPayload Response map[string]map[string]bool `json:"response"` }
type BulkUpdatePayload ¶
type BulkUpdatePayload struct { Includes *NameIncludesExcludes `json:"includes"` Excludes *NameIncludesExcludes `json:"excludes"` EnvIds []int `json:"envIds"` Global bool `json:"global"` DeploymentTemplate *DeploymentTemplateTask `json:"deploymentTemplate"` ConfigMap *CmAndSecretTask `json:"configMap"` Secret *CmAndSecretTask `json:"secret"` }
type BulkUpdateResponse ¶
type BulkUpdateResponse struct { DeploymentTemplate *DeploymentTemplateBulkUpdateResponse `json:"deploymentTemplate"` ConfigMap *CmAndSecretBulkUpdateResponse `json:"configMap"` Secret *CmAndSecretBulkUpdateResponse `json:"secret"` }
type BulkUpdateScript ¶
type BulkUpdateScript struct { ApiVersion string `json:"apiVersion" validate:"required"` Kind string `json:"kind" validate:"required"` Spec *BulkUpdatePayload `json:"spec" validate:"required"` }
type BulkUpdateSeeExampleResponse ¶
type BulkUpdateSeeExampleResponse struct { Operation string `json:"operation"` Script *BulkUpdateScript `json:"script" validate:"required"` ReadMe string `json:"readme"` }
type BulkUpdateService ¶
type BulkUpdateService interface { FindBulkUpdateReadme(operation string) (response *BulkUpdateSeeExampleResponse, err error) GetBulkAppName(bulkUpdateRequest *BulkUpdatePayload) (*ImpactedObjectsResponse, error) ApplyJsonPatch(patch jsonpatch.Patch, target string) (string, error) BulkUpdateDeploymentTemplate(bulkUpdatePayload *BulkUpdatePayload) *DeploymentTemplateBulkUpdateResponse BulkUpdateConfigMap(bulkUpdatePayload *BulkUpdatePayload) *CmAndSecretBulkUpdateResponse BulkUpdateSecret(bulkUpdatePayload *BulkUpdatePayload) *CmAndSecretBulkUpdateResponse BulkUpdate(bulkUpdateRequest *BulkUpdatePayload) (bulkUpdateResponse *BulkUpdateResponse) BulkHibernate(request *BulkApplicationForEnvironmentPayload, ctx context.Context, w http.ResponseWriter, token string, checkAuthForBulkActions func(token string, appObject string, envObject string) bool) (*BulkApplicationForEnvironmentResponse, error) BulkUnHibernate(request *BulkApplicationForEnvironmentPayload, ctx context.Context, w http.ResponseWriter, token string, checkAuthForBulkActions func(token string, appObject string, envObject string) bool) (*BulkApplicationForEnvironmentResponse, error) BulkDeploy(request *BulkApplicationForEnvironmentPayload, emailId string, checkAuthBatch func(emailId string, appObject []string, envObject []string) (map[string]bool, map[string]bool)) (*BulkApplicationForEnvironmentResponse, error) BulkBuildTrigger(request *BulkApplicationForEnvironmentPayload, ctx context.Context, w http.ResponseWriter, token string, checkAuthForBulkActions func(token string, appObject string, envObject string) bool) (*BulkApplicationForEnvironmentResponse, error) GetBulkActionImpactedPipelinesAndWfs(dto *CdBulkActionRequestDto) ([]*pipelineConfig.Pipeline, []int, []int, error) PerformBulkActionOnCdPipelines(dto *CdBulkActionRequestDto, impactedPipelines []*pipelineConfig.Pipeline, ctx context.Context, dryRun bool, impactedAppWfIds []int, impactedCiPipelineIds []int) (*PipelineAndWfBulkActionResponseDto, error) }
type BulkUpdateServiceImpl ¶
type BulkUpdateServiceImpl struct {
// contains filtered or unexported fields
}
func NewBulkUpdateServiceImpl ¶
func NewBulkUpdateServiceImpl(bulkUpdateRepository bulkUpdate.BulkUpdateRepository, chartRepository chartRepoRepository.ChartRepository, logger *zap.SugaredLogger, chartTemplateService util.ChartTemplateService, repoRepository chartRepoRepository.ChartRepoRepository, defaultChart chart.DefaultChart, mergeUtil util.MergeUtil, repositoryService repository.ServiceClient, chartRefRepository chartRepoRepository.ChartRefRepository, envOverrideRepository chartConfig.EnvConfigOverrideRepository, pipelineConfigRepository chartConfig.PipelineConfigRepository, configMapRepository chartConfig.ConfigMapRepository, environmentRepository repository2.EnvironmentRepository, pipelineRepository pipelineConfig.PipelineRepository, appLevelMetricsRepository repository3.AppLevelMetricsRepository, envLevelAppMetricsRepository repository3.EnvLevelAppMetricsRepository, client *http.Client, appRepository app.AppRepository, deploymentTemplateHistoryService history.DeploymentTemplateHistoryService, configMapHistoryService history.ConfigMapHistoryService, workflowDagExecutor pipeline.WorkflowDagExecutor, cdWorkflowRepository pipelineConfig.CdWorkflowRepository, pipelineBuilder pipeline.PipelineBuilder, helmAppService client.HelmAppService, enforcerUtil rbac.EnforcerUtil, enforcerUtilHelm rbac.EnforcerUtilHelm, ciHandler pipeline.CiHandler, ciPipelineRepository pipelineConfig.CiPipelineRepository, appWorkflowRepository appWorkflow.AppWorkflowRepository, appWorkflowService appWorkflow2.AppWorkflowService, pubsubClient *pubsub.PubSubClientServiceImpl, argoUserService argo.ArgoUserService) (*BulkUpdateServiceImpl, error)
func (BulkUpdateServiceImpl) ApplyJsonPatch ¶
func (BulkUpdateServiceImpl) BulkBuildTrigger ¶
func (impl BulkUpdateServiceImpl) BulkBuildTrigger(request *BulkApplicationForEnvironmentPayload, ctx context.Context, w http.ResponseWriter, token string, checkAuthForBulkActions func(token string, appObject string, envObject string) bool) (*BulkApplicationForEnvironmentResponse, error)
func (BulkUpdateServiceImpl) BulkDeploy ¶
func (impl BulkUpdateServiceImpl) BulkDeploy(request *BulkApplicationForEnvironmentPayload, emailId string, checkAuthBatch func(emailId string, appObject []string, envObject []string) (map[string]bool, map[string]bool)) (*BulkApplicationForEnvironmentResponse, error)
func (BulkUpdateServiceImpl) BulkHibernate ¶
func (impl BulkUpdateServiceImpl) BulkHibernate(request *BulkApplicationForEnvironmentPayload, ctx context.Context, w http.ResponseWriter, token string, checkAuthForBulkActions func(token string, appObject string, envObject string) bool) (*BulkApplicationForEnvironmentResponse, error)
func (BulkUpdateServiceImpl) BulkUnHibernate ¶
func (impl BulkUpdateServiceImpl) BulkUnHibernate(request *BulkApplicationForEnvironmentPayload, ctx context.Context, w http.ResponseWriter, token string, checkAuthForBulkActions func(token string, appObject string, envObject string) bool) (*BulkApplicationForEnvironmentResponse, error)
func (BulkUpdateServiceImpl) BulkUpdate ¶
func (impl BulkUpdateServiceImpl) BulkUpdate(bulkUpdatePayload *BulkUpdatePayload) *BulkUpdateResponse
func (BulkUpdateServiceImpl) BulkUpdateConfigMap ¶
func (impl BulkUpdateServiceImpl) BulkUpdateConfigMap(bulkUpdatePayload *BulkUpdatePayload) *CmAndSecretBulkUpdateResponse
func (BulkUpdateServiceImpl) BulkUpdateDeploymentTemplate ¶
func (impl BulkUpdateServiceImpl) BulkUpdateDeploymentTemplate(bulkUpdatePayload *BulkUpdatePayload) *DeploymentTemplateBulkUpdateResponse
func (BulkUpdateServiceImpl) BulkUpdateSecret ¶
func (impl BulkUpdateServiceImpl) BulkUpdateSecret(bulkUpdatePayload *BulkUpdatePayload) *CmAndSecretBulkUpdateResponse
func (BulkUpdateServiceImpl) FindBulkUpdateReadme ¶
func (impl BulkUpdateServiceImpl) FindBulkUpdateReadme(operation string) (*BulkUpdateSeeExampleResponse, error)
func (BulkUpdateServiceImpl) GetBulkActionImpactedPipelinesAndWfs ¶
func (impl BulkUpdateServiceImpl) GetBulkActionImpactedPipelinesAndWfs(dto *CdBulkActionRequestDto) ([]*pipelineConfig.Pipeline, []int, []int, error)
func (BulkUpdateServiceImpl) GetBulkAppName ¶
func (impl BulkUpdateServiceImpl) GetBulkAppName(bulkUpdatePayload *BulkUpdatePayload) (*ImpactedObjectsResponse, error)
func (BulkUpdateServiceImpl) PerformBulkActionOnCdPipelines ¶
func (impl BulkUpdateServiceImpl) PerformBulkActionOnCdPipelines(dto *CdBulkActionRequestDto, impactedPipelines []*pipelineConfig.Pipeline, ctx context.Context, dryRun bool, impactedAppWfIds []int, impactedCiPipelineIds []int) (*PipelineAndWfBulkActionResponseDto, error)
func (BulkUpdateServiceImpl) PerformBulkDeleteActionOnCdPipelines ¶
func (impl BulkUpdateServiceImpl) PerformBulkDeleteActionOnCdPipelines(impactedPipelines []*pipelineConfig.Pipeline, ctx context.Context, dryRun, forceDelete, deleteWfAndCiPipeline bool, impactedAppWfIds, impactedCiPipelineIds []int, userId int32) (*PipelineAndWfBulkActionResponseDto, error)
func (BulkUpdateServiceImpl) SubscribeToCdBulkTriggerTopic ¶ added in v0.6.16
func (impl BulkUpdateServiceImpl) SubscribeToCdBulkTriggerTopic() error
type CdBulkActionRequestDto ¶
type CdBulkActionRequestDto struct { Action CdBulkAction `json:"action"` EnvIds []int `json:"envIds"` EnvNames []string `json:"envNames"` AppIds []int `json:"appIds"` AppNames []string `json:"appNames"` ProjectIds []int `json:"projectIds"` ProjectNames []string `json:"projectNames"` DeleteWfAndCiPipeline bool `json:"deleteWfAndCiPipeline"` ForceDelete bool `json:"forceDelete"` UserId int32 `json:"-"` }
type CdBulkActionResponseDto ¶
type CiBulkActionResponseDto ¶
type CmAndSecretBulkUpdateResponse ¶
type CmAndSecretBulkUpdateResponse struct { Message []string `json:"message"` Failure []*CmAndSecretBulkUpdateResponseForOneApp `json:"failure"` Successful []*CmAndSecretBulkUpdateResponseForOneApp `json:"successful"` }
type CmAndSecretSpec ¶
type CmAndSecretTask ¶
type CmAndSecretTask struct {
Spec *CmAndSecretSpec `json:"spec"`
}
type DeploymentTemplateBulkUpdateResponse ¶
type DeploymentTemplateBulkUpdateResponse struct { Message []string `json:"message"` Failure []*DeploymentTemplateBulkUpdateResponseForOneApp `json:"failure"` Successful []*DeploymentTemplateBulkUpdateResponseForOneApp `json:"successful"` }
type DeploymentTemplateSpec ¶
type DeploymentTemplateSpec struct {
PatchJson string `json:"patchJson"`
}
type DeploymentTemplateTask ¶
type DeploymentTemplateTask struct {
Spec *DeploymentTemplateSpec `json:"spec"`
}
type ImpactedObjectsResponse ¶
type ImpactedObjectsResponse struct { DeploymentTemplate []*DeploymentTemplateImpactedObjectsResponseForOneApp `json:"deploymentTemplate"` ConfigMap []*CmAndSecretImpactedObjectsResponseForOneApp `json:"configMap"` Secret []*CmAndSecretImpactedObjectsResponseForOneApp `json:"secret"` }
type NameIncludesExcludes ¶
type NameIncludesExcludes struct {
Names []string `json:"names"`
}
type PipelineAndWfBulkActionResponseDto ¶
type PipelineAndWfBulkActionResponseDto struct { CdPipelinesRespDtos []*CdBulkActionResponseDto `json:"cdPipelines"` CiPipelineRespDtos []*CiBulkActionResponseDto `json:"ciPipelines"` AppWfRespDtos []*WfBulkActionResponseDto `json:"appWorkflows"` }
type WfBulkActionResponseDto ¶
Click to show internal directories.
Click to hide internal directories.