Documentation
¶
Index ¶
- type CdWorkflowReadService
- type CdWorkflowReadServiceImpl
- func (impl *CdWorkflowReadServiceImpl) CheckIfLatestWf(pipelineId, cdWfId int) (latest bool, err error)
- func (impl *CdWorkflowReadServiceImpl) FindLatestCdWorkflowRunnerArtifactMetadataForAppAndEnvIds(appVsEnvIdMap map[int][]int, runnerType bean4.WorkflowType) ([]*cdWorkflow.CdWorkflowRunnerArtifactMetadata, error)
- func (impl *CdWorkflowReadServiceImpl) FindLatestCdWorkflowRunnerByEnvironmentIdAndRunnerType(appId int, environmentId int, runnerType bean4.WorkflowType) (pipelineConfig.CdWorkflowRunner, error)
- type CdWorkflowRunnerReadService
- type CdWorkflowRunnerReadServiceImpl
- func (impl *CdWorkflowRunnerReadServiceImpl) CheckIfWfrLatest(wfrId, pipelineId int) (isLatest bool, err error)
- func (impl *CdWorkflowRunnerReadServiceImpl) FindWorkflowRunnerById(wfrId int) (*bean.CdWorkflowRunnerDto, error)
- func (impl *CdWorkflowRunnerReadServiceImpl) GetWfrStatusForLatestRunners(pipelineIds []int, pipelines []*pipelineConfig.Pipeline) ([]*pipelineConfig.CdWorkflowStatus, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CdWorkflowReadService ¶
type CdWorkflowReadService interface {
CheckIfLatestWf(pipelineId, cdWfId int) (latest bool, err error)
FindLatestCdWorkflowRunnerByEnvironmentIdAndRunnerType(appId int, environmentId int, runnerType bean4.WorkflowType) (pipelineConfig.CdWorkflowRunner, error)
FindLatestCdWorkflowRunnerArtifactMetadataForAppAndEnvIds(appVsEnvIdMap map[int][]int, runnerType bean4.WorkflowType) ([]*cdWorkflow.CdWorkflowRunnerArtifactMetadata, error)
}
type CdWorkflowReadServiceImpl ¶
type CdWorkflowReadServiceImpl struct {
// contains filtered or unexported fields
}
func NewCdWorkflowReadServiceImpl ¶
func NewCdWorkflowReadServiceImpl(logger *zap.SugaredLogger, cdWorkflowRepository pipelineConfig.CdWorkflowRepository) *CdWorkflowReadServiceImpl
func (*CdWorkflowReadServiceImpl) CheckIfLatestWf ¶
func (impl *CdWorkflowReadServiceImpl) CheckIfLatestWf(pipelineId, cdWfId int) (latest bool, err error)
func (*CdWorkflowReadServiceImpl) FindLatestCdWorkflowRunnerArtifactMetadataForAppAndEnvIds ¶ added in v1.2.1
func (impl *CdWorkflowReadServiceImpl) FindLatestCdWorkflowRunnerArtifactMetadataForAppAndEnvIds(appVsEnvIdMap map[int][]int, runnerType bean4.WorkflowType) ([]*cdWorkflow.CdWorkflowRunnerArtifactMetadata, error)
func (*CdWorkflowReadServiceImpl) FindLatestCdWorkflowRunnerByEnvironmentIdAndRunnerType ¶ added in v1.2.1
func (impl *CdWorkflowReadServiceImpl) FindLatestCdWorkflowRunnerByEnvironmentIdAndRunnerType(appId int, environmentId int, runnerType bean4.WorkflowType) (pipelineConfig.CdWorkflowRunner, error)
type CdWorkflowRunnerReadService ¶
type CdWorkflowRunnerReadService interface {
FindWorkflowRunnerById(wfrId int) (*bean.CdWorkflowRunnerDto, error)
CheckIfWfrLatest(wfrId, pipelineId int) (isLatest bool, err error)
GetWfrStatusForLatestRunners(pipelineIds []int, pipelines []*pipelineConfig.Pipeline) ([]*pipelineConfig.CdWorkflowStatus, error)
}
type CdWorkflowRunnerReadServiceImpl ¶
type CdWorkflowRunnerReadServiceImpl struct {
WorkflowStatusLatestService workflowStatusLatest.WorkflowStatusLatestService
// contains filtered or unexported fields
}
func NewCdWorkflowRunnerReadServiceImpl ¶
func NewCdWorkflowRunnerReadServiceImpl(logger *zap.SugaredLogger, cdWorkflowRepository pipelineConfig.CdWorkflowRepository, WorkflowStatusLatestService workflowStatusLatest.WorkflowStatusLatestService, pipelineStageRepository repository2.PipelineStageRepository) *CdWorkflowRunnerReadServiceImpl
func (*CdWorkflowRunnerReadServiceImpl) CheckIfWfrLatest ¶
func (impl *CdWorkflowRunnerReadServiceImpl) CheckIfWfrLatest(wfrId, pipelineId int) (isLatest bool, err error)
func (*CdWorkflowRunnerReadServiceImpl) FindWorkflowRunnerById ¶
func (impl *CdWorkflowRunnerReadServiceImpl) FindWorkflowRunnerById(wfrId int) (*bean.CdWorkflowRunnerDto, error)
func (*CdWorkflowRunnerReadServiceImpl) GetWfrStatusForLatestRunners ¶ added in v1.8.0
func (impl *CdWorkflowRunnerReadServiceImpl) GetWfrStatusForLatestRunners(pipelineIds []int, pipelines []*pipelineConfig.Pipeline) ([]*pipelineConfig.CdWorkflowStatus, error)
Click to show internal directories.
Click to hide internal directories.