cd

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 struct {
	// contains filtered or unexported fields
}

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

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

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

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