Versions in this module Expand all Collapse all v0 v0.2.21 Aug 13, 2021 v0.2.19 Jul 28, 2021 v0.2.10 May 23, 2021 v0.2.8 Apr 23, 2021 Changes in this version + const CDPIPELINE + const CIPIPELINE + type AppWorkflow struct + Active bool + AppId int + Id int + Name string + TableName struct{} + WorkflowDAG json.RawMessage + type AppWorkflowMapping struct + Active bool + AppWorkflow *AppWorkflow + AppWorkflowId int + ComponentId int + Id int + ParentId int + ParentType string + TableName struct{} + Type string + type AppWorkflowRepository interface + DeleteAppWorkflow func(appWorkflow *AppWorkflow, tx *pg.Tx) error + DeleteAppWorkflowMapping func(appWorkflow *AppWorkflowMapping, tx *pg.Tx) error + FindByAppId func(appId int) (appWorkflow []*AppWorkflow, err error) + FindByComponent func(id int, componentType string) ([]*AppWorkflowMapping, error) + FindByIdAndAppId func(id int, appId int) (*AppWorkflow, error) + FindByNameAndAppId func(name string, appId int) (*AppWorkflow, error) + FindByWorkflowId func(workflowId int) ([]*AppWorkflowMapping, error) + FindWFAllMappingByWorkflowId func(workflowId int) ([]*AppWorkflowMapping, error) + FindWFCDMappingByCDPipelineId func(cdPipelineId int) ([]*AppWorkflowMapping, error) + FindWFCDMappingByCIPipelineId func(ciPipelineId int) ([]*AppWorkflowMapping, error) + FindWFCDMappingByCIPipelineIds func(ciPipelineIds []int) ([]*AppWorkflowMapping, error) + FindWFCIMappingByCIPipelineId func(ciPipelineId int) ([]*AppWorkflowMapping, error) + FindWFCIMappingByWorkflowId func(workflowId int) ([]*AppWorkflowMapping, error) + SaveAppWorkflow func(wf *AppWorkflow) (*AppWorkflow, error) + SaveAppWorkflowMapping func(wf *AppWorkflowMapping, tx *pg.Tx) (*AppWorkflowMapping, error) + UpdateAppWorkflow func(wf *AppWorkflow) (*AppWorkflow, error) + type AppWorkflowRepositoryImpl struct + Logger *zap.SugaredLogger + func NewAppWorkflowRepositoryImpl(Logger *zap.SugaredLogger, dbConnection *pg.DB) *AppWorkflowRepositoryImpl + func (impl AppWorkflowRepositoryImpl) DeleteAppWorkflow(appWorkflow *AppWorkflow, tx *pg.Tx) error + func (impl AppWorkflowRepositoryImpl) DeleteAppWorkflowMapping(appWorkflow *AppWorkflowMapping, tx *pg.Tx) error + func (impl AppWorkflowRepositoryImpl) FindByAppId(appId int) (appWorkflow []*AppWorkflow, err error) + func (impl AppWorkflowRepositoryImpl) FindByComponent(id int, componentType string) ([]*AppWorkflowMapping, error) + func (impl AppWorkflowRepositoryImpl) FindByIdAndAppId(id int, appId int) (*AppWorkflow, error) + func (impl AppWorkflowRepositoryImpl) FindByNameAndAppId(name string, appId int) (*AppWorkflow, error) + func (impl AppWorkflowRepositoryImpl) FindByWorkflowId(workflowId int) ([]*AppWorkflowMapping, error) + func (impl AppWorkflowRepositoryImpl) FindWFAllMappingByWorkflowId(workflowId int) ([]*AppWorkflowMapping, error) + func (impl AppWorkflowRepositoryImpl) FindWFCDMappingByCDPipelineId(cdPipelineId int) ([]*AppWorkflowMapping, error) + func (impl AppWorkflowRepositoryImpl) FindWFCDMappingByCIPipelineId(ciPipelineId int) ([]*AppWorkflowMapping, error) + func (impl AppWorkflowRepositoryImpl) FindWFCDMappingByCIPipelineIds(ciPipelineIds []int) ([]*AppWorkflowMapping, error) + func (impl AppWorkflowRepositoryImpl) FindWFCIMappingByCIPipelineId(ciPipelineId int) ([]*AppWorkflowMapping, error) + func (impl AppWorkflowRepositoryImpl) FindWFCIMappingByWorkflowId(workflowId int) ([]*AppWorkflowMapping, error) + func (impl AppWorkflowRepositoryImpl) SaveAppWorkflow(wf *AppWorkflow) (*AppWorkflow, error) + func (impl AppWorkflowRepositoryImpl) SaveAppWorkflowMapping(wf *AppWorkflowMapping, tx *pg.Tx) (*AppWorkflowMapping, error) + func (impl AppWorkflowRepositoryImpl) UpdateAppWorkflow(wf *AppWorkflow) (*AppWorkflow, error) + type WorkflowDAG struct + CdPipelines []int + CiPipelines []int
Go to main page