Help us shape the future of Go! Take the 2026 Go Developer Survey

cd

package
v1.8.2 Latest Latest
Warning

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

 Go to latest Published: Oct 1, 2025 License: Apache-2.0 Imports: 31 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)),
	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)),
)

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,
	deploymentConfigService common2.DeploymentConfigService,
	cdWorkflowRunnerService CdWorkflowRunnerService) (*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 {
	UpdateWfr(dto *bean.CdWorkflowRunnerDto, updatedBy int) error
	SaveWfr(tx *pg.Tx, wfr *pipelineConfig.CdWorkflowRunner) error
	UpdateIsArtifactUploaded(wfrId int, isArtifactUploaded bool) error
	SaveCDWorkflowRunnerWithStage(wfr *pipelineConfig.CdWorkflowRunner, cdWf *pipelineConfig.CdWorkflow, pipeline *pipelineConfig.Pipeline) (*pipelineConfig.CdWorkflowRunner, error)
	UpdateCdWorkflowRunnerWithStage(wfr *pipelineConfig.CdWorkflowRunner) error
	GetPrePostWorkflowStagesByWorkflowRunnerIdsList(wfIdWfTypeMap map[int]bean4.CdWorkflowWithArtifact) (map[int]map[string][]*bean3.WorkflowStageDto, error)
}

type CdWorkflowRunnerServiceImpl 

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

func NewCdWorkflowRunnerServiceImpl 

func NewCdWorkflowRunnerServiceImpl(logger *zap.SugaredLogger,
	cdWorkflowRepository pipelineConfig.CdWorkflowRepository,
	workflowStageService workflowStatus.WorkFlowStageStatusService,
	transactionManager sql.TransactionWrapper,
	workflowStatusLatestService workflowStatusLatest.WorkflowStatusLatestService) *CdWorkflowRunnerServiceImpl

func (*CdWorkflowRunnerServiceImpl) GetPrePostWorkflowStagesByWorkflowRunnerIdsList added in v1.3.0 

func (impl *CdWorkflowRunnerServiceImpl) GetPrePostWorkflowStagesByWorkflowRunnerIdsList(wfIdWfTypeMap map[int]bean4.CdWorkflowWithArtifact) (map[int]map[string][]*bean3.WorkflowStageDto, error)

func (*CdWorkflowRunnerServiceImpl) SaveCDWorkflowRunnerWithStage added in v1.3.0 

func (impl *CdWorkflowRunnerServiceImpl) SaveCDWorkflowRunnerWithStage(wfr *pipelineConfig.CdWorkflowRunner, cdWf *pipelineConfig.CdWorkflow, pipeline *pipelineConfig.Pipeline) (*pipelineConfig.CdWorkflowRunner, error)

func (*CdWorkflowRunnerServiceImpl) SaveWfr added in v1.8.0 

func (impl *CdWorkflowRunnerServiceImpl) SaveWfr(tx *pg.Tx, wfr *pipelineConfig.CdWorkflowRunner) error

func (*CdWorkflowRunnerServiceImpl) UpdateCdWorkflowRunnerWithStage added in v1.3.0 

func (impl *CdWorkflowRunnerServiceImpl) UpdateCdWorkflowRunnerWithStage(wfr *pipelineConfig.CdWorkflowRunner) error

func (*CdWorkflowRunnerServiceImpl) UpdateIsArtifactUploaded added in v1.0.0 

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

func (*CdWorkflowRunnerServiceImpl) UpdateWfr added in v1.0.0 

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

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.