in

package
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: Jun 7, 2024 License: Apache-2.0 Imports: 53 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,
	cdTriggerService devtronApps.TriggerService,
	argoUserService argo.ArgoUserService,
	pipelineRepository pipelineConfig.PipelineRepository,
	installedAppRepository repository2.InstalledAppRepository) *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 git.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 {
	// 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,
	installedAppRepository repository.InstalledAppRepository) *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,
	cdWorkflowRunnerService cd.CdWorkflowRunnerService,
	workflowDagExecutor dag.WorkflowDagExecutor,
	argoUserService argo.ArgoUserService,
	ciHandler pipeline.CiHandler, cdHandler pipeline.CdHandler,
	eventFactory client.EventFactory, eventClient client.EventClient,
	cdTriggerService devtronApps.TriggerService,
	deployedAppService deployedApp.DeployedAppService,
	webhookService pipeline.WebhookService,
	validator *validator.Validate,
	envVariables *util2.EnvironmentVariables,
	cdWorkflowCommonService cd.CdWorkflowCommonService,
	cdPipelineConfigService pipeline.CdPipelineConfigService,
	pipelineRepository pipelineConfig.PipelineRepository,
	ciArtifactRepository repository.CiArtifactRepository,
	cdWorkflowRepository pipelineConfig.CdWorkflowRepository) (*WorkflowEventProcessorImpl, error)

func (*WorkflowEventProcessorImpl) BuildCIArtifactRequestForImageFromCR 

func (impl *WorkflowEventProcessorImpl) BuildCIArtifactRequestForImageFromCR(imageDetails types.ImageDetail, region string, event bean.CiCompleteEvent, workflowId int) (*bean8.CiArtifactWebhookRequest, error)

func (*WorkflowEventProcessorImpl) BuildCiArtifactRequest 

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

func (*WorkflowEventProcessorImpl) RemoveReleaseContextForPipeline added in v0.7.0 

func (impl *WorkflowEventProcessorImpl) RemoveReleaseContextForPipeline(cdPipelineDeleteEvent *bean7.CdPipelineDeleteEvent)

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) SubscribeDevtronAsyncHelmInstallRequest added in v0.7.0 

func (impl *WorkflowEventProcessorImpl) SubscribeDevtronAsyncHelmInstallRequest() 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(pipelineId, cdWfrId int, cancel context.CancelFunc)

func (*WorkflowEventProcessorImpl) ValidateAndHandleCiSuccessEvent 

func (impl *WorkflowEventProcessorImpl) ValidateAndHandleCiSuccessEvent(triggerContext bean5.TriggerContext, ciPipelineId int, request *bean8.CiArtifactWebhookRequest, imagePushedAt *time.Time) (int, error)

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.