read

Documentation

Index

• type CdWorkflowReadService
• type CdWorkflowReadServiceImpl
  • func NewCdWorkflowReadServiceImpl(logger *zap.SugaredLogger, ...) *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 NewCdWorkflowRunnerReadServiceImpl(logger *zap.SugaredLogger, ...) *CdWorkflowRunnerReadServiceImpl
  • func (impl *CdWorkflowRunnerReadServiceImpl) CheckIfWfrLatest(wfrId, pipelineId int) (isLatest bool, err error)
  • func (impl *CdWorkflowRunnerReadServiceImpl) FindWorkflowRunnerById(wfrId int) (*bean.CdWorkflowRunnerDto, error)

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

func (impl *CdWorkflowReadServiceImpl) FindLatestCdWorkflowRunnerArtifactMetadataForAppAndEnvIds(appVsEnvIdMap map[int][]int, runnerType bean4.WorkflowType) ([]*cdWorkflow.CdWorkflowRunnerArtifactMetadata, error)

func (*CdWorkflowReadServiceImpl) FindLatestCdWorkflowRunnerByEnvironmentIdAndRunnerType

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)
}

type CdWorkflowRunnerReadServiceImpl

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

func NewCdWorkflowRunnerReadServiceImpl

func NewCdWorkflowRunnerReadServiceImpl(logger *zap.SugaredLogger,
	cdWorkflowRepository pipelineConfig.CdWorkflowRepository) *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)