out

Documentation

Index

• Variables
• type WorkflowEventPublishService
• type WorkflowEventPublishServiceImpl
  • func NewWorkflowEventPublishServiceImpl(logger *zap.SugaredLogger, pubSubClient *pubsub.PubSubClientServiceImpl, ...) (*WorkflowEventPublishServiceImpl, error)
  • func (impl *WorkflowEventPublishServiceImpl) TriggerBulkDeploymentAsync(requests []*bean.BulkTriggerRequest, UserId int32) (interface{}, error)
  • func (impl *WorkflowEventPublishServiceImpl) TriggerBulkHibernateAsync(request bean.StopDeploymentGroupRequest) (interface{}, error)
  • func (impl *WorkflowEventPublishServiceImpl) TriggerHelmAsyncRelease(overrideRequest *bean3.ValuesOverrideRequest, ctx context.Context, ...) (releaseNo int, manifest []byte, err error)
  • func (impl *WorkflowEventPublishServiceImpl) UpdatePreviousQueuedRunnerStatus(cdWfrId, pipelineId int, triggeredBy int32) error

Variables

var EventProcessorOutWireSet = wire.NewSet(
	NewWorkflowEventPublishServiceImpl,
	wire.Bind(new(WorkflowEventPublishService), new(*WorkflowEventPublishServiceImpl)),
)

Types

type WorkflowEventPublishService

type WorkflowEventPublishService interface {
	TriggerBulkHibernateAsync(request bean.StopDeploymentGroupRequest) (interface{}, error)
	TriggerHelmAsyncRelease(overrideRequest *bean3.ValuesOverrideRequest, ctx context.Context, triggeredAt time.Time,
		triggeredBy int32) (releaseNo int, manifest []byte, err error)
	TriggerBulkDeploymentAsync(requests []*bean.BulkTriggerRequest, UserId int32) (interface{}, error)
}

type WorkflowEventPublishServiceImpl

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

func NewWorkflowEventPublishServiceImpl

func NewWorkflowEventPublishServiceImpl(logger *zap.SugaredLogger,
	pubSubClient *pubsub.PubSubClientServiceImpl,
	cdWorkflowCommonService cd.CdWorkflowCommonService,
	deployedConfigurationHistoryService history.DeployedConfigurationHistoryService,
	manifestCreationService manifest.ManifestCreationService,
	pipelineStatusTimelineService status.PipelineStatusTimelineService,

	cdWorkflowRepository pipelineConfig.CdWorkflowRepository,
	pipelineRepository pipelineConfig.PipelineRepository,
	groupRepository repository.DeploymentGroupRepository) (*WorkflowEventPublishServiceImpl, error)

func (*WorkflowEventPublishServiceImpl) TriggerBulkDeploymentAsync

func (impl *WorkflowEventPublishServiceImpl) TriggerBulkDeploymentAsync(requests []*bean.BulkTriggerRequest, UserId int32) (interface{}, error)

func (*WorkflowEventPublishServiceImpl) TriggerBulkHibernateAsync

func (impl *WorkflowEventPublishServiceImpl) TriggerBulkHibernateAsync(request bean.StopDeploymentGroupRequest) (interface{}, error)

func (*WorkflowEventPublishServiceImpl) TriggerHelmAsyncRelease

func (impl *WorkflowEventPublishServiceImpl) TriggerHelmAsyncRelease(overrideRequest *bean3.ValuesOverrideRequest, ctx context.Context, triggeredAt time.Time, triggeredBy int32) (releaseNo int, manifest []byte, err error)

TriggerHelmAsyncRelease will publish async helm Install/Upgrade request event for Devtron App releases

func (*WorkflowEventPublishServiceImpl) UpdatePreviousQueuedRunnerStatus

func (impl *WorkflowEventPublishServiceImpl) UpdatePreviousQueuedRunnerStatus(cdWfrId, pipelineId int, triggeredBy int32) error