Documentation
¶
Index ¶
- Constants
- type AllAppWorkflowComponentDetails
- type AppWorkflowDto
- type AppWorkflowMappingDto
- type AppWorkflowService
- type AppWorkflowServiceImpl
- func (impl AppWorkflowServiceImpl) CheckCdPipelineByCiPipelineId(id int) bool
- func (impl AppWorkflowServiceImpl) CreateAppWorkflow(req AppWorkflowDto) (AppWorkflowDto, error)
- func (impl AppWorkflowServiceImpl) DeleteAppWorkflow(appWorkflowId int, userId int32) error
- func (impl AppWorkflowServiceImpl) FilterWorkflows(triggerViewConfig *TriggerViewWorkflowConfig, envIds []int) (*TriggerViewWorkflowConfig, error)
- func (impl AppWorkflowServiceImpl) FindAllAppWorkflowMapping(workflowIds []int) (map[int][]AppWorkflowMappingDto, error)
- func (impl AppWorkflowServiceImpl) FindAllWorkflowsComponentDetails(appId int) (*AllAppWorkflowComponentDetails, error)
- func (impl AppWorkflowServiceImpl) FindAllWorkflowsForApps(request WorkflowNamesRequest) (*WorkflowNamesResponse, error)
- func (impl AppWorkflowServiceImpl) FindAppWorkflowByCiPipelineId(ciPipelineId int) ([]*appWorkflow.AppWorkflowMapping, error)
- func (impl AppWorkflowServiceImpl) FindAppWorkflowById(Id int, appId int) (AppWorkflowDto, error)
- func (impl AppWorkflowServiceImpl) FindAppWorkflowByName(name string, appId int) (AppWorkflowDto, error)
- func (impl AppWorkflowServiceImpl) FindAppWorkflowMapping(workflowId int) ([]AppWorkflowMappingDto, error)
- func (impl AppWorkflowServiceImpl) FindAppWorkflowMappingByComponent(id int, compType string) ([]*appWorkflow.AppWorkflowMapping, error)
- func (impl AppWorkflowServiceImpl) FindAppWorkflowMappingForEnv(appIds []int) (map[int]*AppWorkflowDto, error)
- func (impl AppWorkflowServiceImpl) FindAppWorkflows(appId int) ([]AppWorkflowDto, error)
- func (impl AppWorkflowServiceImpl) FindAppWorkflowsByEnvironmentId(request resourceGroup2.ResourceGroupingRequest, token string) ([]*AppWorkflowDto, error)
- func (impl AppWorkflowServiceImpl) FindCdPipelinesByAppId(appId int) (*bean.CdPipelines, error)
- func (impl AppWorkflowServiceImpl) IsWorkflowNameFound(workflowName string, appId int) (bool, error)
- func (impl AppWorkflowServiceImpl) SaveAppWorkflowMapping(req AppWorkflowMappingDto) (AppWorkflowMappingDto, error)
- type PipelineIdentifier
- type TriggerViewWorkflowConfig
- type WorkflowCloneRequest
- type WorkflowComponentNamesDto
- type WorkflowNamesRequest
- type WorkflowNamesResponse
Constants ¶
View Source
const ( CI_PIPELINE_TYPE = "CI_PIPELINE" CD_PIPELINE_TYPE = "CD_PIPELINE" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AllAppWorkflowComponentDetails ¶ added in v0.6.0
type AllAppWorkflowComponentDetails struct {
Workflows []*WorkflowComponentNamesDto `json:"workflows"`
}
type AppWorkflowDto ¶
type AppWorkflowDto struct {
Id int `json:"id,omitempty"`
Name string `json:"name"`
AppId int `json:"appId"`
AppWorkflowMappingDto []AppWorkflowMappingDto `json:"tree,omitempty"`
UserId int32 `json:"-"`
}
type AppWorkflowMappingDto ¶
type AppWorkflowMappingDto struct {
Id int `json:"id,omitempty"`
AppWorkflowId int `json:"appWorkflowId"`
Type string `json:"type"`
ComponentId int `json:"componentId"`
ParentId int `json:"parentId"`
ParentType string `json:"parentType"`
DeploymentAppDeleteRequest bool `json:"deploymentAppDeleteRequest"`
UserId int32 `json:"-"`
IsLast bool `json:"isLast"`
ChildPipelinesIds mapset.Set `json:"-"`
}
func LevelWiseSort ¶ added in v0.6.28
func LevelWiseSort(appWorkflowMappings []AppWorkflowMappingDto) []AppWorkflowMappingDto
LevelWiseSort performs level wise sort for workflow mappings starting from leaves This will break if ever the workflow mappings array break the assumption of being a DAG with one root node
type AppWorkflowService ¶
type AppWorkflowService interface {
CreateAppWorkflow(req AppWorkflowDto) (AppWorkflowDto, error)
FindAppWorkflows(appId int) ([]AppWorkflowDto, error)
FindAppWorkflowById(Id int, appId int) (AppWorkflowDto, error)
DeleteAppWorkflow(appWorkflowId int, userId int32) error
SaveAppWorkflowMapping(wf AppWorkflowMappingDto) (AppWorkflowMappingDto, error)
FindAppWorkflowMapping(workflowId int) ([]AppWorkflowMappingDto, error)
FindAllAppWorkflowMapping(workflowIds []int) (map[int][]AppWorkflowMappingDto, error)
FindAppWorkflowMappingByComponent(id int, compType string) ([]*appWorkflow.AppWorkflowMapping, error)
CheckCdPipelineByCiPipelineId(id int) bool
FindAppWorkflowByName(name string, appId int) (AppWorkflowDto, error)
IsWorkflowNameFound(workflowName string, appId int) (bool, error)
FindAllWorkflowsComponentDetails(appId int) (*AllAppWorkflowComponentDetails, error)
FindAppWorkflowsByEnvironmentId(request resourceGroup2.ResourceGroupingRequest, token string) ([]*AppWorkflowDto, error)
FindAllWorkflowsForApps(request WorkflowNamesRequest) (*WorkflowNamesResponse, error)
FilterWorkflows(triggerViewConfig *TriggerViewWorkflowConfig, envIds []int) (*TriggerViewWorkflowConfig, error)
FindCdPipelinesByAppId(appId int) (*bean.CdPipelines, error)
FindAppWorkflowByCiPipelineId(ciPipelineId int) ([]*appWorkflow.AppWorkflowMapping, error)
}
type AppWorkflowServiceImpl ¶
type AppWorkflowServiceImpl struct {
Logger *zap.SugaredLogger
// contains filtered or unexported fields
}
func NewAppWorkflowServiceImpl ¶
func NewAppWorkflowServiceImpl(logger *zap.SugaredLogger, appWorkflowRepository appWorkflow.AppWorkflowRepository, ciCdPipelineOrchestrator pipeline.CiCdPipelineOrchestrator, ciPipelineRepository pipelineConfig.CiPipelineRepository, pipelineRepository pipelineConfig.PipelineRepository, enforcerUtil rbac.EnforcerUtil, resourceGroupService resourceGroup2.ResourceGroupService, appRepository appRepository.AppRepository, userAuthService user.UserAuthService, chartService chart.ChartService) *AppWorkflowServiceImpl
func (AppWorkflowServiceImpl) CheckCdPipelineByCiPipelineId ¶ added in v0.4.8
func (impl AppWorkflowServiceImpl) CheckCdPipelineByCiPipelineId(id int) bool
func (AppWorkflowServiceImpl) CreateAppWorkflow ¶
func (impl AppWorkflowServiceImpl) CreateAppWorkflow(req AppWorkflowDto) (AppWorkflowDto, error)
func (AppWorkflowServiceImpl) DeleteAppWorkflow ¶
func (impl AppWorkflowServiceImpl) DeleteAppWorkflow(appWorkflowId int, userId int32) error
func (AppWorkflowServiceImpl) FilterWorkflows ¶ added in v0.6.24
func (impl AppWorkflowServiceImpl) FilterWorkflows(triggerViewConfig *TriggerViewWorkflowConfig, envIds []int) (*TriggerViewWorkflowConfig, error)
func (AppWorkflowServiceImpl) FindAllAppWorkflowMapping ¶ added in v0.6.17
func (impl AppWorkflowServiceImpl) FindAllAppWorkflowMapping(workflowIds []int) (map[int][]AppWorkflowMappingDto, error)
func (AppWorkflowServiceImpl) FindAllWorkflowsComponentDetails ¶ added in v0.6.0
func (impl AppWorkflowServiceImpl) FindAllWorkflowsComponentDetails(appId int) (*AllAppWorkflowComponentDetails, error)
func (AppWorkflowServiceImpl) FindAllWorkflowsForApps ¶ added in v0.6.26
func (impl AppWorkflowServiceImpl) FindAllWorkflowsForApps(request WorkflowNamesRequest) (*WorkflowNamesResponse, error)
func (AppWorkflowServiceImpl) FindAppWorkflowByCiPipelineId ¶ added in v0.6.26
func (impl AppWorkflowServiceImpl) FindAppWorkflowByCiPipelineId(ciPipelineId int) ([]*appWorkflow.AppWorkflowMapping, error)
func (AppWorkflowServiceImpl) FindAppWorkflowById ¶
func (impl AppWorkflowServiceImpl) FindAppWorkflowById(Id int, appId int) (AppWorkflowDto, error)
func (AppWorkflowServiceImpl) FindAppWorkflowByName ¶
func (impl AppWorkflowServiceImpl) FindAppWorkflowByName(name string, appId int) (AppWorkflowDto, error)
func (AppWorkflowServiceImpl) FindAppWorkflowMapping ¶
func (impl AppWorkflowServiceImpl) FindAppWorkflowMapping(workflowId int) ([]AppWorkflowMappingDto, error)
func (AppWorkflowServiceImpl) FindAppWorkflowMappingByComponent ¶
func (impl AppWorkflowServiceImpl) FindAppWorkflowMappingByComponent(id int, compType string) ([]*appWorkflow.AppWorkflowMapping, error)
func (AppWorkflowServiceImpl) FindAppWorkflowMappingForEnv ¶ added in v0.6.15
func (impl AppWorkflowServiceImpl) FindAppWorkflowMappingForEnv(appIds []int) (map[int]*AppWorkflowDto, error)
func (AppWorkflowServiceImpl) FindAppWorkflows ¶
func (impl AppWorkflowServiceImpl) FindAppWorkflows(appId int) ([]AppWorkflowDto, error)
func (AppWorkflowServiceImpl) FindAppWorkflowsByEnvironmentId ¶ added in v0.6.13
func (impl AppWorkflowServiceImpl) FindAppWorkflowsByEnvironmentId(request resourceGroup2.ResourceGroupingRequest, token string) ([]*AppWorkflowDto, error)
func (AppWorkflowServiceImpl) FindCdPipelinesByAppId ¶ added in v0.6.24
func (impl AppWorkflowServiceImpl) FindCdPipelinesByAppId(appId int) (*bean.CdPipelines, error)
func (AppWorkflowServiceImpl) IsWorkflowNameFound ¶ added in v0.7.0
func (impl AppWorkflowServiceImpl) IsWorkflowNameFound(workflowName string, appId int) (bool, error)
func (AppWorkflowServiceImpl) SaveAppWorkflowMapping ¶
func (impl AppWorkflowServiceImpl) SaveAppWorkflowMapping(req AppWorkflowMappingDto) (AppWorkflowMappingDto, error)
type PipelineIdentifier ¶ added in v0.6.24
type TriggerViewWorkflowConfig ¶ added in v0.6.17
type TriggerViewWorkflowConfig struct {
Workflows []AppWorkflowDto `json:"workflows"`
CiConfig *bean.TriggerViewCiConfig `json:"ciConfig"`
CdPipelines *bean.CdPipelines `json:"cdConfig"`
ExternalCiConfig []*bean.ExternalCiConfig `json:"externalCiConfig"`
}
type WorkflowCloneRequest ¶ added in v0.6.21
type WorkflowComponentNamesDto ¶ added in v0.6.0
type WorkflowNamesRequest ¶ added in v0.6.26
type WorkflowNamesRequest struct {
AppNames []string `json:"appNames"`
}
type WorkflowNamesResponse ¶ added in v0.6.26
Click to show internal directories.
Click to hide internal directories.