workflowStatus

Feb 21, 2025

Changes in this version

+ type WorkFlowStageStatusService interface

+ ConvertDBWorkflowStageToMap func(workflowStages []*repository.WorkflowExecutionStage, wfId int, ...) map[string][]*bean2.WorkflowStageDto

+ GetWorkflowStagesByWorkflowIdAndType func(wfId int, wfType string) ([]*repository.WorkflowExecutionStage, error)

+ GetWorkflowStagesByWorkflowIdsAndWfType func(wfIds []int, wfType string) ([]*repository.WorkflowExecutionStage, error)

+ SaveWorkflowStages func(wfId int, wfType, wfName string, tx *pg.Tx) error

+ UpdateWorkflowStages func(wfId int, wfType, wfName, wfStatus, podStatus, message, podName string, ...) (string, string, error)

+ type WorkFlowStageStatusServiceImpl struct

+ func NewWorkflowStageFlowStatusServiceImpl(logger *zap.SugaredLogger, ...) *WorkFlowStageStatusServiceImpl

+ func (impl *WorkFlowStageStatusServiceImpl) ConvertDBWorkflowStageToMap(workflowStages []*repository.WorkflowExecutionStage, wfId int, ...) map[string][]*bean2.WorkflowStageDto

+ func (impl *WorkFlowStageStatusServiceImpl) GetWorkflowStagesByWorkflowIdAndType(wfId int, wfType string) ([]*repository.WorkflowExecutionStage, error)

+ func (impl *WorkFlowStageStatusServiceImpl) GetWorkflowStagesByWorkflowIdsAndWfType(wfIds []int, wfType string) ([]*repository.WorkflowExecutionStage, error)

+ func (impl *WorkFlowStageStatusServiceImpl) SaveWorkflowStages(wfId int, wfType, wfName string, tx *pg.Tx) error

+ func (impl *WorkFlowStageStatusServiceImpl) UpdateWorkflowStages(wfId int, wfType, wfName, wfStatus, podStatus, message, podName string, ...) (string, string, error)