cd

Documentation

Index

• Variables
• type CdWorkflowCommonService
• type CdWorkflowCommonServiceImpl
  • func NewCdWorkflowCommonServiceImpl(logger *zap.SugaredLogger, ...) (*CdWorkflowCommonServiceImpl, error)
  • func (impl *CdWorkflowCommonServiceImpl) GetTriggerValidateFuncs() []pubsub.ValidateMsg
  • func (impl *CdWorkflowCommonServiceImpl) MarkCurrentDeploymentFailed(runner *pipelineConfig.CdWorkflowRunner, releaseErr error, triggeredBy int32) error
  • func (impl *CdWorkflowCommonServiceImpl) MarkDeploymentFailedForRunnerId(cdWfrId int, releaseErr error, triggeredBy int32) error
  • func (impl *CdWorkflowCommonServiceImpl) SupersedePreviousDeployments(ctx context.Context, cdWfrId int, pipelineId int, triggeredAt time.Time, ...) error
  • func (impl *CdWorkflowCommonServiceImpl) UpdateNonTerminalStatusInRunner(ctx context.Context, wfrId int, userId int32, status string) error
  • func (impl *CdWorkflowCommonServiceImpl) UpdatePreviousQueuedRunnerStatus(cdWfrId, pipelineId int, triggeredBy int32) error
• type CdWorkflowRunnerService
• type CdWorkflowRunnerServiceImpl
  • func NewCdWorkflowRunnerServiceImpl(logger *zap.SugaredLogger, ...) *CdWorkflowRunnerServiceImpl
  • func (impl *CdWorkflowRunnerServiceImpl) UpdateIsArtifactUploaded(wfrId int, isArtifactUploaded bool) error
  • func (impl *CdWorkflowRunnerServiceImpl) UpdateWfr(dto *bean.CdWorkflowRunnerDto, updatedBy int) error
• type CdWorkflowService
• type CdWorkflowServiceImpl
  • func NewCdWorkflowServiceImpl(logger *zap.SugaredLogger, ...) *CdWorkflowServiceImpl
  • func (impl *CdWorkflowServiceImpl) UpdateWorkFlow(dto *bean.CdWorkflowDto) error

Variables

var CdWorkflowWireSet = wire.NewSet(
	NewCdWorkflowCommonServiceImpl,
	wire.Bind(new(CdWorkflowCommonService), new(*CdWorkflowCommonServiceImpl)),
	NewCdWorkflowServiceImpl,
	wire.Bind(new(CdWorkflowService), new(*CdWorkflowServiceImpl)),
	read.NewCdWorkflowReadServiceImpl,
	wire.Bind(new(read.CdWorkflowReadService), new(*read.CdWorkflowReadServiceImpl)),
	NewCdWorkflowRunnerServiceImpl,
	wire.Bind(new(CdWorkflowRunnerService), new(*CdWorkflowRunnerServiceImpl)),
	read.NewCdWorkflowRunnerReadServiceImpl,
	wire.Bind(new(read.CdWorkflowRunnerReadService), new(*read.CdWorkflowRunnerReadServiceImpl)),
)

Types

type CdWorkflowCommonService

type CdWorkflowCommonService interface {
	SupersedePreviousDeployments(ctx context.Context, cdWfrId int, pipelineId int, triggeredAt time.Time, triggeredBy int32) error
	MarkDeploymentFailedForRunnerId(cdWfrId int, releaseErr error, triggeredBy int32) error
	MarkCurrentDeploymentFailed(runner *pipelineConfig.CdWorkflowRunner, releaseErr error, triggeredBy int32) error
	UpdateNonTerminalStatusInRunner(ctx context.Context, wfrId int, userId int32, status string) error
	UpdatePreviousQueuedRunnerStatus(cdWfrId, pipelineId int, triggeredBy int32) error

	GetTriggerValidateFuncs() []pubsub.ValidateMsg
}

type CdWorkflowCommonServiceImpl

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

func NewCdWorkflowCommonServiceImpl

func NewCdWorkflowCommonServiceImpl(logger *zap.SugaredLogger,
	cdWorkflowRepository pipelineConfig.CdWorkflowRepository,
	pipelineStatusTimelineService status.PipelineStatusTimelineService,
	pipelineRepository pipelineConfig.PipelineRepository,
	pipelineStatusTimelineRepository pipelineConfig.PipelineStatusTimelineRepository,
	deploymentConfigService common2.DeploymentConfigService) (*CdWorkflowCommonServiceImpl, error)

func (*CdWorkflowCommonServiceImpl) GetTriggerValidateFuncs

func (impl *CdWorkflowCommonServiceImpl) GetTriggerValidateFuncs() []pubsub.ValidateMsg

GetTriggerValidateFuncs gets all the required validation funcs

func (*CdWorkflowCommonServiceImpl) MarkCurrentDeploymentFailed

func (impl *CdWorkflowCommonServiceImpl) MarkCurrentDeploymentFailed(runner *pipelineConfig.CdWorkflowRunner, releaseErr error, triggeredBy int32) error

func (*CdWorkflowCommonServiceImpl) MarkDeploymentFailedForRunnerId

func (impl *CdWorkflowCommonServiceImpl) MarkDeploymentFailedForRunnerId(cdWfrId int, releaseErr error, triggeredBy int32) error

func (*CdWorkflowCommonServiceImpl) SupersedePreviousDeployments

func (impl *CdWorkflowCommonServiceImpl) SupersedePreviousDeployments(ctx context.Context, cdWfrId int, pipelineId int, triggeredAt time.Time, triggeredBy int32) error

func (*CdWorkflowCommonServiceImpl) UpdateNonTerminalStatusInRunner

func (impl *CdWorkflowCommonServiceImpl) UpdateNonTerminalStatusInRunner(ctx context.Context, wfrId int, userId int32, status string) error

func (*CdWorkflowCommonServiceImpl) UpdatePreviousQueuedRunnerStatus

func (impl *CdWorkflowCommonServiceImpl) UpdatePreviousQueuedRunnerStatus(cdWfrId, pipelineId int, triggeredBy int32) error

type CdWorkflowRunnerService

type CdWorkflowRunnerService interface {
	UpdateWfr(dto *bean.CdWorkflowRunnerDto, updatedBy int) error
	UpdateIsArtifactUploaded(wfrId int, isArtifactUploaded bool) error
}

type CdWorkflowRunnerServiceImpl

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

func NewCdWorkflowRunnerServiceImpl

func NewCdWorkflowRunnerServiceImpl(logger *zap.SugaredLogger,
	cdWorkflowRepository pipelineConfig.CdWorkflowRepository) *CdWorkflowRunnerServiceImpl

func (*CdWorkflowRunnerServiceImpl) UpdateIsArtifactUploaded

func (impl *CdWorkflowRunnerServiceImpl) UpdateIsArtifactUploaded(wfrId int, isArtifactUploaded bool) error

func (*CdWorkflowRunnerServiceImpl) UpdateWfr

func (impl *CdWorkflowRunnerServiceImpl) UpdateWfr(dto *bean.CdWorkflowRunnerDto, updatedBy int) error

type CdWorkflowService

type CdWorkflowService interface {
	UpdateWorkFlow(dto *bean.CdWorkflowDto) error
}

type CdWorkflowServiceImpl

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

func NewCdWorkflowServiceImpl

func NewCdWorkflowServiceImpl(logger *zap.SugaredLogger,
	cdWorkflowRepository pipelineConfig.CdWorkflowRepository) *CdWorkflowServiceImpl

func (*CdWorkflowServiceImpl) UpdateWorkFlow

func (impl *CdWorkflowServiceImpl) UpdateWorkFlow(dto *bean.CdWorkflowDto) error