workflowStatus

Documentation

Index

• type WorkFlowStageStatusService
• type WorkFlowStageStatusServiceImpl
  • 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)

Types

type WorkFlowStageStatusService

type WorkFlowStageStatusService interface {
	GetWorkflowStagesByWorkflowIdsAndWfType(wfIds []int, wfType string) ([]*repository.WorkflowExecutionStage, error)
	GetWorkflowStagesByWorkflowIdAndType(wfId int, wfType string) ([]*repository.WorkflowExecutionStage, error)

	SaveWorkflowStages(wfId int, wfType, wfName string, tx *pg.Tx) error
	UpdateWorkflowStages(wfId int, wfType, wfName, wfStatus, podStatus, message, podName string, tx *pg.Tx) (string, string, error)
	ConvertDBWorkflowStageToMap(workflowStages []*repository.WorkflowExecutionStage, wfId int, status, podStatus, message, wfType string, startTime, endTime time.Time) map[string][]*bean2.WorkflowStageDto
}

type WorkFlowStageStatusServiceImpl

type WorkFlowStageStatusServiceImpl struct {
	// contains filtered or unexported fields
}

func NewWorkflowStageFlowStatusServiceImpl

func NewWorkflowStageFlowStatusServiceImpl(logger *zap.SugaredLogger,
	workflowStatusRepository repository.WorkflowStageRepository,
	ciWorkflowRepository pipelineConfig.CiWorkflowRepository,
	cdWorkflowRepository pipelineConfig.CdWorkflowRepository,
	transactionManager sql.TransactionWrapper,
) *WorkFlowStageStatusServiceImpl

func (*WorkFlowStageStatusServiceImpl) ConvertDBWorkflowStageToMap

func (impl *WorkFlowStageStatusServiceImpl) ConvertDBWorkflowStageToMap(workflowStages []*repository.WorkflowExecutionStage, wfId int, status, podStatus, message, wfType string, startTime, endTime time.Time) map[string][]*bean2.WorkflowStageDto

func (*WorkFlowStageStatusServiceImpl) GetWorkflowStagesByWorkflowIdAndType

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

func (*WorkFlowStageStatusServiceImpl) GetWorkflowStagesByWorkflowIdsAndWfType

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

func (*WorkFlowStageStatusServiceImpl) SaveWorkflowStages

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

func (*WorkFlowStageStatusServiceImpl) UpdateWorkflowStages

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