in

Documentation

Index

• Variables
• type WorkflowEventProcessorImpl
  • func NewWorkflowEventProcessorImpl(logger *zap.SugaredLogger, pubSubClient *pubsub.PubSubClientServiceImpl, ...) (*WorkflowEventProcessorImpl, error)
  • func (impl *WorkflowEventProcessorImpl) BuildCIArtifactRequestForImageFromCR(imageDetails types.ImageDetail, region string, event bean.CiCompleteEvent, ...) (*bean8.CiArtifactWebhookRequest, error)
  • func (impl *WorkflowEventProcessorImpl) BuildCiArtifactRequest(event bean.CiCompleteEvent) (*bean8.CiArtifactWebhookRequest, error)
  • func (impl *WorkflowEventProcessorImpl) SubscribeCDStageCompleteEvent() error
  • func (impl *WorkflowEventProcessorImpl) SubscribeCDWorkflowStatusUpdate() error
  • func (impl *WorkflowEventProcessorImpl) SubscribeCICompleteEvent() error
  • func (impl *WorkflowEventProcessorImpl) SubscribeCIWorkflowStatusUpdate() error
  • func (impl *WorkflowEventProcessorImpl) SubscribeHibernateBulkAction() error
  • func (impl *WorkflowEventProcessorImpl) SubscribeTriggerBulkAction() error
  • func (impl *WorkflowEventProcessorImpl) ValidateAndHandleCiSuccessEvent(triggerContext bean5.TriggerContext, ciPipelineId int, ...) (int, error)

Variables

var EventProcessorInWireSet = wire.NewSet(
	NewWorkflowEventProcessorImpl,
)

Types

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,
	globalEnvVariables *util2.GlobalEnvVariables,
	cdWorkflowCommonService cd.CdWorkflowCommonService,
	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) 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) SubscribeHibernateBulkAction

func (impl *WorkflowEventProcessorImpl) SubscribeHibernateBulkAction() error

func (*WorkflowEventProcessorImpl) SubscribeTriggerBulkAction

func (impl *WorkflowEventProcessorImpl) SubscribeTriggerBulkAction() error

func (*WorkflowEventProcessorImpl) ValidateAndHandleCiSuccessEvent

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