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) UpdateCDWorkflowRunnerStatus(ctx context.Context, overrideRequest *bean.ValuesOverrideRequest, ...) error
  • func (impl *CdWorkflowCommonServiceImpl) UpdatePreviousDeploymentStatus(currentRunner *pipelineConfig.CdWorkflowRunner, pipelineId int, ...) error
• type CdWorkflowRunnerService
• type CdWorkflowRunnerServiceImpl
  • func NewCdWorkflowRunnerServiceImpl(logger *zap.SugaredLogger, ...) *CdWorkflowRunnerServiceImpl
  • func (impl *CdWorkflowRunnerServiceImpl) CheckIfWfrLatest(wfrId, pipelineId int) (isLatest bool, err error)
  • func (impl *CdWorkflowRunnerServiceImpl) FindWorkflowRunnerById(wfrId int) (*bean.CdWorkflowRunnerDto, error)
• type CdWorkflowService
• type CdWorkflowServiceImpl
  • func NewCdWorkflowServiceImpl(logger *zap.SugaredLogger, ...) *CdWorkflowServiceImpl
  • func (impl *CdWorkflowServiceImpl) CheckIfLatestWf(pipelineId, cdWfId int) (latest bool, err error)
  • 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)),
	NewCdWorkflowRunnerServiceImpl,
	wire.Bind(new(CdWorkflowRunnerService), new(*CdWorkflowRunnerServiceImpl)),
)

Types

type CdWorkflowCommonService

type CdWorkflowCommonService interface {
	UpdatePreviousDeploymentStatus(currentRunner *pipelineConfig.CdWorkflowRunner, pipelineId int, triggeredAt time.Time, triggeredBy int32) error
	MarkCurrentDeploymentFailed(runner *pipelineConfig.CdWorkflowRunner, releaseErr error, triggeredBy int32) error
	UpdateCDWorkflowRunnerStatus(ctx context.Context, overrideRequest *bean.ValuesOverrideRequest, triggeredAt time.Time, status, message string) 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) (*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) UpdateCDWorkflowRunnerStatus

func (impl *CdWorkflowCommonServiceImpl) UpdateCDWorkflowRunnerStatus(ctx context.Context, overrideRequest *bean.ValuesOverrideRequest, triggeredAt time.Time, status, message string) error

TODO: remove bean.ValuesOverrideRequest

func (*CdWorkflowCommonServiceImpl) UpdatePreviousDeploymentStatus

func (impl *CdWorkflowCommonServiceImpl) UpdatePreviousDeploymentStatus(currentRunner *pipelineConfig.CdWorkflowRunner, pipelineId int, triggeredAt time.Time, triggeredBy int32) error

type CdWorkflowRunnerService

type CdWorkflowRunnerService interface {
	FindWorkflowRunnerById(wfrId int) (*bean.CdWorkflowRunnerDto, error)
	CheckIfWfrLatest(wfrId, pipelineId int) (isLatest bool, err error)
}

type CdWorkflowRunnerServiceImpl

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

func NewCdWorkflowRunnerServiceImpl

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

func (*CdWorkflowRunnerServiceImpl) CheckIfWfrLatest

func (impl *CdWorkflowRunnerServiceImpl) CheckIfWfrLatest(wfrId, pipelineId int) (isLatest bool, err error)

func (*CdWorkflowRunnerServiceImpl) FindWorkflowRunnerById

func (impl *CdWorkflowRunnerServiceImpl) FindWorkflowRunnerById(wfrId int) (*bean.CdWorkflowRunnerDto, error)

type CdWorkflowService

type CdWorkflowService interface {
	CheckIfLatestWf(pipelineId, cdWfId int) (latest bool, err error)
	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) CheckIfLatestWf

func (impl *CdWorkflowServiceImpl) CheckIfLatestWf(pipelineId, cdWfId int) (latest bool, err error)

func (*CdWorkflowServiceImpl) UpdateWorkFlow

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