appWorkflow

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Dec 20, 2024 License: Apache-2.0 Imports: 24 Imported by: 11

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func LevelWiseSort added in v0.6.28 

func LevelWiseSort(appWorkflowMappings []bean4.AppWorkflowMappingDto) []bean4.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

Types

type AppWorkflowService 

type AppWorkflowService interface {
	CreateAppWorkflow(req bean4.AppWorkflowDto) (bean4.AppWorkflowDto, error)
	FindAppWorkflows(appId int) ([]bean4.AppWorkflowDto, error)
	FindAppWorkflowById(Id int, appId int) (bean4.AppWorkflowDto, error)
	DeleteAppWorkflow(appWorkflowId int, userId int32) error

	SaveAppWorkflowMapping(wf bean4.AppWorkflowMappingDto) (bean4.AppWorkflowMappingDto, error)
	FindAppWorkflowMapping(workflowId int) ([]bean4.AppWorkflowMappingDto, error)
	FindAllAppWorkflowMapping(workflowIds []int) (map[int][]bean4.AppWorkflowMappingDto, error)
	FindAppWorkflowMappingByComponent(id int, compType string) ([]*appWorkflow.AppWorkflowMapping, error)
	CheckCdPipelineByCiPipelineId(id int) bool
	FindAppWorkflowByName(name string, appId int) (bean4.AppWorkflowDto, error)
	IsWorkflowNameFound(workflowName string, appId int) (bool, error)
	FindAllWorkflowsComponentDetails(appId int) (*bean4.AllAppWorkflowComponentDetails, error)
	FindAppWorkflowsByEnvironmentId(request resourceGroup2.ResourceGroupingRequest, token string) ([]*bean4.AppWorkflowDto, error)
	FindAllWorkflowsForApps(request bean4.WorkflowNamesRequest) (*bean4.WorkflowNamesResponse, error)
	FilterWorkflows(triggerViewConfig *bean4.TriggerViewWorkflowConfig, queryParams *bean4.WorkflowsFilterQuery) (*bean4.TriggerViewWorkflowConfig, error)
	FindCdPipelinesByAppId(appId int) (*bean.CdPipelines, error)
	FindAppWorkflowByCiPipelineId(ciPipelineId int) ([]*appWorkflow.AppWorkflowMapping, error)
	FindWFMappingByComponent(componentType string, componentId int) (*appWorkflow.AppWorkflowMapping, error)
	FindWFCDMappingsByWorkflowId(appWorkflowId 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,
	deploymentConfigService common.DeploymentConfigService,
) *AppWorkflowServiceImpl

func (AppWorkflowServiceImpl) CheckCdPipelineByCiPipelineId added in v0.4.8 

func (impl AppWorkflowServiceImpl) CheckCdPipelineByCiPipelineId(id int) bool

func (AppWorkflowServiceImpl) CreateAppWorkflow 

func (impl AppWorkflowServiceImpl) CreateAppWorkflow(req bean4.AppWorkflowDto) (bean4.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 *bean4.TriggerViewWorkflowConfig, queryParams *bean4.WorkflowsFilterQuery) (*bean4.TriggerViewWorkflowConfig, error)

func (AppWorkflowServiceImpl) FindAllAppWorkflowMapping added in v0.6.17 

func (impl AppWorkflowServiceImpl) FindAllAppWorkflowMapping(workflowIds []int) (map[int][]bean4.AppWorkflowMappingDto, error)

func (AppWorkflowServiceImpl) FindAllWorkflowsComponentDetails added in v0.6.0 

func (impl AppWorkflowServiceImpl) FindAllWorkflowsComponentDetails(appId int) (*bean4.AllAppWorkflowComponentDetails, error)

func (AppWorkflowServiceImpl) FindAllWorkflowsForApps added in v0.6.26 

func (impl AppWorkflowServiceImpl) FindAllWorkflowsForApps(request bean4.WorkflowNamesRequest) (*bean4.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) (bean4.AppWorkflowDto, error)

func (AppWorkflowServiceImpl) FindAppWorkflowByName 

func (impl AppWorkflowServiceImpl) FindAppWorkflowByName(name string, appId int) (bean4.AppWorkflowDto, error)

func (AppWorkflowServiceImpl) FindAppWorkflowMapping 

func (impl AppWorkflowServiceImpl) FindAppWorkflowMapping(workflowId int) ([]bean4.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]*bean4.AppWorkflowDto, error)

func (AppWorkflowServiceImpl) FindAppWorkflows 

func (impl AppWorkflowServiceImpl) FindAppWorkflows(appId int) ([]bean4.AppWorkflowDto, error)

func (AppWorkflowServiceImpl) FindAppWorkflowsByEnvironmentId added in v0.6.13 

func (impl AppWorkflowServiceImpl) FindAppWorkflowsByEnvironmentId(request resourceGroup2.ResourceGroupingRequest, token string) ([]*bean4.AppWorkflowDto, error)

func (AppWorkflowServiceImpl) FindCdPipelinesByAppId added in v0.6.24 

func (impl AppWorkflowServiceImpl) FindCdPipelinesByAppId(appId int) (*bean.CdPipelines, error)

func (AppWorkflowServiceImpl) FindWFCDMappingsByWorkflowId added in v0.7.2 

func (impl AppWorkflowServiceImpl) FindWFCDMappingsByWorkflowId(appWorkflowId int) ([]*appWorkflow.AppWorkflowMapping, error)

func (AppWorkflowServiceImpl) FindWFMappingByComponent added in v0.7.2 

func (impl AppWorkflowServiceImpl) FindWFMappingByComponent(componentType string, componentId int) (*appWorkflow.AppWorkflowMapping, 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 bean4.AppWorkflowMappingDto) (bean4.AppWorkflowMappingDto, error)

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.