cd

package
v0.7.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 10, 2024 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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)),
)

Functions

This section is empty.

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) (*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 added in v0.7.1 

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

func (*CdWorkflowCommonServiceImpl) SupersedePreviousDeployments added in v0.7.1 

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

func (*CdWorkflowCommonServiceImpl) UpdateNonTerminalStatusInRunner added in v0.7.1 

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

func (*CdWorkflowCommonServiceImpl) UpdatePreviousQueuedRunnerStatus added in v0.7.1 

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

type CdWorkflowRunnerService 

type CdWorkflowRunnerService interface {
	FindWorkflowRunnerById(wfrId int) (*bean.CdWorkflowRunnerDto, error)
	CheckIfWfrLatest(wfrId, pipelineId int) (isLatest bool, err error)
	UpdateWfrStatus(dto *bean.CdWorkflowRunnerDto, status string, updatedBy int) 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 added in v0.7.0 

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

func (*CdWorkflowRunnerServiceImpl) FindWorkflowRunnerById 

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

func (*CdWorkflowRunnerServiceImpl) UpdateWfrStatus added in v0.7.1 

func (impl *CdWorkflowRunnerServiceImpl) UpdateWfrStatus(dto *bean.CdWorkflowRunnerDto, status string, updatedBy int) 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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.