Versions in this module Expand all Collapse all v0 v0.2.21 Aug 13, 2021 v0.2.20 Aug 10, 2021 v0.2.19 Jul 28, 2021 v0.2.18 Jul 20, 2021 v0.2.17 Jul 16, 2021 v0.2.16 Jul 9, 2021 v0.2.15 Jul 2, 2021 v0.2.14 Jun 28, 2021 v0.2.13 Jun 22, 2021 v0.2.12 Jun 1, 2021 v0.2.11 May 24, 2021 v0.2.10 May 23, 2021 v0.2.9 May 5, 2021 v0.2.8 Apr 23, 2021 v0.2.7 Apr 12, 2021 v0.2.6 Apr 7, 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