trigger

Documentation

Index

• Variables
• func SetGitCommitValuesForBuildingCommitHash(ciMaterial *pipelineConfig.CiPipelineMaterial, ...) pipelineConfig.GitCommit
• type BuildxCacheFlags
• type HandlerService
• type HandlerServiceImpl
  • func NewHandlerServiceImpl(Logger *zap.SugaredLogger, workflowService executor.WorkflowService, ...) *HandlerServiceImpl
  • func (impl *HandlerServiceImpl) BuildManualTriggerCommitHashesForSourceTypeBranchFix(ciPipelineMaterial bean.CiPipelineMaterial, ...) (pipelineConfig.GitCommit, error)
  • func (impl *HandlerServiceImpl) BuildManualTriggerCommitHashesForSourceTypeWebhook(ciPipelineMaterial bean.CiPipelineMaterial, ...) (pipelineConfig.GitCommit, map[string]string, error)
  • func (impl *HandlerServiceImpl) BuildPayload(trigger types.Trigger, pipeline *pipelineConfig.CiPipeline) *client.Payload
  • func (impl *HandlerServiceImpl) CancelBuild(workflowId int, forceAbort bool) (int, error)
  • func (impl *HandlerServiceImpl) CheckAndReTriggerCI(workflowStatus eventProcessorBean.CiCdStatus) error
  • func (impl *HandlerServiceImpl) DownloadCiWorkflowArtifacts(pipelineId int, buildId int) (*os.File, error)
  • func (impl *HandlerServiceImpl) GetCiMaterials(pipelineId int, ciMaterials []*pipelineConfig.CiPipelineMaterial) ([]*pipelineConfig.CiPipelineMaterial, error)
  • func (impl *HandlerServiceImpl) GetCiPipeline(ciMaterialId int) (*pipelineConfig.CiPipeline, error)
  • func (impl *HandlerServiceImpl) GetHistoricBuildLogs(workflowId int, ciWorkflow *pipelineConfig.CiWorkflow) (map[string]string, error)
  • func (impl *HandlerServiceImpl) GetRunningWorkflowLogs(workflowId int, followLogs bool) (*bufio.Reader, func() error, error)
  • func (impl *HandlerServiceImpl) GetWorkflowRequestVariablesForCopyContainerImagePlugin(preCiSteps []*pipelineConfigBean.StepObject, ...) (map[string][]string, map[string]bean2.RegistryCredentials, string, []int, ...)
  • func (impl *HandlerServiceImpl) HandleCIManual(ciTriggerRequest bean.CiTriggerRequest) (int, error)
  • func (impl *HandlerServiceImpl) HandleCIWebhook(gitCiTriggerRequest bean.GitCiTriggerRequest) (int, error)
  • func (impl *HandlerServiceImpl) HandlePodDeleted(ciWorkflow *pipelineConfig.CiWorkflow)
  • func (impl *HandlerServiceImpl) ReserveImagesGeneratedAtPlugin(customTagId int, destinationImages []string) ([]int, error)
  • func (impl *HandlerServiceImpl) StartCiWorkflowAndPrepareWfRequest(trigger types.Trigger) (*pipelineConfig.CiPipeline, map[string]string, *pipelineConfig.CiWorkflow, ...)

Variables

var WireSet = wire.NewSet(
	NewHandlerServiceImpl,
	wire.Bind(new(HandlerService), new(*HandlerServiceImpl)),
)

Functions

func SetGitCommitValuesForBuildingCommitHash

func SetGitCommitValuesForBuildingCommitHash(ciMaterial *pipelineConfig.CiPipelineMaterial, oldGitCommit pipelineConfig.GitCommit) pipelineConfig.GitCommit

Types

type BuildxCacheFlags

type BuildxCacheFlags struct {
	BuildxCacheModeMin     bool `env:"BUILDX_CACHE_MODE_MIN" envDefault:"false" description:"To set build cache mode to minimum in buildx" `
	AsyncBuildxCacheExport bool `env:"ASYNC_BUILDX_CACHE_EXPORT" envDefault:"false" description:"To enable async container image cache export"`
}

type HandlerService

type HandlerService interface {
	HandlePodDeleted(ciWorkflow *pipelineConfig.CiWorkflow)
	CheckAndReTriggerCI(workflowStatus eventProcessorBean.CiCdStatus) error
	HandleCIManual(ciTriggerRequest bean.CiTriggerRequest) (int, error)
	HandleCIWebhook(gitCiTriggerRequest bean.GitCiTriggerRequest) (int, error)

	StartCiWorkflowAndPrepareWfRequest(trigger types.Trigger) (*pipelineConfig.CiPipeline, map[string]string, *pipelineConfig.CiWorkflow, *types.WorkflowRequest, error)

	CancelBuild(workflowId int, forceAbort bool) (int, error)
	GetRunningWorkflowLogs(workflowId int, followLogs bool) (*bufio.Reader, func() error, error)
	GetHistoricBuildLogs(workflowId int, ciWorkflow *pipelineConfig.CiWorkflow) (map[string]string, error)
	DownloadCiWorkflowArtifacts(pipelineId int, buildId int) (*os.File, error)
}

type HandlerServiceImpl

type HandlerServiceImpl struct {
	Logger *zap.SugaredLogger

	K8sUtil *k8s.K8sServiceImpl
	// contains filtered or unexported fields
}

func NewHandlerServiceImpl

func NewHandlerServiceImpl(Logger *zap.SugaredLogger, workflowService executor.WorkflowService,
	ciPipelineMaterialRepository pipelineConfig.CiPipelineMaterialRepository,
	ciPipelineRepository pipelineConfig.CiPipelineRepository,
	ciArtifactRepository repository5.CiArtifactRepository,
	pipelineStageService pipeline2.PipelineStageService,
	userService user.UserService,
	ciTemplateService pipeline.CiTemplateReadService,
	appCrudOperationService app.AppCrudOperationService,
	envRepository repository6.EnvironmentRepository,
	appRepository appRepository.AppRepository,
	scopedVariableManager variables.ScopedVariableManager,
	customTagService pipeline2.CustomTagService,
	ciCdPipelineOrchestrator pipeline2.CiCdPipelineOrchestrator, attributeService attributes.AttributesService,
	pluginInputVariableParser pipeline2.PluginInputVariableParser,
	globalPluginService plugin.GlobalPluginService,
	ciService pipeline2.CiService,
	ciWorkflowRepository pipelineConfig.CiWorkflowRepository,
	gitSensorClient gitSensor.Client,
	ciLogService pipeline2.CiLogService,
	blobConfigStorageService pipeline2.BlobStorageConfigService,
	clusterService cluster.ClusterService,
	envService environment.EnvironmentService,
	K8sUtil *k8s.K8sServiceImpl,
	asyncRunnable *async.Runnable,
) *HandlerServiceImpl

func (*HandlerServiceImpl) BuildManualTriggerCommitHashesForSourceTypeBranchFix

func (impl *HandlerServiceImpl) BuildManualTriggerCommitHashesForSourceTypeBranchFix(ciPipelineMaterial bean.CiPipelineMaterial, pipeLineMaterialFromDb *pipelineConfig.CiPipelineMaterial) (pipelineConfig.GitCommit, error)

func (*HandlerServiceImpl) BuildManualTriggerCommitHashesForSourceTypeWebhook

func (impl *HandlerServiceImpl) BuildManualTriggerCommitHashesForSourceTypeWebhook(ciPipelineMaterial bean.CiPipelineMaterial, pipeLineMaterialFromDb *pipelineConfig.CiPipelineMaterial) (pipelineConfig.GitCommit, map[string]string, error)

func (*HandlerServiceImpl) BuildPayload

func (impl *HandlerServiceImpl) BuildPayload(trigger types.Trigger, pipeline *pipelineConfig.CiPipeline) *client.Payload

TODO: Send all trigger data

func (*HandlerServiceImpl) CancelBuild

func (impl *HandlerServiceImpl) CancelBuild(workflowId int, forceAbort bool) (int, error)

func (*HandlerServiceImpl) CheckAndReTriggerCI

func (impl *HandlerServiceImpl) CheckAndReTriggerCI(workflowStatus eventProcessorBean.CiCdStatus) error

func (*HandlerServiceImpl) DownloadCiWorkflowArtifacts

func (impl *HandlerServiceImpl) DownloadCiWorkflowArtifacts(pipelineId int, buildId int) (*os.File, error)

func (*HandlerServiceImpl) GetCiMaterials

func (impl *HandlerServiceImpl) GetCiMaterials(pipelineId int, ciMaterials []*pipelineConfig.CiPipelineMaterial) ([]*pipelineConfig.CiPipelineMaterial, error)

func (*HandlerServiceImpl) GetCiPipeline

func (impl *HandlerServiceImpl) GetCiPipeline(ciMaterialId int) (*pipelineConfig.CiPipeline, error)

func (*HandlerServiceImpl) GetHistoricBuildLogs

func (impl *HandlerServiceImpl) GetHistoricBuildLogs(workflowId int, ciWorkflow *pipelineConfig.CiWorkflow) (map[string]string, error)

func (*HandlerServiceImpl) GetRunningWorkflowLogs

func (impl *HandlerServiceImpl) GetRunningWorkflowLogs(workflowId int, followLogs bool) (*bufio.Reader, func() error, error)

func (*HandlerServiceImpl) GetWorkflowRequestVariablesForCopyContainerImagePlugin

func (impl *HandlerServiceImpl) GetWorkflowRequestVariablesForCopyContainerImagePlugin(preCiSteps []*pipelineConfigBean.StepObject, postCiSteps []*pipelineConfigBean.StepObject, customTag string, customTagId int, buildImagePath string, buildImagedockerRegistryId string) (map[string][]string, map[string]bean2.RegistryCredentials, string, []int, error)

func (*HandlerServiceImpl) HandleCIManual

func (impl *HandlerServiceImpl) HandleCIManual(ciTriggerRequest bean.CiTriggerRequest) (int, error)

func (*HandlerServiceImpl) HandleCIWebhook

func (impl *HandlerServiceImpl) HandleCIWebhook(gitCiTriggerRequest bean.GitCiTriggerRequest) (int, error)

func (*HandlerServiceImpl) HandlePodDeleted

func (impl *HandlerServiceImpl) HandlePodDeleted(ciWorkflow *pipelineConfig.CiWorkflow)

func (*HandlerServiceImpl) ReserveImagesGeneratedAtPlugin

func (impl *HandlerServiceImpl) ReserveImagesGeneratedAtPlugin(customTagId int, destinationImages []string) ([]int, error)

func (*HandlerServiceImpl) StartCiWorkflowAndPrepareWfRequest

func (impl *HandlerServiceImpl) StartCiWorkflowAndPrepareWfRequest(trigger types.Trigger) (*pipelineConfig.CiPipeline, map[string]string, *pipelineConfig.CiWorkflow, *types.WorkflowRequest, error)