in

package
v1.5.1 Latest Latest
Warning

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

 Go to latest Published: May 8, 2025 License: Apache-2.0 Imports: 64 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var EventProcessorInWireSet = wire.NewSet(
	NewCIPipelineEventProcessorImpl,
	NewWorkflowEventProcessorImpl,
	NewDeployedApplicationEventProcessorImpl,
	NewCDPipelineEventProcessorImpl,
	NewAppStoreAppsEventProcessorImpl,
)

Functions

This section is empty.

Types

type AppStoreAppsEventProcessorImpl added in v0.7.0 

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

func NewAppStoreAppsEventProcessorImpl added in v0.7.0 

func NewAppStoreAppsEventProcessorImpl(logger *zap.SugaredLogger,
	pubSubClient *pubsub.PubSubClientServiceImpl,
	chartGroupService chartGroup.ChartGroupService,
	iavHistoryRepository repository.InstalledAppVersionHistoryRepository) *AppStoreAppsEventProcessorImpl

func (*AppStoreAppsEventProcessorImpl) SubscribeAppStoreAppsBulkDeployEvent added in v0.7.0 

func (impl *AppStoreAppsEventProcessorImpl) SubscribeAppStoreAppsBulkDeployEvent() error

func (*AppStoreAppsEventProcessorImpl) SubscribeHelmInstallStatusEvent added in v0.7.0 

func (impl *AppStoreAppsEventProcessorImpl) SubscribeHelmInstallStatusEvent() error

type CDPipelineEventProcessorImpl added in v0.7.0 

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

func NewCDPipelineEventProcessorImpl added in v0.7.0 

func NewCDPipelineEventProcessorImpl(logger *zap.SugaredLogger,
	pubSubClient *pubsub.PubSubClientServiceImpl,
	cdWorkflowCommonService cd.CdWorkflowCommonService,
	workflowStatusService status.WorkflowStatusService,
	cdHandlerService devtronApps.HandlerService,
	pipelineRepository pipelineConfig.PipelineRepository,
	installedAppReadService installedAppReader.InstalledAppReadService) *CDPipelineEventProcessorImpl

func (*CDPipelineEventProcessorImpl) SubscribeArgoTypePipelineSyncEvent added in v0.7.0 

func (impl *CDPipelineEventProcessorImpl) SubscribeArgoTypePipelineSyncEvent() error

func (*CDPipelineEventProcessorImpl) SubscribeCDBulkTriggerTopic added in v0.7.0 

func (impl *CDPipelineEventProcessorImpl) SubscribeCDBulkTriggerTopic() error

type CIPipelineEventProcessorImpl added in v0.7.0 

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

func NewCIPipelineEventProcessorImpl added in v0.7.0 

func NewCIPipelineEventProcessorImpl(logger *zap.SugaredLogger, pubSubClient *pubsub.PubSubClientServiceImpl,
	gitWebhookService gitWebhook.GitWebhookService) *CIPipelineEventProcessorImpl

func (*CIPipelineEventProcessorImpl) SubscribeNewCIMaterialEvent added in v0.7.0 

func (impl *CIPipelineEventProcessorImpl) SubscribeNewCIMaterialEvent() error

type DeployedApplicationEventProcessorImpl added in v0.7.0 

type DeployedApplicationEventProcessorImpl struct {
	DeploymentConfigService common.DeploymentConfigService
	// contains filtered or unexported fields
}

func NewDeployedApplicationEventProcessorImpl added in v0.7.0 

func NewDeployedApplicationEventProcessorImpl(logger *zap.SugaredLogger,
	pubSubClient *pubsub.PubSubClientServiceImpl,
	appService app.AppService,
	gitOpsConfigReadService config.GitOpsConfigReadService,
	installedAppService FullMode.InstalledAppDBExtendedService,
	workflowDagExecutor dag.WorkflowDagExecutor,
	cdWorkflowCommonService cd.CdWorkflowCommonService,
	pipelineBuilder pipeline.PipelineBuilder,
	appStoreDeploymentService service.AppStoreDeploymentService,
	pipelineRepository pipelineConfig.PipelineRepository,
	installedAppReadService installedAppReader.InstalledAppReadService,
	DeploymentConfigService common.DeploymentConfigService) *DeployedApplicationEventProcessorImpl

func (*DeployedApplicationEventProcessorImpl) SubscribeArgoAppDeleteStatus added in v0.7.0 

func (impl *DeployedApplicationEventProcessorImpl) SubscribeArgoAppDeleteStatus() error

func (*DeployedApplicationEventProcessorImpl) SubscribeArgoAppUpdate added in v0.7.0 

func (impl *DeployedApplicationEventProcessorImpl) SubscribeArgoAppUpdate() error

type WorkflowEventProcessorImpl 

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

func NewWorkflowEventProcessorImpl 

func NewWorkflowEventProcessorImpl(logger *zap.SugaredLogger,
	pubSubClient *pubsub.PubSubClientServiceImpl,
	cdWorkflowService cd.CdWorkflowService,
	cdWorkflowReadService read.CdWorkflowReadService,
	cdWorkflowRunnerService cd.CdWorkflowRunnerService,
	cdWorkflowRunnerReadService read.CdWorkflowRunnerReadService,
	workflowDagExecutor dag.WorkflowDagExecutor,
	ciHandler pipeline.CiHandler, cdHandler pipeline.CdHandler,
	eventFactory client.EventFactory, eventClient client.EventClient,
	cdHandlerService devtronApps.HandlerService,
	deployedAppService deployedApp.DeployedAppService,
	webhookService pipeline.WebhookService,
	validator *validator.Validate,
	envVariables *globalUtil.EnvironmentVariables,
	cdWorkflowCommonService cd.CdWorkflowCommonService,
	cdPipelineConfigService pipeline.CdPipelineConfigService,
	userDeploymentRequestService service.UserDeploymentRequestService,
	ucid ucid.Service,
	pipelineRepository pipelineConfig.PipelineRepository,
	ciArtifactRepository repository.CiArtifactRepository,
	cdWorkflowRepository pipelineConfig.CdWorkflowRepository,
	deploymentConfigService common.DeploymentConfigService,
	ciHandlerService trigger.HandlerService) (*WorkflowEventProcessorImpl, error)

func (*WorkflowEventProcessorImpl) BuildCiArtifactRequest 

func (impl *WorkflowEventProcessorImpl) BuildCiArtifactRequest(event bean.CiCompleteEvent) (*wrokflowDagBean.CiArtifactWebhookRequest, error)

func (*WorkflowEventProcessorImpl) ProcessConcurrentAsyncDeploymentReq added in v0.7.1 

func (impl *WorkflowEventProcessorImpl) ProcessConcurrentAsyncDeploymentReq(ctx context.Context, cdAsyncInstallReq *bean.UserDeploymentRequest) error

func (*WorkflowEventProcessorImpl) ProcessIncompleteDeploymentReq added in v0.7.1 

func (impl *WorkflowEventProcessorImpl) ProcessIncompleteDeploymentReq()

func (*WorkflowEventProcessorImpl) RemoveReleaseContextForPipeline added in v0.7.0 

func (impl *WorkflowEventProcessorImpl) RemoveReleaseContextForPipeline(pipelineId int, triggeredBy int32)

func (*WorkflowEventProcessorImpl) ShutDownDevtronAppReleaseContext added in v0.7.1 

func (impl *WorkflowEventProcessorImpl) ShutDownDevtronAppReleaseContext()

func (*WorkflowEventProcessorImpl) SubscribeCDPipelineDeleteEvent added in v0.7.0 

func (impl *WorkflowEventProcessorImpl) SubscribeCDPipelineDeleteEvent() error

func (*WorkflowEventProcessorImpl) SubscribeCDStageCompleteEvent 

func (impl *WorkflowEventProcessorImpl) SubscribeCDStageCompleteEvent() error

func (*WorkflowEventProcessorImpl) SubscribeCDWorkflowStatusUpdate 

func (impl *WorkflowEventProcessorImpl) SubscribeCDWorkflowStatusUpdate() error

func (*WorkflowEventProcessorImpl) SubscribeCICompleteEvent 

func (impl *WorkflowEventProcessorImpl) SubscribeCICompleteEvent() error

func (*WorkflowEventProcessorImpl) SubscribeCIWorkflowStatusUpdate 

func (impl *WorkflowEventProcessorImpl) SubscribeCIWorkflowStatusUpdate() error

func (*WorkflowEventProcessorImpl) SubscribeDevtronAsyncInstallRequest added in v0.7.1 

func (impl *WorkflowEventProcessorImpl) SubscribeDevtronAsyncInstallRequest() error

func (*WorkflowEventProcessorImpl) SubscribeHibernateBulkAction 

func (impl *WorkflowEventProcessorImpl) SubscribeHibernateBulkAction() error

func (*WorkflowEventProcessorImpl) SubscribeTriggerBulkAction 

func (impl *WorkflowEventProcessorImpl) SubscribeTriggerBulkAction() error

func (*WorkflowEventProcessorImpl) UpdateReleaseContextForPipeline added in v0.7.0 

func (impl *WorkflowEventProcessorImpl) UpdateReleaseContextForPipeline(ctx context.Context, pipelineId, cdWfrId int, cancelWithCause context.CancelCauseFunc, cancelParentCtx context.CancelFunc)

Source Files

View all Source files

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.